• UDP协议是一个不安全、不连续的，把数据发送出去之后就结束了，根本不管对方有没有接收到。

• 快递员：DatagramSocket

• 包裹：DatagramPacket

原理就是将数据以及对方的信息都放到包裹里面，然后让快递员发送给对应的人。

1、UDP传输数据

/*
DatagramSocket ds = new DatagramSocket(port); // 创建一个快递员，这个端口是自己开放的端口，用来接收和发送数据的。
别人给你发消息，就是给你这个端口发送数据。
然后你这个端口的快递员就可以拿到快递。
*/
public class UDPsendMsg {public void sendMsg(DatagramSocket ds, int port, String host, String msg){ // 发送信息byte[] bs = msg.getBytes(); // UDP传输只能传输字节流，所以需要将信息先转为byte数组DatagramPacket dp; // 创建一个包裹，用来存放需要发送的数据以及目标信息try {//  length是为了让对方知道你传输的数据长度dp = new DatagramPacket(bs, bs.length, InetAddress.getByName(host), port); // 将数据以及目标信息放进包裹ds.send(dp); // 通过快递员ds发送包裹} catch (UnknownHostException e) {throw new RuntimeException(e);} catch (IOException e) {throw new RuntimeException(e);}}public String receMsg(DatagramSocket ds) { // 接收信息byte[] bs = new byte[1024]; // 用来存放接收的信息DatagramPacket dp = new DatagramPacket(bs, 1024); // 先创建一个新包裹try {ds.receive(dp); // 接收快递员ds的快递，放到dp包裹里} catch (IOException e) {throw new RuntimeException(e);}String msg = new String(bs, 0, dp.getLength()); // 数据在bs内，然后0，length是需要的数据信息，然后转为字符串return msg; }
}

2、练习

• 实现一个多人聊天室内，跟之前的TCP多人聊天室功能相同

• DatagramPacket包裹类通过快递员类得到包裹之后包裹类是有对方的host 、port等信息的。

public class UDPsendMsg { // 首先创建了一个工具类，用来发送和接收消息方法的封装调用public void sendMsg(DatagramSocket ds, int port, String host, String msg){byte[] bs = msg.getBytes();DatagramPacket dp;try {dp = new DatagramPacket(bs, bs.length, InetAddress.getByName(host), port);// 3.把包裹发送出去ds.send(dp);} catch (UnknownHostException e) {throw new RuntimeException(e);} catch (IOException e) {throw new RuntimeException(e);}}public Map<String, String> receMsg(DatagramSocket ds) {byte[] bs = new byte[1024];DatagramPacket dp = new DatagramPacket(bs, 1024);try {ds.receive(dp);} catch (IOException e) {throw new RuntimeException(e);}String msg = new String(bs, 0, dp.getLength());Map<String, String> data = new HashMap<String, String>();data.put("msg", msg);data.put("port", String.valueOf(dp.getPort()));data.put("ip", dp.getAddress().toString().substring(1));return data;}
}
​
public class ReceThread extends Thread { // 实现客户端接收信息的线程private DatagramSocket ds;
​public ReceThread(DatagramSocket ds) {this.ds = ds;}
​@Overridepublic void run() {UDPsendMsg sendMsg = new UDPsendMsg();while(true) {Map<String, String> data = sendMsg.receMsg(ds);String str = (String)data.get("msg");System.out.println(str);}}
}
​
public class SendThread extends Thread { // 实现客户端发送信息的线程private DatagramSocket ds;public SendThread(DatagramSocket ds) {this.ds = ds;}@Overridepublic void run() {Scanner sc = new Scanner(System.in);UDPsendMsg sendMsg = new UDPsendMsg();System.out.println("可以进行聊天了！！");sendMsg.sendMsg(ds, 9999, "127.0.0.1", "asdf");while(true) {String str = sc.nextLine();sendMsg.sendMsg(ds, 9999, "127.0.0.1", str);}}
}
​
public class Client { // 实现客户端public static void main(String[] args) throws SocketException {Scanner sc  = new Scanner(System.in);System.out.println("请输入你使用的端口号：");int port = Integer.parseInt(sc.nextLine());DatagramSocket ds = new DatagramSocket(port);new ReceThread(ds).start();new SendThread(ds).start();}
}
​
public class ServerSendThread extends Thread { // 实现服务端的接收消息后发送给其它消息的线程private DatagramSocket ds;private List<Map<String, String>> datalist;public ServerSendThread(DatagramSocket ds, List<Map<String,String>> datalist) {this.ds = ds;this.datalist = datalist;}@Overridepublic void run() {UDPsendMsg sendMsg = new UDPsendMsg();
​while(true){Map<String, String> data = sendMsg.receMsg(ds);String msg = data.get("msg");Map<String, String> d = new HashMap<String, String>();d.put("port", data.get("port"));d.put("host", data.get("ip"));msg = data.get("ip") + "/" + data.get("port") + ": " + msg;if(!datalist.contains(d)) {// 聊天室内加入一个新成员System.out.println("聊天室内加入一个新成员" + d.get("host") + ":"+ d.get("port"));datalist.add(d);msg = "聊天室内加入一个新成员：" + data.get("ip") + "/" + data.get("port");}for(Map<String, String> da : datalist){if(!d.equals(da)) {sendMsg.sendMsg(ds, Integer.parseInt(da.get("port")), da.get("host"), msg);}}}}
}
​
public class Server { // 实现服务器端public static void main(String[] args) throws SocketException {DatagramSocket ds = new DatagramSocket(9999);List<Map<String, String>> list = new ArrayList<Map<String, String>>();new ServerSendThread(ds, list).start();}
}