import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
class receiveDemo {
public static void main(String[] args) throws IOException {
//创建客户端的套接字Socket对象
DatagramSocket dgs=new DatagramSocket(2000);
while(true){
//创建客户端的用来接收的数据包
byte[] bys=new byte[1024];
DatagramPacket dp=new DatagramPacket(bys,bys.length);
//调用Socket之中的方法接收数据
dgs.receive(dp);
//解析Socket中的信息并显示
String ip=dp.getAddress().getHostAddress();
String info=new String(dp.getData(),0,dp.getLength());
System.out.println("from:"+ip+" data is: "+info);
/*不关闭资源,接收端一直开放!用来模拟服务器*/
//dgs.close();
}
}
}
|
|