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

素颜马尾好姑娘i 2022-12-20 15:52 195阅读 0赞

Reactor模式是把一个完整的IO操作分成几部分来进行，使用一个或多个Reactor来处理IO请求，对于具体的IO读写以及数据读取完成后的操作，分成更细粒度的模块，根据具体的需求和模块的耗时，来选择性使用单线程或是多线程或者线程池来完成整个IO操作。

来看具体的例子：

[![Reactor简单例子][Reactor]][Reactor_Reactor]  
[![Reactor简单例子][Reactor 1]][Reactor_Reactor 1]  
  
[![Reactor简单例子][Reactor 2]][Reactor_Reactor 2]  
Reactor实现了Runnable接口，为多线程做准备（实际应用中未必要使用多线程，很多时候使用单线程）；

注册accpet事件；

设置通道为非阻塞。

[![Reactor简单例子][Reactor 3]][Reactor_Reactor 3]  
[![Reactor简单例子][Reactor 4]][Reactor_Reactor 4]  
这里的while (true)和单线程的IO多路复用一致，不同的是在dispatch分发这里，这里可以选择单线程继续执行，也可以使用多线程执行，根据IO操作的耗时来决定。

这里的key.attachment()第一次是在Reactor初始化时设置的：

[![Reactor简单例子][Reactor 5]][Reactor_Reactor 5]  
attach了一个Acceptor对象。

接下来来看Acceptor：

[![Reactor简单例子][Reactor 6]][Reactor_Reactor 6]  
Acceptor同样实现了Runnable接口，为多线程做准备，根据实际需要来决定是否使用多线程。

[![Reactor简单例子][Reactor 7]][Reactor_Reactor 7]  
在Acceptor里，对客户端连接的请求进行处理：

设置非阻塞模式；

注册读事件；

attach具体的处理handler。

selector.wakeup()针对多线程，唤醒selector.select()方法上阻塞的线程。

这里sk.attach(new Handler(sk, sc));后，会返回到Reactor的while(true)主循环里dispatch()方法进行处理：

[![Reactor简单例子][Reactor 8]][Reactor_Reactor 8]

最后来看具体的处理Handler：

[![Reactor简单例子][Reactor 9]][Reactor_Reactor 9]  
Handler同样实现Runnable接口，为多线程做准备。

添加一个state变量，用来区分 读/写 操作。

[![Reactor简单例子][Reactor 10]][Reactor_Reactor 10]  
[![Reactor简单例子][Reactor 11]][Reactor_Reactor 11]  
  
[![Reactor简单例子][Reactor 12]][Reactor_Reactor 12]  
在Handler里进行具体的IO读写并且对 读/写 监听事件进行切换。

[Reactor]: https://img-blog.csdnimg.cn/img_convert/0bfe61a22cf0df6f7014f8135c831451.png
[Reactor_Reactor]: /images/20221120/3184948b5d0447a6bd6ae06cde018db2.png
[Reactor 1]: https://img-blog.csdnimg.cn/img_convert/43a13e332a765d3318167338026ff5b2.png
[Reactor_Reactor 1]: /images/20221120/c7a17308d3304c5a8da0272444bef710.png
[Reactor 2]: https://img-blog.csdnimg.cn/img_convert/2cc6b09d52b785922025109c92c3beb3.png
[Reactor_Reactor 2]: /images/20221120/f6f133e265924a4f91a120f4b21d1a8d.png
[Reactor 3]: https://img-blog.csdnimg.cn/img_convert/16caa223ea3be3acbd40a0140093f539.png
[Reactor_Reactor 3]: /images/20221120/589241db9c9743c9b9c181d50630aba5.png
[Reactor 4]: https://img-blog.csdnimg.cn/img_convert/f4805faecdd151e0a52725072d0af614.png
[Reactor_Reactor 4]: /images/20221120/bf498c1762d54c69800244ea648dbfc6.png
[Reactor 5]: https://img-blog.csdnimg.cn/img_convert/01a2d0d6c9671e7eb66aa8d1afc2245a.png
[Reactor_Reactor 5]: /images/20221120/544e181d160c47e18d4b155967ad04a6.png
[Reactor 6]: https://img-blog.csdnimg.cn/img_convert/fd39460d2c385a64213fb54e99802e82.png
[Reactor_Reactor 6]: /images/20221120/0228c44397a14a88991b19c0ff3ba6d5.png
[Reactor 7]: https://img-blog.csdnimg.cn/img_convert/aed764305769a503144e3bc8bbb8ebb6.png
[Reactor_Reactor 7]: /images/20221120/6a94537b71664a659e90a82c4dcad404.png
[Reactor 8]: https://img-blog.csdnimg.cn/img_convert/c314cd45429c843573377efd216749f2.png
[Reactor_Reactor 8]: /images/20221120/1cfcd32bf8d24b0bbc1d7346f1e7ff6a.png
[Reactor 9]: https://img-blog.csdnimg.cn/img_convert/b8608bb798e0e20ca7c7c262eaaa83ae.png
[Reactor_Reactor 9]: /images/20221120/e40b66caef8e4b8798ee22d207bf223b.png
[Reactor 10]: https://img-blog.csdnimg.cn/img_convert/8ce1648dc3b302f72af90a9627766ba7.png
[Reactor_Reactor 10]: /images/20221120/67a257884bdb4db29821c38067704844.png
[Reactor 11]: https://img-blog.csdnimg.cn/img_convert/5a0b15a9cf3694e4128788f3e956e07c.png
[Reactor_Reactor 11]: http://album.sina.com.cn/pic/004dzziXzy7mmk6uWw31b
[Reactor 12]: https://img-blog.csdnimg.cn/img_convert/d56eedd07062f837dde0cc75fb4372c1.png
[Reactor_Reactor 12]: http://album.sina.com.cn/pic/004dzziXzy7mmk6M5Ica8