Netty进阶之路--优雅的退出

我会带着你远行 2022-04-25 01:34 588阅读 0赞

### Netty进阶之路--优雅的退出 ###

*  前言
 *  Netty优雅退出
 *   *  Netty优雅退出（同步方式）
     *  Netty优雅退出（异步方式）
 *  Netty退出做了一些事情

# 前言 #

之前的写的轻量级的RPC框架基础功能差不多搭建完了，还差一些全局配置中心和网关，这两个打算后期在慢慢写。目前一直在看关于Netty相关的书籍和资料，主要是希望自己能够在通信那块加强一些和把RPC框架（Netty方面的）优化一下，也为了以后找工作做准备。

主要再看2本电子书  
1.Netty权威指南  
2.Netty进阶之路 跟着案例学Netty  
这两本应该足够我目前的学习了。

# Netty优雅退出 #

目前我们的Netty都是通过tomcat或者其他容器开启一个线程来启动的，所以当我们的这些容器退出的时候，我们的Netty也需要退出。

我们绑定端口之后同样需要等待端口关闭之后再进行资源的释放。但是由于这些操作Netty都不在主线程中进行的，换句话说Netty是通过异步的方式来绑定端口和监听端口关闭的(当然Netty也支持同步的方式)，所以如果我们通过异步方式，但是又直接在finally中将资源释放那就意味着，Netty直接关闭了。

//绑定端口
                ChannelFuture future=b.bind(port);
                future.channel().closeFuture();
    		} catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                //释放资源退出
                //bossGroup.shutdownGracefully();
                //workerGroup.shutdownGracefully();
            }

## Netty优雅退出（同步方式） ##

我们只需要将操作同步起来就ok了（但是我认为这个同步阻塞等待服务端退出是违背Netty的初衷的）

ChannelFuture future=b.bind(port).sync();
                future.channel().closeFuture().sync();

## Netty优雅退出（异步方式） ##

我们通过异步的方式退出并释放资源才是Netty的优雅退出

//绑定端口 同步等待成功
                ChannelFuture future=b.bind(port).sync();
                System.out.println("netty server start on port:"+port);
                //采用非同步方法退出netty 通过异步的方法不会被阻塞
                future.channel().closeFuture().addListener(new ChannelFutureListener() {
    				@Override
    				public void operationComplete(ChannelFuture future) throws Exception {
    					// TODO Auto-generated method stub
    					//释放资源退出
    					System.out.println(future.channel().toString()+" 链路关闭");
    		            bossGroup.shutdownGracefully();
    		            workerGroup.shutdownGracefully();
    				}
    			});
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                //释放资源退出
                //bossGroup.shutdownGracefully();
                //workerGroup.shutdownGracefully();
            }

# Netty退出做了一些事情 #

虽然我们仅仅用了2行代码就将Netty的资源释放了其实底层还是做了许许多多的事情的。

1.  积压在发送队列中的待发送消息需要发送完成
2.  正在读写的消息，需要做处理
3.  NioEventLoopGroup中的有些定时任务需要处理
4.  NIO的线程需要退出