要求：
使用多线程实现多发送方发送数据到同一个接收者
代码：
发送端：可以在多台电脑上启动发送端，同时向接收端发送数据
注意：匹配地址和端口号
package com.qf.demo;import java.io.IOException;import .DatagramPacket;import .DatagramSocket;import .InetAddress;import .SocketException;import .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 .DatagramPacket;import .DatagramSocket;import .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()));}}
运行结果：
接收端：
