测试类：

1. package com.kxg_05;
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.DatagramSocket;
   
5. 
   
6. public class ChatRoom {
   
7.         public static void main(String[] args) throws IOException {
   
8.                 DatagramSocket dsSend = new DatagramSocket();
   
9.                 DatagramSocket dsReceive = new DatagramSocket(48264);
   
10. 
    
11.                 SendThread st = new SendThread(dsSend);
    
12.                 ReceiveThread rt = new ReceiveThread(dsReceive);
    
13. 
    
14.                 Thread t1 = new Thread(st);
    
15.                 Thread t2 = new Thread(rt);
    
16. 
    
17.                 t1.start();
    
18.                 t2.start();
    
19.         }
    
20. }

复制代码

发送端类：

1. package com.kxg_05;
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. import java.util.Scanner;
   
8. 
   
9. public class SendThread implements Runnable {
   
10.         private DatagramSocket ds;
    
11. 
    
12.         public SendThread(DatagramSocket ds) {
    
13.                 this.ds = ds;
    
14.         }
    
15. 
    
16.         @Override
    
17.         public void run() {
    
18.                 try {
    
19.                 Scanner sc = new Scanner(System.in);
    
20.                 String s = null;
    
21.                         while ((s = sc.nextLine()) != null) {
    
22.                         byte[] bys = s.getBytes();
    
23.                         DatagramPacket dp = new DatagramPacket(bys, bys.length,
    
24.                                         InetAddress.getByName("10.164.22.254"), 48264);
    
25.                                 ds.send(dp);
    
26.                                 if (s.equals("我下了")) {
    
27.                                         break;
    
28.                                 }
    
29.                         }
    
30.                         ds.close();
    
31.                 } catch (IOException e) {
    
32.                         e.printStackTrace();
    
33.                 }
    
34.         }
    
35. }

复制代码

接收端类：

1. package com.kxg_05;
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. 
   
7. public class ReceiveThread implements Runnable {
   
8.         private DatagramSocket ds;
   
9. 
   
10.         public ReceiveThread(DatagramSocket ds) {
    
11.                 this.ds = ds;
    
12.         }
    
13. 
    
14.         @Override
    
15.         public void run() {
    
16.                 try {
    
17.                         while (true) {
    
18.                                 byte[] bys = new byte[1024];
    
19. 
    
20.                                 DatagramPacket dp = new DatagramPacket(bys, bys.length);
    
21. 
    
22.                                 ds.receive(dp);
    
23. 
    
24.                                 String ip = dp.getAddress().getHostAddress();
    
25. 
    
26.                                 String s = new String(dp.getData(), 0, dp.getLength());
    
27. 
    
28.                                 System.out.println(ip + ":" + s);
    
29.                         }
    
30.                 } catch (IOException e) {
    
31.                         e.printStackTrace();
    
32.                 }
    
33.         }
    
34. }

复制代码

测试类：

1. package com.kxg_05;
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.DatagramSocket;
   
5. 
   
6. public class ChatRoom {
   
7.         public static void main(String[] args) throws IOException {
   
8.                 DatagramSocket dsSend = new DatagramSocket();
   
9.                 DatagramSocket dsReceive = new DatagramSocket(48264);
   
10. 
    
11.                 SendThread st = new SendThread(dsSend);
    
12.                 ReceiveThread rt = new ReceiveThread(dsReceive);
    
13. 
    
14.                 Thread t1 = new Thread(st);
    
15.                 Thread t2 = new Thread(rt);
    
16. 
    
17.                 t1.start();
    
18.                 t2.start();
    
19.         }
    
20. }

复制代码

发送端类：

1. package com.kxg_05;
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. import java.util.Scanner;
   
8. 
   
9. public class SendThread implements Runnable {
   
10.         private DatagramSocket ds;
    
11. 
    
12.         public SendThread(DatagramSocket ds) {
    
13.                 this.ds = ds;
    
14.         }
    
15. 
    
16.         @Override
    
17.         public void run() {
    
18.                 try {
    
19.                 Scanner sc = new Scanner(System.in);
    
20.                 String s = null;
    
21.                         while ((s = sc.nextLine()) != null) {
    
22.                         byte[] bys = s.getBytes();
    
23.                         DatagramPacket dp = new DatagramPacket(bys, bys.length,
    
24.                                         InetAddress.getByName("10.164.22.254"), 48264);
    
25.                                 ds.send(dp);
    
26.                                 if (s.equals("我下了")) {
    
27.                                         break;
    
28.                                 }
    
29.                         }
    
30.                         ds.close();
    
31.                 } catch (IOException e) {
    
32.                         e.printStackTrace();
    
33.                 }
    
34.         }
    
35. }

复制代码

接收端类：

1. package com.kxg_05;
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. 
   
7. public class ReceiveThread implements Runnable {
   
8.         private DatagramSocket ds;
   
9. 
   
10.         public ReceiveThread(DatagramSocket ds) {
    
11.                 this.ds = ds;
    
12.         }
    
13. 
    
14.         @Override
    
15.         public void run() {
    
16.                 try {
    
17.                         while (true) {
    
18.                                 byte[] bys = new byte[1024];
    
19. 
    
20.                                 DatagramPacket dp = new DatagramPacket(bys, bys.length);
    
21. 
    
22.                                 ds.receive(dp);
    
23. 
    
24.                                 String ip = dp.getAddress().getHostAddress();
    
25. 
    
26.                                 String s = new String(dp.getData(), 0, dp.getLength());
    
27. 
    
28.                                 System.out.println(ip + ":" + s);
    
29.                         }
    
30.                 } catch (IOException e) {
    
31.                         e.printStackTrace();
    
32.                 }
    
33.         }
    
34. }

复制代码