社区微信群开通啦,扫一扫抢先加入社区官方微信群
社区微信群
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.util.concurrent.ThreadPoolExecutor;
/**
* @ClassName:UdpRecv
* @Description:接收方,需要先开启
* @author: Torey
*/
public class UdpRecv {
public static void main(String[] args) throws IOException, InterruptedException {
DatagramSocket ds = new DatagramSocket(3000);
byte[] bytes = new byte[1024];
DatagramPacket dp=new DatagramPacket(bytes,1024);
System.out.println("UdpRecv:我在等待消息");
ds.receive(dp);
System.out.println("UdpRecv,:我接收到消息");
String strRecv=new String(dp.getData(),0,dp.getLength())+" from "+dp.getAddress().getHostAddress()+":"+dp.getPort();
System.out.println(strRecv);
Thread.sleep(1000);
System.out.println("UdpRecv:我要发信息");
String str="UdpRecv: I'm LiMing,Hello";
DatagramPacket dp2=new DatagramPacket(str.getBytes(),str.length(),InetAddress.getByName("127.0.01"),dp.getPort());
ds.send(dp2);
System.out.println("UdpRecv:我发送信息结束");
ds.close();
}
}
import java.io.IOException;
import java.net.*;
/**
* @ClassName:UdpSend
* @Description:发送方
* @author: Torey
*/
public class UdpSend {
public static void main(String[] args) throws IOException, InterruptedException {
//定义数据管道
DatagramSocket ds=new DatagramSocket();
String str="UdpSend,AAA:Hello,xiaoMing";
DatagramPacket datagramPacket=new DatagramPacket(str.getBytes(),str.length(),
InetAddress.getByName("127.0.0.1"),3000);
System.out.println("UdpSend:发送信息");
ds.send(datagramPacket);
System.out.println("UdpSend:发送信息结束");
Thread.sleep(1000);
byte[] buf=new byte[1024];
DatagramPacket dp2 = new DatagramPacket(buf, 1024);
System.out.println("UdpSend:我在等待信息");
ds.receive(dp2);
System.out.println("UdpSend:我接收到信息");
String str2=new String(dp2.getData(),0,dp2.getLength())
+" from "+dp2.getAddress().getHostAddress()+":"+dp2.getPort();
System.out.println(str2);
ds.close();
}
}
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!