the reactor pattern and java nio

前端之家收集整理的这篇文章主要介绍了the reactor pattern and java nio前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
在《java NIO》作者PPT《How to Build a Scalable Multiplexed Server With NIO》 和 Doug Lea 《Scalable IO in Java》PPT中
都有java nio的实现是通过reactor pattern 来实现的有说明。java nio作为一种跨平台IO操作。在不同平台上面封装了对应平台的IO模型。
在reactor pattern 作者中已经提及,通过reactor pattern 模式可以来实现跨平台操作。所以,java nio通过reactor pattern模式就是这样完成的。
java nio在window 平台下面是使用Select 模型。对于java nio源代码的分析,对于如果理解reactor pattern的设计模式意义不大。因为java nio实现中

需要对JNI的封装。如果要了解对于不同平台的封装,可以通过ZThead库来了解会有更大的意义。这样可以避免对JNI 的干扰。因为JNI涉及到脚本语言java和C/C++交互的知识。

How to Build a Scalable Multiplexed Server With NIO

Reactor Pattern Mapped to NIO
Handle
SelectionKey
Event
SelectionKey.OP_READ,etc
Demultiplexer
Selector
Dispatcher
Selector.select() + iterate Selector.selectedKeys()
Handler
An instance of Runnable or Callable

最简单例子:TestReactor.java


  1. public class TestReactor
  2. {
  3. public static void main(String[] args) throws Exception
  4. {
  5. //创建serversocketchannel通道.
  6. ServerSocketChannel serversocketchannel =ServerSocketChannel.open();
  7. //设置非阻塞,异步模式
  8. serversocketchannel.configureBlocking(false);
  9. //关联的serversocket
  10. ServerSocket serversocket = serversocketchannel.socket();
  11. SocketAddress endpoint =new InetSocketAddress("127.0.0.1",8888);
  12. //绑定指定的端口
  13. serversocket.bind(endpoint);
  14. //创建Selector。在Reactor Pattern模式中,相当于Demultiplexer 作用,用来多路复用器
  15. Selector sel = Selector.open();
  16. //在select中注册链接事件。
  17. //在reactor 模式中SelectionKey 相当于event事件。
  18. //在SectionKey中存在OP_READ,OP_WRITE,OP_CONNECT,OP_ACCEPT 事件类型。此时与OP_ACCEPT 关联的Channel为ServerSocketChannel
  19. SelectionKey selKey = serversocketchannel.register(sel,SelectionKey.OP_ACCEPT);
  20. while(true)
  21. {
  22. //进行阻塞操作,等待事件的到来。返回值在select 模型中表示完成操作的数目
  23. int selCount = sel.select();
  24. if(selCount>0)
  25. {
  26. System.out.println("selCount=>>"+selCount);
  27. }
  28. //返回可以操作的键集合。在window select 模型中,返回可以操作的fd_set集合
  29. Set<SelectionKey> selKeySet = sel.selectedKeys();
  30. for(SelectionKey key:selKeySet)
  31. {
  32. //在SelectionKey中,存在链接可以接受事件,则调用accept()函数就不会存在阻塞现象。
  33. //select
  34. if(key.isAcceptable())
  35. {
  36. //获取与SelectionKey.OP_ACCEPT关联的通道。即ServerSocketChannel.
  37. ServerSocketChannel serverChannel = (ServerSocketChannel)key.channel();
  38. //调用ServerSocketChannel 不会发生阻塞。获取到客户链接
  39. SocketChannel socketchannel = serverChannel.accept();
  40. //设置阻塞模式
  41. socketchannel.configureBlocking(false);
  42. //关联SocketChannel的读和写事件
  43. socketchannel.register(sel,SelectionKey.OP_READ|SelectionKey.OP_WRITE);
  44. //同时可以在SelectionKey中关联其他对象。在Select 模式中,Selectionkey 相当于Completionkey参数
  45. }
  46. if(key.isWritable())
  47. {
  48. SocketChannel socketchannel = (SocketChannel)key.channel();
  49. ByteBuffer src =ByteBuffer.allocate(100);
  50. src.putInt(100);
  51. src.flip();
  52. socketchannel.write(src);
  53. //关联SocketChannel的读和写事件
  54. socketchannel.register(sel,SelectionKey.OP_READ);
  55. //同时可以在SelectionKey中关联其他对象。在Select 模式中,Selectionkey 相当于Completionkey参数
  56. }
  57. if(key.isReadable())
  58. {
  59. SocketChannel socketchannel = (SocketChannel)key.channel();
  60. InetSocketAddress remote = (InetSocketAddress)socketchannel.getRemoteAddress();
  61. String remotestring = remote.getHostString()+remote.getPort();
  62. //关联SocketChannel的读和写事件
  63. socketchannel.register(sel,SelectionKey.OP_WRITE);
  64. //同时可以在SelectionKey中关联其他对象。在Select 模式中,Selectionkey 相当于Completionkey参数
  65. }
  66. selKeySet.remove(key);
  67. }
  68. }
  69. }
  70. }

猜你在找的React相关文章