同步非阻塞IO例子_晏无心_新浪博客

布满荆棘的人生 2022-12-20 15:52 105阅读 0赞

同步非阻塞IO是指在进行IO读写时，可以立即返回，不用阻塞等待read、write完全结束。

java实现同步非阻塞IO需要使用Java NIO技术。

先来看server端：

[![同步非阻塞IO例子][IO]][IO_IO]  
使用iava nio的ServerSocketChannel，设置

serverChannel.configureBlocking(true);

是为了方便测试，serverSocket阻塞的等待客户端的连接，连接成功后再向下执行。

channel.configureBlocking(false);

将与客户端交互的socket设置为非阻塞模式，这样IO read、write的时候就可以立即返回，不用阻塞等待。

channel.write()

向客户端发送数据。

再来看客户端：

[![同步非阻塞IO例子][IO 1]][IO_IO 1]  
客户端使用java nio的SocketChannel连接服务端。

socket.configureBlocking(false);

设置IO连接为非阻塞模式。

socket.read(buffer);

读取服务器端发送的数据。

因为服务端和客户端的IO读写是非阻塞模式的，socket.read()会立即返回，所以这里读取到buffer里的数据不一定是完整的。

这里通过Thread.sleep(3000);后进行多次读取，如果服务端的IO写时间比较长，那么客户端的IO读也要多次读取才能将服务器端发送的数据读取完整。

来看例子的结果：

[![同步非阻塞IO例子][IO 2]][IO_IO 2]  
可以看出，客户端每次读取的数据内容是递增的。

非阻塞模式和阻塞模式的区别就是阻塞模式，socket.read()必须等待服务端完全发送消息结束才返回，如果服务器端发送数据耗时很长，客户端将会被一直阻塞而不能进行其他操作；

而对于非阻塞模式来说，socket.read()会立即返回，客户端可以进行其他操作，但需要多次去read才能保证读取完整的服务端发送的消息。

[IO]: https://img-blog.csdnimg.cn/img_convert/c07eca4664779d162bb104adebe6aef9.png
[IO_IO]: /images/20221120/e66159b03bb14b31bf629127093801fb.png
[IO 1]: https://img-blog.csdnimg.cn/img_convert/f8217216d85e74c0604a3feda31f4d1c.png
[IO_IO 1]: /images/20221120/d1e12c42b47943d187be3ce373fa01ef.png
[IO 2]: https://img-blog.csdnimg.cn/img_convert/e5958db5364979b88a4dc12ba5ac78f0.png
[IO_IO 2]: /images/20221120/1aaa52ee34d34d81ac037c90376fbf63.png

发表评论取消回复

表情：

评论列表（有 0 条评论，105人围观）

还没有评论，来说两句吧...

相关阅读

相关 javafuture和Callable简单例子_晏无心_新浪博客

[![javafuture和Callable简单例子][javafuture_Callable]][javafuture_Callable_javafuture_Callabl

「爱情、让人受尽委屈。」/ 2022年12月20日 15:52/ 0 赞/ 109 阅读

相关 Reactor简单例子_晏无心_新浪博客

Reactor模式是把一个完整的IO操作分成几部分来进行，使用一个或多个Reactor来处理IO请求，对于具体的IO读写以及数据读取完成后的操作，分成更细粒度的模块，根据具体的

素颜马尾好姑娘i/ 2022年12月20日 15:52/ 0 赞/ 196 阅读

相关同步非阻塞IO例子_晏无心_新浪博客

同步非阻塞IO是指在进行IO读写时，可以立即返回，不用阻塞等待read、write完全结束。 java实现同步非阻塞IO需要使用Java NIO技术。先来看se

布满荆棘的人生/ 2022年12月20日 15:52/ 0 赞/ 106 阅读

相关常见的IO模型_晏无心_新浪博客

一、服务器端编程经常需要构造高性能的IO模型，常见的IO模型有四种： 1.同步阻塞IO（Blocking IO）：即传统的IO模型。 2.同步非阻塞IO（Non-block

客官°小女子只卖身不卖艺/ 2022年12月20日 15:51/ 0 赞/ 134 阅读

相关 RPC的简单例子和理解_晏无心_新浪博客

RPC，远程过程调用，目的是实现调用远程的方法和调用本地方法一样，开发者可以通明的使用，感觉不到远程调用的存在。自己写了个RPC的简单例子，依赖于http协议，采

男娘i/ 2022年12月20日 15:51/ 0 赞/ 133 阅读

相关同步阻塞IO简单例子_晏无心_新浪博客

同步阻塞IO是最基本的IO操作。直接来看例子。先看Server端： [![同步阻塞IO简单例子][IO]][IO_IO] 启动一个ServerSocket等

一时失言乱红尘/ 2022年12月20日 15:51/ 0 赞/ 143 阅读

相关初识dubbo_晏无心_新浪博客

互联网技术发展的很快。想起刚毕业那会，大多数公司还在使用EJB，spring和maven还没有完全的普及。在公司的第一个项目，就是将技术框架从EJB变为spring，项

ゝ一世哀愁。/ 2022年12月20日 15:51/ 0 赞/ 147 阅读

相关 springmvc集成freemarker_晏无心_新浪博客

springmvc使用FreeMarkerViewResolver来处理ModelAndView，将页面渲染交给FreeMarkerView来处理。在springmvc.x

梦里梦外;/ 2022年12月20日 15:51/ 0 赞/ 201 阅读

相关 springmvcHandlerMapping解析_晏无心_新浪博客

Spingmvc中的HandlerMapping负责解析请求URL，对应到Handler进行处理（这里的Handler一般为Controller里的一个方法method，也可以

蔚落/ 2022年12月20日 12:56/ 0 赞/ 192 阅读

相关 Springmvc HandlerAdapter解析_晏无心_新浪博客

springmvc中HanlderMapping和HandlerAdapter一般是对应出现（并不是一一对应，一个HandlerAdapter可以匹配处理多个HandlerMa

客官°小女子只卖身不卖艺/ 2022年12月20日 12:56/ 0 赞/ 182 阅读