1. package heima.net;
   
2. 
   
3. import java.io.BufferedReader;
   
4. import java.io.IOException;
   
5. import java.io.InputStreamReader;
   
6. import java.net.DatagramPacket;
   
7. import java.net.DatagramSocket;
   
8. import java.net.InetAddress;
   
9. import java.net.SocketException;
   
10. 
    
11. public class UDPChatDemo {
    
12. 
    
13.     /**
    
14.      * @param 黑马程序员
    
15.      *            -UDP聊天
    
16.      * @author 高一航
    
17.      */
    
18.     public static void main(String[] args) {
    
19.         try {
    
20.             DatagramSocket sendSocket = new DatagramSocket();
    
21.             DatagramSocket recieveSocket = new DatagramSocket(10001);//监听本机的10001端口
    
22.             new Thread(new Sender(sendSocket)).start();
    
23.             new Thread(new Receiver(recieveSocket)).start();
    
24.         } catch (SocketException e) {
    
25.             e.printStackTrace();
    
26.         }
    
27. 
    
28.     }
    
29. 
    
30. }
    
31. 
    
32. class Sender implements Runnable {
    
33.     private DatagramSocket ds;// 1,建立Socket端点
    
34.     private DatagramPacket dp;// 2,定义数据包,用于存储数据;
    
35. 
    
36.     public Sender(DatagramSocket ds) {
    
37.         this.ds = ds;
    
38.     }
    
39. 
    
40.     @Override
    
41.     public void run() {
    
42.         BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
    
43.         byte[] buf = new byte[1024];
    
44.         String line;
    
45.         try {
    
46.             while ((line = in.readLine()) != null) {
    
47.                 buf = line.getBytes();
    
48.                 dp = new DatagramPacket(buf, buf.length,
    
49.                         InetAddress.getByName("127.0.0.1"), 10000);
    
50.                 ds.send(dp);// 3,通过socket发送方法,将数据发送
    
51.                 if ("bye".equalsIgnoreCase(line)) {
    
52.                     break;
    
53.                 }
    
54.             }
    
55.         } catch (IOException e) {
    
56.             e.printStackTrace();
    
57.         } finally {
    
58.             try {
    
59.                 in.close();
    
60.             } catch (IOException e) {
    
61.                 e.printStackTrace();
    
62.             }
    
63.             ds.close();
    
64.             System.out.println("sender resources closed");
    
65.         }
    
66.     }
    
67. 
    
68. }
    
69. 
    
70. class Receiver implements Runnable {
    
71.     private DatagramSocket ds;// 1,建立Socket端点
    
72.     public DatagramPacket dp;// 2,定义数据包,用于存储数据;
    
73. 
    
74.     public Receiver(DatagramSocket ds) {
    
75.         this.ds = ds;
    
76.     }
    
77. 
    
78.     @Override
    
79.     public void run() {
    
80.         byte[] buf = new byte[1024];
    
81.         String ip;
    
82.         String context;
    
83.         try {
    
84.             while (true) {
    
85.                 dp = new DatagramPacket(buf, buf.length);
    
86.                 ds.receive(dp);//3,通过socket的receive方法将数据存入数据包
    
87.                 ip = dp.getAddress().getHostAddress();//获取IP
    
88.                 context = new String(dp.getData(), 0, dp.getLength());//获取内容
    
89.                 System.out.println(ip + " : " + context);
    
90.             }
    
91.         } catch (IOException e) {
    
92.             e.printStackTrace();
    
93.         } finally {
    
94.             ds.close();
    
95.             System.out.println("Receiver resources closed");
    
96.         }
    
97.     }
    
98. 
    
99. }

复制代码

1. package heima.net;
   
2. 
   
3. import java.io.BufferedReader;
   
4. import java.io.IOException;
   
5. import java.io.InputStreamReader;
   
6. import java.net.DatagramPacket;
   
7. import java.net.DatagramSocket;
   
8. import java.net.InetAddress;
   
9. import java.net.SocketException;
   
10. 
    
11. public class UDPChatDemo {
    
12. 
    
13.     /**
    
14.      * @param 黑马程序员
    
15.      *            -UDP聊天
    
16.      * @author 高一航
    
17.      */
    
18.     public static void main(String[] args) {
    
19.         try {
    
20.             DatagramSocket sendSocket = new DatagramSocket();
    
21.             DatagramSocket recieveSocket = new DatagramSocket(10001);//监听本机的10001端口
    
22.             new Thread(new Sender(sendSocket)).start();
    
23.             new Thread(new Receiver(recieveSocket)).start();
    
24.         } catch (SocketException e) {
    
25.             e.printStackTrace();
    
26.         }
    
27. 
    
28.     }
    
29. 
    
30. }
    
31. 
    
32. class Sender implements Runnable {
    
33.     private DatagramSocket ds;// 1,建立Socket端点
    
34.     private DatagramPacket dp;// 2,定义数据包,用于存储数据;
    
35. 
    
36.     public Sender(DatagramSocket ds) {
    
37.         this.ds = ds;
    
38.     }
    
39. 
    
40.     @Override
    
41.     public void run() {
    
42.         BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
    
43.         byte[] buf = new byte[1024];
    
44.         String line;
    
45.         try {
    
46.             while ((line = in.readLine()) != null) {
    
47.                 buf = line.getBytes();
    
48.                 dp = new DatagramPacket(buf, buf.length,
    
49.                         InetAddress.getByName("127.0.0.1"), 10000);
    
50.                 ds.send(dp);// 3,通过socket发送方法,将数据发送
    
51.                 if ("bye".equalsIgnoreCase(line)) {
    
52.                     break;
    
53.                 }
    
54.             }
    
55.         } catch (IOException e) {
    
56.             e.printStackTrace();
    
57.         } finally {
    
58.             try {
    
59.                 in.close();
    
60.             } catch (IOException e) {
    
61.                 e.printStackTrace();
    
62.             }
    
63.             ds.close();
    
64.             System.out.println("sender resources closed");
    
65.         }
    
66.     }
    
67. 
    
68. }
    
69. 
    
70. class Receiver implements Runnable {
    
71.     private DatagramSocket ds;// 1,建立Socket端点
    
72.     public DatagramPacket dp;// 2,定义数据包,用于存储数据;
    
73. 
    
74.     public Receiver(DatagramSocket ds) {
    
75.         this.ds = ds;
    
76.     }
    
77. 
    
78.     @Override
    
79.     public void run() {
    
80.         byte[] buf = new byte[1024];
    
81.         String ip;
    
82.         String context;
    
83.         try {
    
84.             while (true) {
    
85.                 dp = new DatagramPacket(buf, buf.length);
    
86.                 ds.receive(dp);//3,通过socket的receive方法将数据存入数据包
    
87.                 ip = dp.getAddress().getHostAddress();//获取IP
    
88.                 context = new String(dp.getData(), 0, dp.getLength());//获取内容
    
89.                 System.out.println(ip + " : " + context);
    
90.             }
    
91.         } catch (IOException e) {
    
92.             e.printStackTrace();
    
93.         } finally {
    
94.             ds.close();
    
95.             System.out.println("Receiver resources closed");
    
96.         }
    
97.     }
    
98. 
    
99. }

复制代码