`
fly_ever
  • 浏览: 152720 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

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的具体实现类的对象。之后的处理过程,则是通过对获取到的对象进行处理。

 

0
3
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics