1 public class Send {//发送端 2 public static void main(String[] args) throws IOException { 3 DatagramSocket socket = new DatagramSocket(888);//创建socket相当于创建码头 4 5 Bu睿共享 fferedReader reader = new BufferedReader(new InputStreamReader(System.in)); 6 while(true) { 7 String data = reader.readLine(); 8 byte[] datas = data.getBytes(); 9 10 DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress("localhost", 666));//创建packet相当于创建集装箱 11 socket.send(packet);//接货 12 if (data.equals("bye")){ 13 break; 14 } 15 16 } 17 socket.close(); 18 } 19睿共享 }
1 //接收端睿共享 2 public class Receiving { 3 public static void main(String[] args) throws IOException { 4 DatagramSocket socket = new DatagramSocket(666); 5 6 while(true) { 7睿共享 byte[] container = new byte[1024]; 8 9 DatagramPacket packet = new DatagramPacket(container,0,container.length); 10 socket.receive(packet); 11 12 //断开连接 bye 13 byte[] data = packet.getData(); 14 String receiveData = new String(data, 0, data.length); 15 16 System.out.println(receiveData); 17 18 if (receiveData.equals("bye")){ 19 break; 20 } 21 socket.receive(packet);//阻塞接收包裹 22 } 23 socket.clos睿共享 e(); 24 } 25 }
在控制台输入