成都最好的网站建设,国外做调灵风暴的网站,电子商务网站设计书,企业工商信息查询网UDP协议是一个不安全、不连续的#xff0c;把数据发送出去之后就结束了#xff0c;根本不管对方有没有接收到。 快递员#xff1a;DatagramSocket 包裹#xff1a;DatagramPacket
原理就是将数据以及对方的信息都放到包裹里面#xff0c;然后让快递员发送给对应的人。… 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内然后0length是需要的数据信息然后转为字符串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 MapString, 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());MapString, String data new HashMapString, 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) {MapString, 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 ListMapString, String datalist;public ServerSendThread(DatagramSocket ds, ListMapString,String datalist) {this.ds ds;this.datalist datalist;}Overridepublic void run() {UDPsendMsg sendMsg new UDPsendMsg();
while(true){MapString, String data sendMsg.receMsg(ds);String msg data.get(msg);MapString, String d new HashMapString, 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(MapString, 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);ListMapString, String list new ArrayListMapString, String();new ServerSendThread(ds, list).start();}
}
