1 public class Send {//发送端 2 p睿共享 ublic static void main(String[] args) throws IOException { 3 DatagramSocket socket = new DatagramSocket(888);//创建socket相当于创建码头 4 5 BufferedReader reader = new BufferedReader(new InputStreamR睿共享 eader(Syste睿共享 m.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 pub睿共享 lic 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.close(); 24 } 25 }
在控制台输入