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

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

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

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

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

由于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 连接对象和地址,具体使用时进行异常捕获就可以了!

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

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

(0)

相关推荐

  • python实现UDP协议下的文件传输

    本文实例为大家分享了python实现UDP文件传输的具体代码,供大家参考,具体内容如下 UDP协议下文件传输: 服务端 import socket count = 0 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) server_addr = ('127.0.0.1',9999) s.bind(server_addr) print('Bind UDP on 9999...') while True: if count == 0: data

  • UDP简单服务端客户端代码示例

    UDP的理论不再多说,我这里直接给出一个关于UDP的HelloWorld程序,代码明了,希望对刚入门的学生有所帮助! 当然,实际上,在这块我也刚入门! 首先写服务端代码,服务端邦定本地的IP和端口来监听访问: package udp; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetSocketAddress; /** *

  • Java模拟UDP通信示例代码

    Java基础:模拟UDP通信 1.一次发送,一次接收 1.1.发送方 // 发送端,不需要连接服务器 public class UdpClientDemo {     public static void main(String[] args) throws Exception {         // 1. 发送数据包需要一个Socket         DatagramSocket socket = new DatagramSocket();         // 1.2 建立一个包    

  • 详解python UDP 编程

    前面我们讲了 TCP 编程,我们知道 TCP 可以建立可靠连接,并且通信双方都可以以流的形式发送数据.本文我们再来介绍另一个常用的协议–UDP.相对TCP,UDP则是面向无连接的协议. UDP 协议 我们来看 UDP 的定义: UDP 协议(User Datagram Protocol),中文名是用户数据报协议,是 OSI(Open System Interconnection,开放式系统互联) 参考模型中一种无连接的传输层协议,提供面向事务的简单不可靠信息传送服务. 从这个定义中,我们可以总结

  • java UDP通信客户端与服务器端实例分析

    本文实例讲述了java UDP通信客户端与服务器端.分享给大家供大家参考,具体如下: 最初Udp是以字节为单位进行传输的,所以有很大的限制 服务器端: import java.net.*; public class TestUdpServer { public static void main(String[] args) throws Exception { byte[] buf = new byte[1024]; DatagramPacket dp = new DatagramPacket(

  • Python实现UDP程序通信过程图解

    运行流程:编辑好代码后,通过cmd打开文件执行.例:C:\Users\小李酷少>C:\Users\小李酷少\Desktop\发送端.py hello 易见问题:在运行程序的时候容易出现"请求的地址无效"的情况: 这是因为在编辑代码时候输入的ip地址不正确. 解决方法: 打开cmd,输入ipconfig,查看本机ip地址.如下图 之后在代码行修改为正确的IP地址就好啦. 1.代码 (1)接收端代码: import socket #使用IPV4协议,使用UDP协议传输数据 s=soc

  • java网络之基于UDP的聊天程序示例解析

    基于UDP的Socket通信 UDP协议不是一种基于稳定连接的协议,是一种面向数据报包的通信协议,不需要通信双方建立稳定的连接,也没有所谓服务端和客户的概念,数据报包在传输的时候不保证一定及时到达,也不能保证数据报包的到达顺序,但是UDP协议传输效率要远高于TCP/IP. 以下是一个基于UDP的简单的消息发送接收程序. 消息发送方 1.创建一个数据报的网络通道 DatagramSocket ds = new DatagramSocket(); 2.准备需要传输的数据 String msg = "

  • C# 使用Tcp/Udp协议的示例代码

    所使用的:多线程 委托 Socket 键值队 个人跟着视频做的一个小练习,有兴趣的可以去看一下对于初学者来讲是比较有帮助的 连接:https://www.bilibili.com/video/BV1bZ4y1W74q?p=3&t=358 废话不多说上代码  综合视频中的理解 有什么不对的地方希望大神指点一下 public partial class Form1 : Form { public Form1() { InitializeComponent(); myAddOnlieDelegate

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

    之前写了一个简单的UDP服务端和客户端示例,用于入门UDP,当我实际使用时发生了一点问题! 上次使用中我也把连接对象 DatagramSocket 写成了静态的,在类的初始化时使用,可是系统中有很多地方使用,难道我要不断的创建这个类的对象吗? 可以这么做,当时有后果,后果就是内存溢出. UDP是没有状态的,DatagramSocket 创建一次即可,就是开始指向某个地址的端口,而不用每次创建. 由于UDP是无状态的,在创建 DatagramSocket 对象时只是创建了一个指向网络的对象,就像你

  • Python @property原理解析和用法实例

    这篇文章主要介绍了Python @property原理解析和用法实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 在我们定义数据库字段类的时候,往往需要对其中的类属性做一些限制,一般用get和set方法来写,那在python中,我们该怎么做能够少写代码,又能优雅的实现想要的限制,减少错误的发生呢,这时候就需要我们的@property闪亮登场啦,巴拉巴拉能量--.. 用代码来举例子更容易理解,比如一个学生成绩表定义成这样 class Stude

  • javascript History对象原理解析

    这篇文章主要介绍了javascript History对象原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 length history.length属性保存着历史记录的URL数量.初始时,该值为1.由于IE10+浏览器在初始时返回2,存在兼容性问题,所以该值并不常用 跳转方法 go().back()和forward() 如果移动的位置超出了访问历史的边界,以上三个方法并不报错,而是静默失败 [注意]使用历史记录时,页面通常从浏览器缓存之

  • JavaWeb pageContext对象原理解析

    这篇文章主要介绍了JavaWeb pageContext对象原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.JSP九大内置对象 1.out:用来向客户端发送文本数据 2.config:相当Servlet中的ServletConfig 3.page:当前JSP页面对象,相当在页面中的this,不过this能用的方法更多 4.pageContext:JSP的上下文对象,一般说到上下对象立马想到四个字:共享数据,没错这个就是JSP四大域中

  • Golang底层原理解析String使用实例

    目录 引言 String底层 stringStruct结构 引言 本人因为种种原因(说来听听),放弃大学学的java,走上了golang这条路,本着干一行爱一行的情怀,做开发嘛,不能只会使用这门语言,所以打算开一个底层原理系列,深挖一下,狠狠的掌握一下这门语言 废话不多说,上货 String底层 既然研究底层,那就得全方面覆盖,必须先搞一下基础的东西,那必须直接基本数据类型走起啊, 字符串String的底层我看就很基础 string大家应该都不陌生,go中的string是所有8位字节字符串的集合

  • Python可变对象与不可变对象原理解析

    一.原理 可变对象:list dict set 不可变对象:tuple string int float bool 1. python不允许程序员选择采用传值还是传引用.Python参数传递采用的肯定是"传对象引用"的方式.实际上,这种方式相当于传值和传引用的一种综合.如果函数收到的是一个可变对象的引用,就能修改对象的原始值--相当于通过"传引用"来传递对象.如果函数收到的是一个不可变对象的引用,就不能直接修改原始对象--相当于通过"传值'来传递对象. 2

  • RabbitMQ简单队列实例及原理解析

    这篇文章主要介绍了RabbitMQ简单队列实例及原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 RabbitMQ 简述 RabbitMQ是一个消息代理:它接受并转发消息. 您可以将其视为邮局:当您将要把寄发的邮件投递到邮箱中时,您可以确信Postman 先生最终会将邮件发送给收件人. 在这个比喻中,RabbitMQ是一个邮箱,邮局和邮递员,用来接受,存储和转发二进制数据块的消息. 队列就像是在RabbitMQ中扮演邮箱的角色. 虽然消息

  • Python中使用gflags实例及原理解析

    这篇文章主要介绍了Python中使用gflags实例及原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 安装命令pip install python-gflags 使用示例: import gflags FLAGS = gflags.FLAGS gflags.DEFINE_string('name', 'ming', 'this is a value') gflags.DEFINE_integer('qps', 0, 'test qps'

  • Python爬虫解析网页的4种方式实例及原理解析

    这篇文章主要介绍了Python爬虫解析网页的4种方式实例及原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 用Python写爬虫工具在现在是一种司空见惯的事情,每个人都希望能够写一段程序去互联网上扒一点资料下来,用于数据分析或者干点别的事情.​ 我们知道,爬虫的原理无非是把目标网址的内容下载下来存储到内存中,这个时候它的内容其实是一堆HTML,然后再对这些HTML内容进行解析,按照自己的想法提取出想要的数据,所以今天我们主要来讲四种在Py

  • Python While循环语句实例演示及原理解析

    这篇文章主要介绍了Python While循环语句实例演示及原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 Python 编程中 while 语句用于循环执行程序,即在某条件下,循环执行某段程序,以处理需要重复处理的相同任务.其基本形式为: while 判断条件: 执行语句-- 执行语句可以是单个语句或语句块.判断条件可以是任何表达式,任何非零.或非空(null)的值均为true. 当判断条件假false时,循环结束. 执行流程图如下:

随机推荐