UDP连接对象原理解析及使用实例

2023-07-13 19:05:03 68

之前写了一个简单的UDP服务端和客户端示例，用于入门UDP，当我实际使用时发生了一点问题！

上次使用中我也把连接对象DatagramSocket写成了静态的，在类的初始化时使用，可是系统中有很多地方使用，难道我要不断的创建这个类的对象吗？

可以这么做，当时有后果，后果就是内存溢出。

UDP是没有状态的，DatagramSocket创建一次即可，就是开始指向某个地址的端口，而不用每次创建。

由于UDP是无状态的，在创建DatagramSocket对象时只是创建了一个指向网络的对象，就像你架设一个大喇叭对着某个方向，可是你并不知道这个方向到底有没有人在听。

如果，即使你没有开服务端，创建连接对象并向这个地址放松数据，都是没有问题。你用喇叭向某个方向喊没人听这没有什么！可是当你需要回应时如果一直没有接到响应，超时之后就会报错！

packageudp;

importjava.net.*;

/**
*@说明UDP客户端程序，用于对服务端发送数据，并接收服务端的回应信息
*@authorcuisuqiang
*@version1.0
*@sincecuisuqiang@163.com
*/
publicclassUdpClientSocket{
/**
*连接对象
*/
privatestaticDatagramSocketds=null;
/**
*地址对象
*/
privatestaticSocketAddressaddress=null;

/**
*测试客户端发包和接收回应信息的方法
*/
publicstaticvoidmain(String[]args)throwsException{
init();
while(true){
UdpClientSocket.send(address,"你好，亲爱的!".getBytes());
UdpClientSocket.receive();
try{
Thread.sleep(3*1000);
}catch(Exceptione){
e.printStackTrace();
}
}
}

/**
*对连接和地址初始化
*/
publicstaticvoidinit(){
try{
ds=newDatagramSocket(8899);//邦定本地端口作为客户端
ds.setSoTimeout(2*1000);
address=newInetSocketAddress("127.0.0.1",3344);
}catch(Exceptione){
e.printStackTrace();
}
}

/**
*向指定的服务端发送数据信息
*/
publicstaticvoidsend(SocketAddressaddress,byte[]bytes){
try{
DatagramPacketdp=newDatagramPacket(bytes,bytes.length,address);
ds.send(dp);
}catch(Exceptione){
e.printStackTrace();
}
}

/**
*接收从指定的服务端发回的数据
*/
publicstaticvoidreceive(){
try{
byte[]buffer=newbyte[1024];
DatagramPacketdp=newDatagramPacket(buffer,buffer.length);
ds.receive(dp);
byte[]data=newbyte[dp.getLength()];
System.arraycopy(dp.getData(),0,data,0,dp.getLength());
System.out.println("服务端回应数据："+newString(data));
}catch(Exceptione){
e.printStackTrace();
}
}
}

执行以代码运行结果如下：

java.net.SocketTimeoutException:Receivetimedout
atjava.net.PlainDatagramSocketImpl.receive0(NativeMethod)
atjava.net.PlainDatagramSocketImpl.receive(PlainDatagramSocketImpl.java:136)
atjava.net.DatagramSocket.receive(DatagramSocket.java:712)
atudp.UdpClientSocket.receive(UdpClientSocket.java:69)
atudp.UdpClientSocket.main(UdpClientSocket.java:28)

运行超时，但是报错的地方不是创建对象和发送数据，而是接收数据时超时！

这个程序一直运行，我们来搞一个服务端：

packageudp;

importjava.net.DatagramPacket;
importjava.net.DatagramSocket;
importjava.net.InetSocketAddress;
importjava.net.SocketAddress;

/**
*@说明UDP服务类
*@authorcuisuqiang
*@version1.0
*@sincecuisuqiang@163.com
*/
publicclassUdpServerSocket{
	
	privatestaticDatagramSocketds=null;
	privatestaticSocketAddressaddress=null;
	
	/**
	*测试方法
	*/
	publicstaticvoidmain(String[]args)throwsException{
		init();
		System.out.println("---->服务开始监听！<----");
		while(true){
			UdpServerSocket.receive();
			UdpServerSocket.response(address,"你好,吃了吗!");
		}		
	}
	
	publicstaticvoidinit(){
		try{
			ds=newDatagramSocket(3344);
			ds.setSoTimeout(0);
			address=newInetSocketAddress("127.0.0.1",8899);
		}catch(Exceptione){
			e.printStackTrace();
		}
	}

	/**
	*接收数据包，该方法会造成线程阻塞
	*/
	publicstaticvoidreceive(){
		try{
			byte[]buffer=newbyte[1024];
			DatagramPacketpacket=newDatagramPacket(buffer,buffer.length);
			ds.receive(packet);
			Stringinfo=newString(packet.getData(),0,packet.getLength());
			System.out.println("接收信息："+info);
		}catch(Exceptione){
			e.printStackTrace();
		}
	}

	/**
	*将响应包发送给请求端
	*/
	publicstaticvoidresponse(SocketAddressaddress,Stringinfo){
		try{
			DatagramPacketdp=newDatagramPacket(info.getBytes(),info.getBytes().length,address);
			dp.setData(info.getBytes());
			ds.send(dp);
		}catch(Exceptione){
			e.printStackTrace();
		}		
	}
}

运行后客户端可以正常发送和接收数据！

如果在实际运用中，我是设置一个系统启动项，来初始化init连接对象和地址，具体使用时进行异常捕获就可以了！

如果你的连接对象每次创建，且使用频繁，一般几分钟系统即可搞挂！

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

UDP连接对象原理解析及使用实例

热门推荐

随机推荐