在本节中我将要讨论 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后接收到事件结果后做的一些操作。
相关文章
- 07-10《领域驱动设计:软件核心复杂性应对之道(修订版)》—第1章 1.3节持续学习
- 07-10《重构与模式(修订版)》—第1章1.4节测试驱动开发和持续重构
- 07-10Netty 异步的、事件驱动的网络应用程序框架和工具
- 07-10Netty实战一之异步和事件驱动
- 07-10Netty异步和事件驱动
- 07-10《策略驱动型数据中心——ACI技术详解》一第1章 数据中心架构考虑因素1.1 应用和存储
- 07-10第 1 章 Netty——异步和事件驱动 -------1.3
- 07-10《Android安全技术揭秘与防范》——第1章,第1.3节Android和iOS系统对比
- 07-10《Android的设计与实现:卷I》——第1章 1.3Android源码下载和编译
- 07-10《iOS和tvOS 2D游戏开发教程》——第1章,第1.3节挑战