1. 通過多線程改進剛才的聊天程序，這樣我就可以實現在一個窗口發送和接收數據了

2. ?代碼示例：

（1）SendThread.java，如下：

1 package com.himi.udpDemo2; 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 10 public class SendThread implements Runnable { 11 12 private DatagramSocket ds; 13 14 public SendThread(DatagramSocket ds) { 15 this.ds = ds; 16 } 17 18 public void run() { 19 try { 20 // 封裝鍵盤錄入數據 21 BufferedReader br = new BufferedReader(new InputStreamReader( 22 System.in)); 23 String line = null; 24 while ((line = br.readLine()) != null) { 25 if ("886".equals(line)) { 26 break; 27 } 28 29 // 創建數據并打包 30 byte[] bys = line.getBytes(); 31 // DatagramPacket dp = new DatagramPacket(bys, bys.length, 32 // InetAddress.getByName("192.168.12.92"), 12345); 33 DatagramPacket dp = new DatagramPacket(bys, bys.length, 34 InetAddress.getByName("49.123.72.145"), 12306); 35 36 // 發送數據 37 ds.send(dp); 38 } 39 40 // 釋放資源 41 ds.close(); 42 } catch (IOException e) { 43 e.printStackTrace(); 44 } 45 } 46 47 }

?

（2）ReceiveThread.java，如下：

1 package com.himi.udpDemo2; 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 public void run() { 15 try { 16 while (true) { 17 // 創建一個包裹 18 byte[] bys = new byte[1024]; 19 DatagramPacket dp = new DatagramPacket(bys, bys.length); 20 21 // 接收數據 22 ds.receive(dp); 23 24 // 解析數據 25 String ip = dp.getAddress().getHostAddress(); 26 String s = new String(dp.getData(), 0, dp.getLength()); 27 System.out.println("from " + ip + " data is : " + s); 28 } 29 } catch (IOException e) { 30 e.printStackTrace(); 31 } 32 } 33 34 }

?

（3）聊天室程序CharRoom.java，調用上面兩個線程工具類，代碼如下:

1 package com.himi.udpDemo2; 2 3 import java.io.IOException; 4 import java.net.DatagramSocket; 5 6 /* 7 * 通過多線程改進剛才的聊天程序，這樣我就可以實現在一個窗口發送和接收數據了 8 */ 9 public class ChatRoom { 10 public static void main(String[] args) throws IOException { 11 DatagramSocket dsSend = new DatagramSocket(); 12 DatagramSocket dsReceive = new DatagramSocket(12306); 13 14 SendThread st = new SendThread(dsSend); 15 ReceiveThread rt = new ReceiveThread(dsReceive); 16 17 Thread t1 = new Thread(st); 18 Thread t2 = new Thread(rt); 19 20 t1.start(); 21 t2.start(); 22 } 23 }

運行效果如下：

轉載于:https://www.cnblogs.com/hebao0514/p/4859593.html

總結

以上是生活随笔為你收集整理的Java基础知识强化之网络编程笔记05：UDP之多线程实现聊天室案例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。