Java NIO实例UDP发送接收数据代码分享
发布时间:2020-12-14 21:07:10 所属栏目:Java 来源:网络整理
导读:Java的NIO包中,有一个专门用于发送UDP数据包的类:DatagramChannel,UDP是一种无连接的网络协议, 一般用于发送一些准确度要求不太高的数据等。 完整的服务端程序如下: public class StatisticsServer { //每次发送接收的数据包大小 private final int MAX
Java的NIO包中,有一个专门用于发送UDP数据包的类:DatagramChannel,UDP是一种无连接的网络协议, 完整的服务端程序如下: public class StatisticsServer { //每次发送接收的数据包大小 private final int MAX_BUFF_SIZE = 1024 * 10; //服务端监听端口,客户端也通过该端口发送数据 private int port; private DatagramChannel channel; private Selector selector; private ScheduledExecutorService es = Executors.newScheduledThreadPool(1); public void init() throws IOException { //创建通道和选择器 selector = Selector.open(); channel = DatagramChannel.open(); //设置为非阻塞模式 channel.configureBlocking(false); channel.socket().bind(new InetSocketAddress(port)); //将通道注册至selector,监听只读消息(此时服务端只能读数据,无法写数据) channel.register(selector,SelectionKey.OP_READ); //使用线程的方式,保证服务端持续等待接收客户端数据 es.scheduleWithFixedDelay(new Runnable() { @Override public void run() { try { while(selector.select() > 0) { Iterator<SelectionKey> iterator = selector.selectedKeys().iterator(); while(iterator.hasNext()) { SelectionKey key = iterator.next(); try { iterator.remove(); if(key.isReadable()) { //接收数据 doReceive(key); } } catch (Exception e) { logger.error("SelectionKey receive exception",e); try { if (key != null) { key.cancel(); key.channel().close(); } } catch (ClosedChannelException cex) { logger.error("Close channel exception",cex); } } } } } catch (IOException e) { logger.error("selector.select exception",e); } } },0L,2L,TimeUnit.MINUTES); } //处理接收到的数据 private void doReceive(SelectionKey key) throws IOException { String content = ""; DatagramChannel sc = (DatagramChannel) key.channel(); ByteBuffer buffer = ByteBuffer.allocate(MAX_BUFF_SIZE); buffer.clear(); sc.receive(buffer); buffer.flip(); while(buffer.hasRemaining()) { byte[] buf = new byte[buffer.limit()]; buffer.get(buf); content += new String(buf); } buffer.clear(); logger.debug("receive content="+content); if(StringUtils.isNotBlank(content)) { doSave(content); } } } 客户端发送完整例子如下: DatagramChannel channel = DatagramChannel.open(); StringBuilder sb = new StringBuilder(); sb.append("2017-03-09 12:30:00;") .append("aaa") .append("testapp;") .append("test.do;") .append("param=hello;") .append("test;") .append("100;") .append("1"); ByteBuffer buffer = ByteBuffer.allocate(10240); buffer.clear(); buffer.put(sb.toString().getBytes()); buffer.flip(); //此处IP为服务端IP地址,端口和服务端的端口一致 int n = channel.send(buffer,new InetSocketAddress("127.0.0.1",8080)); System.out.println(n); //每次数据发送完毕之后,一定要调用close方法,来关闭占用的udp端口,否则程序不结束,端口不会释放 channel.close(); 总结 以上就是本文关于Java NIO实例UDP发送接收数据代码分享的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站: Rxjava功能操作符的使用方法详解 分享一个简单的java爬虫框架 Javaweb应用使用限流处理大量的并发请求详解 有什么问题可以随时留言,小编会及时回复大家的。感谢朋友们对本站的支持! (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
相关内容
- ScreenUtils 可用于获取屏幕宽高,截屏的工具类
- java – 如何读取下载文本中的中断?
- Java是否自动针对多核处理器优化循环
- javax.net.ssl.SSLHandshakeException: sun.security.valid
- 虚拟机安装Centos
- java – 创建一个不能创建其对象的类
- binding – javafx将fx:id传递给fxml onAction方法中的con
- 10 Questions To Make Programming Interviews Less Expens
- java – ElasticSearch – 使用FilterBuilders
- 树莓派快速 (安装)