欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java NIO实例UDP发送接收数据代码分享

程序员文章站 2023-12-20 11:28:40
java的nio包中,有一个专门用于发送udp数据包的类:datagramchannel,udp是一种无连接的网络协议, 一般用于发送一些准确度要求不太高的数据等。 完...

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功能操作符的使用方法详解

javaweb应用使用限流处理大量的并发请求详解

有什么问题可以随时留言,小编会及时回复大家的。感谢朋友们对本站的支持!

上一篇:

下一篇: