future.channel().closeFuture().sync()作用 bind(port).sync()作用

一、实例

例子1

public class NettyServer {public static void main(String[] args) throws InterruptedException {EventLoopGroup parentGroup = new NioEventLoopGroup();EventLoopGroup childGroup = new NioEventLoopGroup();try {ServerBootstrap bootstrap = new ServerBootstrap();bootstrap.group(parentGroup, childGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<NioServerSocketChannel>() {@Overrideprotected void initChannel(NioServerSocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();//添加处理器pipeline.addLast(new StringDecoder());pipeline.addLast(new StringEncoder());}});//前面都是准备阶段，执行到bind这行的时候，原生nio代码里体现的init,register,bind Port才开始真正执行//这里也要进行阻塞sync()：保证在初始化完成后才进行操作ChannelFuture future = bootstrap.bind(8888).sync();System.out.println("服务器已启动。。。");//同步阻塞等待future.channel().closeFuture().sync();} finally {parentGroup.shutdownGracefully();childGroup.shutdownGracefully();}}
}

在这里面future.channel().closeFuture().sync();这个语句的主要目的是，如果缺失上述代码，则main方法所在的线程，即主线程会在执行完bind().sync()方法后，会进入finally 代码块，之前的启动的nettyserver也会随之关闭掉，整个程序都结束了。该语句能让线程进入wait状态，也就是main线程暂时不会执行到finally里面，nettyserver也持续运行，如果监听到关闭事件，可以优雅的关闭通道和nettyserver，虽然这个例子中，永远不会监听到关闭事件(代码比较简洁，没有涉及触发关闭事件的代码)。该例子仅仅为了展示存在api shutdownGracefully，可以优雅的关闭nettyserver。当然，如果你在代码中通过其他线程触发了关闭事件，此时main会响应事件，并进入finally代码块，进行优雅的关闭操作。

如果我们不想加f.channel().closeFuture().sync()又想保证程序正常运行怎么办，简单，去掉finally 里面关闭nettyserver的语句即可。下面我们来改造下：

public class NettyServer {public static void main(String[] args) throws InterruptedException {EventLoopGroup parentGroup = new NioEventLoopGroup();EventLoopGroup childGroup = new NioEventLoopGroup();try {ServerBootstrap bootstrap = new ServerBootstrap();bootstrap.group(parentGroup, childGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<NioServerSocketChannel>() {@Overrideprotected void initChannel(NioServerSocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();//添加处理器pipeline.addLast(new StringDecoder());pipeline.addLast(new StringEncoder());}});//前面都是准备阶段，执行到bind这行的时候，原生nio代码里体现的init,register,bind Port才开始真正执行ChannelFuture future = bootstrap.bind(8888).sync();System.out.println("服务器已启动。。。");//同步阻塞等待//future.channel().closeFuture().sync();} finally {//            parentGroup.shutdownGracefully();
//            childGroup.shutdownGracefully();}}
}

是不是一目了然了？其实入门例子可以完全按照我的改造的方法来演示，去掉f.channel().closeFuture().sync()。否则，对于刚入门的小白来说，无法理解这个例子中的奥义。

深入研究

前文得知，future.channel().closeFuture().sync()作用是为了让netty不会关闭，那么具体是什么原理呢？

原因是这样：

netty为了基于性能，多采用异步方式，而我们通过调用sync()方法，会让主线程间接调用wait()方法，进而实现阻塞的效果。当然，在简单的demo中，会这样实现阻塞，但是在正式环境下，一般不会这么写。同样的，在前面“b.bind(port).sync();”中也有sync()，原理类似，当调用bind(port)时，是异步的，因此为了保证在初始化完成后才进行操作，避免调用一个初始化未完成的句柄，sync方法是等待异步操作执行完毕。

总结就是：sync()让主线程间接调用wait()方法

当然也可以使用监听器进行异步回调

public class ASychNettyServer {public static void main(String[] args) throws InterruptedException {EventLoopGroup parentGroup = new NioEventLoopGroup();EventLoopGroup childGroup = new NioEventLoopGroup();ServerBootstrap bootstrap = new ServerBootstrap();bootstrap.group(parentGroup, childGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<NioServerSocketChannel>() {@Overrideprotected void initChannel(NioServerSocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();//添加处理器pipeline.addLast(new StringDecoder());pipeline.addLast(new StringEncoder());}});//前面都是准备阶段，执行到bind这行的时候，原生nio代码里体现的init,register,bind Port才开始真正执行//这里也要进行阻塞sync()：保证在初始化完成后才进行操作ChannelFuture future = bootstrap.bind(8888).sync();future.addListener((ChannelFutureListener) channelFuture -> {if(future.isSuccess()){System.out.println("8888端口绑定成功");System.out.println("服务器已启动。。。");}else {System.out.println("8888端口绑定失败");}});}
}