bio 和 nio 作为 server 端,当建立了 10 个连接时,分别产生多少个线程?
答案: 因为传统的 io 也就是 bio 是同步线程堵塞的,所以每个连接都要分配一个专用线程来处理请求,这样 10 个连接就会创建 10 个线程去处理。而 nio 是一种同步非阻塞的 i/o 模型,它的核心技术是多路复用,可以使用一个链接上的不同通道来处理不同的请求,所以即使有 10 个连接,对于 nio 来说,开启 1 个线程就够了。
publicclassdemoserverextendsthread{ privateserversocket serversocket; publicint getport(){ return serversocket.getlocalport(); } publicvoid run(){ try{ serversocket =newserversocket(0); while(true){ socket socket = serversocket.accept(); requesthandler requesthandler =newrequesthandler(socket); requesthandler.start(); } }catch(ioexception e){ e.printstacktrace(); }finally{ if(serversocket !=null){ try{ serversocket.close(); }catch(ioexception e){ e.printstacktrace(); } } } } publicstaticvoid main(string[] args)throwsioexception{ demoserver server =newdemoserver(); server.start(); try(socket client =newsocket(inetaddress.getlocalhost(), server.getport())){ bufferedreader bufferedreader =newbufferedreader(newinputstreamreader(client.getinputstream())); bufferedreader.lines().foreach(s ->system.out.println(s)); } } } // 简化实现,不做读取,直接发送字符串 classrequesthandlerextendsthread{ privatesocket socket; requesthandler(socket socket){ this.socket = socket; } @override publicvoid run(){ try(printwriter out =newprintwriter(socket.getoutputstream());){ out.println("hello world!"); out.flush(); }catch(exception e){ e.printstacktrace(); } } }
这样,一个简单的 socket 服务器就被实现出来了。
(图片来源于杨晓峰)
publicclassnioserverextendsthread{ publicvoid run(){ try(selector selector =selector.open(); serversocketchannel serversocket =serversocketchannel.open();){// 创建 selector 和 channel serversocket.bind(newinetsocketaddress(inetaddress.getlocalhost(),8888)); serversocket.configureblocking(false); // 注册到 selector,并说明关注点 serversocket.register(selector,selectionkey.op_accept); while(true){ selector.select();// 阻塞等待就绪的 channel,这是关键点之一 set<selectionkey> selectedkeys = selector.selectedkeys(); iterator<selectionkey> iter = selectedkeys.iterator(); while(iter.hasnext()){ selectionkey key = iter.next(); // 生产系统中一般会额外进行就绪状态检查 sayhelloworld((serversocketchannel) key.channel()); iter.remove(); } } }catch(ioexception e){ e.printstacktrace(); } } privatevoid sayhelloworld(serversocketchannel server)throwsioexception{ try(socketchannel client = server.accept();){ client.write(charset.defaultcharset().encode("hello world!")); } } // 省略了与前面类似的 main }
可以看到,在前面两个样例中,io 都是同步阻塞模式,所以需要多线程以实现多任务处理。而 nio 则是利用了单线程轮询事件的机制,通过高效地定位就绪的 channel,来决定做什么,仅仅 select 阶段是阻塞的,可以有效避免大量客户端连接时,频繁线程切换带来的问题,应用的扩展能力有了非常大的提高。下面这张图对这种实现思路进行了形象地说明。
作者: 王磊的博客
免费java资料领取,涵盖了java、redis、mongodb、mysql、zookeeper、spring cloud、dubbo/kafka、hadoop、hbase、flink等高并发分布式、大数据、机器学习等技术。
传送门:
如对本文有疑问, 点击进行留言回复!!
[杭电多校2020]第一场 1004 Distinct Sub-palindromes
Swift -- 将本地生成的UIImage进行持久化保存(存到文件中fileManager.createFile)
网友评论