第 1 章 Netty——异步和事件驱动 -------1.3

在本节中我将要讨论 Netty 的主要构件块:
? Channel;
? 回调;
? Future;
? 事件和 ChannelHandler。
1.3.1 Channel
它代表一个到实体(如一个硬件设备、一个文件、一个网络套接字或者一个能够执行一个或者多个不同的I/O操作的程序组件)的开放连接,如读操作和写操作。目前,可以把 Channel看作是传入(入站)或者传出(出站)数据的载体。因此,它可以 被打开或者被关闭,连接或者断开连接。
1.3.2 回调
一个回调其实就是一个方法,一个指向已经被提供给另外一个方法的方法的引用。这使得后者,可以在适当的时候调用前者。回调在广泛的编程场景中都有应用,而且也是在操作完成后通知相关方最常见的方式之一。
public class ConnectHandler extends ChannelInboundHandlerAdapter { @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { System.out.println( "Client " + ctx.channel().remoteAddress() + " connected"); } }当一个新的连接已经被建立时 channelActive(ChannelHandler Context)将会被调用。
1.3.3 Future
和Java的concurrent.Future差不多,但是其所提供的实现,只 允许手动检查对应的操作是否已经完成,或者一直阻塞直到它完成。所以 Netty 提供了它自己的实现——ChannelFuture,用于在执行异步操作的时候使用。
ChannelFuture提供了几种额外的方法,这些方法使得我们能够注册一个或者多个 ChannelFutureListener实例。监听器的回调方法operationComplete(),将会在对应的操作完成时被调用 。然后监听器可以判断该操作是成功地完成了还是出错了。如果是后者,我们可以检索产生的Throwable。简而 言之 ,由 ChannelFutureListener提供的通知机制消除 了手动检查对应的操作是否完成的必要。
1.3.4 事件和 ChannelHandler
Netty 使用不同的事件来通知我们状态的改变或者是操作的状态。这使得我们能够基于已经 发生的事件来触发适当的动作。相当于在进行了回调或者说future后接收到事件结果后做的一些操作。

第 1 章 Netty——异步和事件驱动 -------1.3

上一篇:Webpack安装配置及打包详细过程


下一篇:三种特殊的JS代码加密