Java NIO Socket通信的方法是什么
短信预约 -IT技能 免费直播动态提醒
这篇文章主要讲解了“Java NIO Socket通信的方法是什么”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Java NIO Socket通信的方法是什么”吧!
服务器代码:
import java.net.*; import java.nio.*; import java.nio.channels.*; import java.util.*; public class server { ServerSocketChannel ssc ; public void start() { try { Selector selector = Selector.open(); ServerSocketChannel ssc=ServerSocketChannel.open(); ssc.configureBlocking(false); ServerSocket ss=ssc.socket(); InetSocketAddress address = new InetSocketAddress(55555); ss.bind(address); ssc.register(selector, SelectionKey.OP_ACCEPT); System.out.println("端口注册完毕!"); while(true) { selector.select(); Set<SelectionKey> selectionKeys=selector.selectedKeys(); Iterator<SelectionKey> iter=selectionKeys.iterator(); ByteBuffer echoBuffer=ByteBuffer.allocate(20); SocketChannel sc; while(iter.hasNext()) { SelectionKey key=iter.next(); if((key.readyOps()&SelectionKey.OP_ACCEPT)==SelectionKey.OP_ACCEPT) { ServerSocketChannel subssc=(ServerSocketChannel)key.channel(); sc=subssc.accept(); sc.configureBlocking(false); sc.register(selector, SelectionKey.OP_READ); iter.remove(); System.out.println("有新连接:"+sc); } else if((key.readyOps()&SelectionKey.OP_READ)==SelectionKey.OP_READ) { sc=(SocketChannel) key.channel(); while(true) { echoBuffer.clear(); int a; try { a=sc.read(echoBuffer); } catch(Exception e) { e.printStackTrace(); break; } if(a==-1) break; if(a>0) { byte[] b=echoBuffer.array(); System.out.println("接收数据: "+new String(b)); echoBuffer.flip(); sc.write(echoBuffer); System.out.println("返回数据: "+new String(b)); } } sc.close(); System.out.println("连接结束"); System.out.println("============================="); iter.remove(); } } } } catch (Exception e) { e.printStackTrace(); } } }
客户端代码:
import java.net.*; import java.nio.*; import java.nio.channels.*; public class client { public void start() { try { SocketAddress address = new InetSocketAddress("localhost",55555); SocketChannel client=SocketChannel.open(address); client.configureBlocking(false); String a="asdasdasdasddffasfas"; ByteBuffer buffer=ByteBuffer.allocate(20); buffer.put(a.getBytes()); buffer.clear(); int d=client.write(buffer); System.out.println("发送数据: "+new String(buffer.array())); while(true) { buffer.flip(); int i=client.read(buffer); if(i>0) { byte[] b=buffer.array(); System.out.println("接收数据: "+new String(b)); client.close(); System.out.println("连接关闭!"); break; } } } catch(Exception e) { e.printStackTrace(); } }
感谢各位的阅读,以上就是“Java NIO Socket通信的方法是什么”的内容了,经过本文的学习后,相信大家对Java NIO Socket通信的方法是什么这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是编程网,小编将为大家推送更多相关知识点的文章,欢迎关注!
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341