电脑之家 - 专业计算机基础知识与电脑技术学习网站
分类导航

路由器|交换机|网络协议|网络知识|

服务器之家 - 电脑之家 - 网络技术 - 网络协议 - UDP连接对象原理解析及使用实例

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

2021-07-19 01:07cuisuqiang 网络协议

这篇文章主要介绍了UDP连接对象原理解析及使用实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

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

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

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

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

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

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
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)

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

这个程序一直运行,我们来搞一个服务端:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
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 连接对象和地址,具体使用时进行异常捕获就可以了!

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

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

原文链接:https://www.iteye.com/blog/cuisuqiang-1553989

延伸 · 阅读

精彩推荐
  • 网络协议为什么叫 HTTP/2 ,而不是 HTTP/2.0 ?

    为什么叫 HTTP/2 ,而不是 HTTP/2.0 ?

    互联网时代,足不出户,点点鼠标就可以轻松了解外面的世界变化,这一切得益于网络传输数据。我们都知道网络有7层模型,从底层到上层依次是:物理层...

    微观技术4842021-11-01
  • 网络协议四次挥手,TCP连接的关闭

    四次挥手,TCP连接的关闭

    我们退出 telnet 命令后,TCP 将关闭连接。于此同时,我们通过 tcpdump 也观察到 TCP 关闭连接的通信过程。本节,我们继续深入研究 TCP 关闭连接的通信细节。...

    小菜学编程9942021-10-28
  • 网络协议OAuth2.0协议扩展——OIDC认证协议

    OAuth2.0协议扩展——OIDC认证协议

    客户端无法认定资源拥有者就是正确的拥护者,虽然市面上的OAuth 2.0能够保证授权的安全性,但是OAuth 2.0本身并没有对用户认证提供明确的规范。...

    码农小胖哥4952021-08-02
  • 网络协议三分钟教你读懂通信协议

    三分钟教你读懂通信协议

    协议到底是什么?为什么大家都在强调协议的重要性?学习协议有哪些注意事项?今天小编就给大家简单介绍下相关内容。...

    中兴文档9972021-10-27
  • 网络协议5分钟看懂互联网安全协议IPSec

    5分钟看懂互联网安全协议IPSec

    通信双方需要一个真正在IP层提供安全性的方法,保证发送和接收的数据是安全的,IPSec(Internet Protocol Security,互联网安全协议)做到了。...

    中兴文档9342021-11-01
  • 网络协议HTTP缓存协议实战

    HTTP缓存协议实战

    缓存,又称作Cache,我们把临时存储数据的地方叫做缓存池,缓存池里面放的数据就叫做缓存,本文就以实战的形式为大家介绍HTTP缓存协议。...

    vivo互联网技术6942022-03-10
  • 网络协议一文读懂 https 底层原理

    一文读懂 https 底层原理

    既然https协议本质只是http上加了安全层,本文就主要将安全层是怎么实现的。当然要靠加密。加密又分成对称加密和非对称加密。...

    Java知音11462021-12-26
  • 网络协议从一次线上问题说起,详解 TCP 半连接队列、全连接队列

    从一次线上问题说起,详解 TCP 半连接队列、全连接队列

    某次大促值班 ing,对系统稳定性有着充分信心、心态稳如老狗的笔者突然收到上游反馈有万分几的概率请求我们 endpoint 会出现 Connection timeout 。...

    云巅论剑11612021-10-28