OpenBloX的发送接收机制

OpenBloX的发送接收机制

OpenBlox使用Java的NIO库来实现的网络间通信。

1,Java的NIO库介绍

Java.nio：定义很多基本类型缓存(Buffer)；

Java.nio.channels：定义通道及选择器等；

Java.nio.charset：字符的编码解码。

通道(Channel)首先在选择器(Selector)中注册自己感兴趣的事件，当相应的事件发生时，选择器便通过选择键(SelectionKey)通知已注册的通道。然后通道将需要处理的信息，通过缓存(Buffer)打包，编码/解码，完成输入输出控制。

通道

主要介绍ServerSocketChannel 和SocketChannel，它们都是可选择的(Selectable)通道，分别可以工作在同步和异步两种方式下，可选择是指可以有选择的注册自己感兴趣的事件。可以用channel.configureBlocking(Boolean)来设置其工作方式。ServerSocketChannel相当于ServerSocket，SocketChannel相当于Socket。

其在异步(非阻塞)的工作方式下的情况：

在服务器端，ServerSocketChannel通过静态函数open()返回一个实例serverChl。然后该通道调用serverChl.socket().bind()绑定到服务器某端口，并调用register(Selector sel,SelectionKey.OP_ACCEPT)注册OP_ACCEPT事件到一个选择器中(ServerSocketChannel只可以注册OP_ACCEPT事件)。当有客户请求连接时，选择器就会通知该通道有客户连接请求，就可以进行相应的输入输出控制了。

在客户端，clientChl实例注册自己感兴趣的事件(可以是OP_CONNECT,OP_READ,OP_WRITE的组合)后，调用clientChl.connect(InetSocketAddress)连接服务器然后进行相应处理。

选择器和选择键

选择器(Selector)的作用是：将通道感兴趣的事件放入队列中，而不是马上提交给应用程序，等已注册的通道自己来请求处理这些事件。即，选择器将会随时报告已经准备好了的通道，而且是按照先进先出的顺序。选择器是通过选择键来报告，选择键的作用就是表明哪个通道已经做好了准备，准备干什么。如果选择器中尚无通道已注册事件发生，调用Selector.select()将阻塞，直到有事件发生为止。另外，可以调用selectNow()或select(long timeout)，前者立即返回，没有事件时返回0值，后者等等timeout后返回。

2,OpenBloX的发送接收机制

NIO中selector的注册：ConnectionsThreadTCP.handleAcceptable() ->registerChannel()->selectableChannel.register(selector,interestOps,channelWrapper);

发送信息

信息的发送，通过Peer.send(MessageBase message)来完成。Peer.send()方法，是通过调用以下方法来完成的PeerChannels peerChannels.send(tempBuffer);
然后通过ChannelWrapper workingChannel.write(buffer) 来完成。因此，发送信息时，信息由接口ChannelWrapper的实现类SocketChannelWrapper封装，该封装的类保持一个final类型的SocketChannel对象，即信息(ByteBuffer)最终写入SocketChannel对象中。

接收信息

信息的接收，通过ConnectionsThread.loopSelector()方法，监听是否有信息到达。如果有信息到达，则调用handleReadable继续处理，最后是通过SessionFactory.handleReceivedRequest(ByteBufferWrapper bufferWrapper,int offset,String originHost)或者handleReceivedAnswer来完成。在handleReadable中获取信息时，通过Key来得到接口ChannelWrapper的具体实现类的对象。之后的处理过程，则是通过对获取到的对象进行处理。