本篇文章给大家分享的是有关使用UDP连接对象原理，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。
由于UDP是无状态的，在创建 DatagramSocket 对象时只是创建了一个指向网络的对象，就像你架设一个大喇叭对着某个方向，可是你并不知道这个方向到底有没有人在听。
如果，即使你没有开服务端，创建连接对象并向这个地址放松数据，都是没有问题。你用喇叭向某个方向喊没人听这没有什么！可是当你需要回应时如果一直没有接到响应，超时之后就会报错！
package udp;
import java.net.*;
/**
* @说明 UDP客户端程序，用于对服务端发送数据，并接收服务端的回应信息
* @author cuisuqiang
* @version 1.0
* @since <a href="mailto:cuisuqiang@163.com" rel="external nofollow" >cuisuqiang@163.com</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 cuisuqiang@163.com
*/
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 连接对象和地址，具体使用时进行异常捕获就可以了！
如果你的连接对象每次创建，且使用频繁，一般几分钟系统即可搞挂！
以上就是使用UDP连接对象原理，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注亿速云行业资讯频道。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
