Netty 异步模型

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

---

Future 说明

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

   //绑定一个端口并且同步, 生成了一个 ChannelFuture 对象
            //启动服务器(并绑定端口)
            ChannelFuture cf = bootstrap.bind(6668).sync();

            //给cf 注册监听器，监控我们关心的事件

            cf.addListener(new ChannelFutureListener() {
                @Override
                public void operationComplete(ChannelFuture future) throws Exception {
                    if (cf.isSuccess()) {
                        System.out.println("监听端口 6668 成功");
                    } else {
                        System.out.println("监听端口 6668 失败");
                    }
                }
            });

View Code