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发送接收数据代码分享的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站:
有什么问题可以随时留言,小编会及时回复大家的。感谢朋友们对本站的支持!