Netty剖析之Netty异步模型

浅浅的花香味﹌ 2023-07-03 06:15 66阅读 0赞

### 异步模型基本介绍 ###

1.  异步的概念和同步相对，当一个异步过程调用发出后，调用者不能立刻得到结果。实际处理这个调用的组件在完成后，通过状态、通知、回调来通知调用者。
2.  Netty中IO操作是异步的，包括Bind，write，connect等操作会简单的返回一个channelFuture
3.  调用者并不能立刻获得结果，而是通过Future-Listener机制，用户可以方便的主动获取或者通过通知机制获得IO操作结果
4.  Netty的异步模型是建立在future和callback之上的。callback就是回调，future的核心思想是：假设有一个方法执行非常耗时，等待这个方法执行完再返回结果，显然是不合适的，那么就可以在调用此方法的时候，立马返回一个future，后续可以通过future去监控方法的处理过程，即Future-Listener机制

### Future介绍 ###

1.  表示异步的执行结果，可以通过它提供的方法来检测执行是否完成，比如检索计算等等
2.  channelFuture是一个接口（public interface ChannelFuture extends Future），我们可以手动添加监听器，当监听的事件发生时，就会通知到监听器

示意图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70]  
目的：

1.  再使用Netty进行编码时，拦截操作和转换出入站数据只需要提供callback和利用future即可，这使得链式操作简单、高效、并有利于编写可重用的、通用的代码
2.  Netty框架的目标就是让你的业务逻辑从网络基础应用编码中分离出来，解脱处理

### Future-Listener机制 ###

当future对象刚刚创建时，处于非完成状态，调用者可以通过返回的channelFuture来获取操作执行的状态，注册监听函数来执行完成后的操作

常见的操作：

1.  通过isDone方法来判断当前操作是否完成
2.  通过isSuccess方法来判断已完成的当前操作是否成功
3.  通过getCause方法来获取已完成的当前操作失败的原因
4.  通过isCancelled方法来判断已完成的当前操作是否被取消
5.  通过addListener方法来注册监听器，当操作已完成，将会通知指定的监听器

代码示例：

// 绑定端口
    ChannelFuture channelFuture = serverBootstrap.bind(8899).sync();
    // 注册监听器
    channelFuture.addListener(new ChannelFutureListener() {
        @Override
        public void operationComplete(ChannelFuture channelFuture) throws Exception {
            if (channelFuture.isSuccess()) {
                System.out.println("端口绑定成功~");
            } else {
                System.out.println("端口绑定失败~");
            }
        }
    });

只需要在你需要异步监听结果的代码后面调用sync方法，然后返回一个ChannelFuture对象，即可注册监听器

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200203121937333.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n,size_16,color_FFFFFF,t_70