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

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

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

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

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

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

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

package udp; 
 
import java.net.*; 
 
/** 
 * @说明 udp客户端程序，用于对服务端发送数据，并接收服务端的回应信息 
 * @author cuisuqiang 
 * @version 1.0 
 * @since <a href="mailto:[e-mail]" rel="external nofollow" >[e-mail]</a> 
 */ 
public class udpclientsocket { 
  /** 
   * 连接对象 
   */ 
  private static datagramsocket ds = null; 
  /** 
   * 地址对象 
   */ 
  private static socketaddress address = null; 
   
  /** 
   * 测试客户端发包和接收回应信息的方法 
   */ 
  public static void main(string[] args) throws exception { 
    init(); 
    while(true){ 
      udpclientsocket.send(address,"你好，亲爱的!".getbytes()); 
      udpclientsocket.receive(); 
      try { 
        thread.sleep(3 * 1000); 
      } catch (exception e) { 
        e.printstacktrace(); 
      } 
    } 
  } 
   
  /** 
   * 对连接和地址初始化 
   */ 
  public static void init(){ 
    try { 
      ds = new datagramsocket(8899); // 邦定本地端口作为客户端 
      ds.setsotimeout(2 * 1000); 
      address = new inetsocketaddress("127.0.0.1",3344); 
    } catch (exception e) { 
      e.printstacktrace(); 
    } 
  } 
   
  /** 
   * 向指定的服务端发送数据信息 
   */ 
  public static void send(socketaddress address,byte[] bytes){ 
    try { 
      datagrampacket dp = new datagrampacket(bytes, bytes.length, address); 
      ds.send(dp); 
    } catch (exception e) { 
      e.printstacktrace(); 
    } 
  } 
 
  /** 
   * 接收从指定的服务端发回的数据 
   */ 
  public static void receive(){ 
    try { 
      byte[] buffer = new byte[1024]; 
      datagrampacket dp = new datagrampacket(buffer, buffer.length); 
      ds.receive(dp);    
      byte[] data = new byte[dp.getlength()]; 
      system.arraycopy(dp.getdata(), 0, data, 0, dp.getlength());  
      system.out.println("服务端回应数据：" + new string(data)); 
    } catch (exception e) { 
      e.printstacktrace(); 
    } 
  } 
} 

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

java.net.sockettimeoutexception: receive timed out
at java.net.plaindatagramsocketimpl.receive0(native method)
at java.net.plaindatagramsocketimpl.receive(plaindatagramsocketimpl.java:136)
at java.net.datagramsocket.receive(datagramsocket.java:712)
at udp.udpclientsocket.receive(udpclientsocket.java:69)
at udp.udpclientsocket.main(udpclientsocket.java:28)

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

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

package udp;

import java.net.datagrampacket;
import java.net.datagramsocket;
import java.net.inetsocketaddress;
import java.net.socketaddress;

/**
 * @说明 udp服务类
 * @author cuisuqiang
 * @version 1.0
 * @since [e-mail]
 */
public class udpserversocket {
	
	private static datagramsocket ds = null;
	private static socketaddress address = null;
	
	/**
	 * 测试方法
	 */
	public static void main(string[] args) throws exception {
		init();
		system.out.println("---->服务开始监听！<----");
		while (true) {
			udpserversocket.receive();
			udpserversocket.response(address,"你好,吃了吗!");
		}		
	}
	
	public static void init(){
		try {
			ds = new datagramsocket(3344);
			ds.setsotimeout(0);
			address = new inetsocketaddress("127.0.0.1",8899);
		} catch (exception e) {
			e.printstacktrace();
		}
	}

	/**
	 * 接收数据包，该方法会造成线程阻塞
	 */
	public static void receive() {
		try {
			byte[] buffer = new byte[1024];
			datagrampacket packet = new datagrampacket(buffer, buffer.length);
			ds.receive(packet);
			string info = new string(packet.getdata(), 0, packet.getlength());
			system.out.println("接收信息：" + info);
		} catch (exception e) {
			e.printstacktrace();
		}
	}

	/**
	 * 将响应包发送给请求端
	 */
	public static void response(socketaddress address,string info){
		try {
			datagrampacket dp = new datagrampacket(info.getbytes(), info.getbytes().length, address);
			dp.setdata(info.getbytes());
			ds.send(dp);
		} catch (exception e) {
			e.printstacktrace();
		}		
	}
}

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

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

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

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