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

Java NIO实例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，监听只读消息（此时服务端只能读数据，无法写数据）

http:// channel.register(selector, SelectionKey.OP_READ);

//使用线程的方式，保证服务端持续等待接收客户端数据

es.scheduleWithFixedDelay(new Runnable() {

@Override

public void run() {

try {

while(selector.select() > 0) {

Iterator 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);

http:// }

}

}

}

} 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()];

xdwtLBPQRT 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应用使用限流处理大量的并发请求详解

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。