udp协议可提供简单的无连接服务吗(UDP连接对象原理解析及使用实例)
udp协议可提供简单的无连接服务吗
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 连接对象和地址,具体使用时进行异常捕获就可以了!
如果你的连接对象每次创建,且使用频繁,一般几分钟系统即可搞挂!
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持开心学习网。
- udp协议可提供简单的无连接服务吗(UDP连接对象原理解析及使用实例)
- udp 常用端口(UDP DUP超时UPD端口状态检测代码示例)
- python udp通信(Python socket模块实现的udp通信功能示例)
- linuxudp通信程序(linux对于UDP的学习)
- python udp网络编程(python实现一个简单的udp通信的示例代码)
- docker 环境下udp双向通信怎么办(解决Docker network Create加--subnet后遇到问题)
- docker端口映射和暴露端口的区别(解决docker指定udp端口号的问题)
- udp客户端与服务端通信注意事项(UDP简单服务端客户端代码示例)
- 七夕的寓意(七夕的寓意)
- 苏志燮赵恩静结婚,韩国四大公共财产变三人,这么快就有替补了(苏志燮赵恩静结婚)
- 《内在美》后,一大波新韩剧来袭,李钟硕朴信惠宋慧乔玄彬回归(一大波新韩剧来袭)
- 给孩子选购保温杯,注意这4个步骤,比颜值更重要(给孩子选购保温杯)
- 保温好 容量大 颜值高 保温杯你给娃娃买对了吗(保温好容量大颜值高)
- 《道德经》 人生避开骄狂,才能免去祸患(道德经人生避开骄狂)
热门推荐
- JavaScript中使用concat合并数组
- css3字体怎么设置(使用CSS3 font-feature-settings特性减除字体动画震颤效果)
- vue-router底层实现原理(vue-router history模式服务器端配置过程记录)
- sql server提供的聚合函数(SQLServer行列互转实现思路聚合函数)
- sql server信息管理案例(利用SQL Server数据库邮件服务实现监控和预警)
- dede织梦的后台如何调整和使用(dedecms织梦模板去掉文档内链自动连接关键词的下划线)
- vue怎么引入axios(如何用vue封装axios请求)
- Chrome谷歌浏览器开发者工具中Profiles的使用
- html5video怎么优化(HTML5 video循环播放多个视频的方法步骤)
- php怎样创建新文件详情(php文件后缀不强制为.php的实操方法)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8