要求：

使用多線程實現多發送方發送數據到同一個接收者

---

代碼：

發送端：可以在多臺電腦上啟動發送端，同時向接收端發送數據

注意：匹配地址和端口號 package com.qf.demo;import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; import java.net.UnknownHostException;public class SendTest {public static void main(String[] args) {System.out.println("發送端已啟動！");DatagramSocket socket=null;try {//1.創建socket對象socket=new DatagramSocket();//2.要發送的內容，可以用Scanner在后臺輸入String string="最近很煩，有時間陪我聊天嗎？";DatagramPacket packet=new DatagramPacket(string.getBytes(), string.getBytes().length, InetAddress.getLocalHost(), 6677);//3.發送數據socket.send(packet);} catch (SocketException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (UnknownHostException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}finally {if(socket!=null){socket.close();}}} }

---

接收端：

package com.qf.demo;import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.SocketException;public class ReceiveTest {public static void main(String[] args) {// 1 sockettry {DatagramSocket socket = new DatagramSocket(6677);while(true){byte[] bs = new byte[1024];DatagramPacket p = new DatagramPacket(bs, bs.length);socket.receive(p);// 阻塞程序程序執行MyThread thread = new MyThread(p);thread.start();}} catch (SocketException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}} }class MyThread extends Thread{DatagramPacket p = null;public MyThread(DatagramPacket p ) {this.p = p;}@Overridepublic void run() {// 將接收到的數據進行 打印輸出System.out.println("接收到的--發送端--數據："+new String(p.getData(),0,p.getLength()));} }

---

運行結果：

接收端：

總結

以上是生活随笔為你收集整理的{网络编程}和{多线程}应用：基于UDP协议【实现多发送方发送数据到同一个接收者】--练习的全部內容，希望文章能夠幫你解決所遇到的問題。

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