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的资源释放了其实底层还是做了许许多多的事情的。
- 积压在发送队列中的待发送消息需要发送完成
- 正在读写的消息,需要做处理
- NioEventLoopGroup中的有些定时任务需要处理
- NIO的线程需要退出
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/15329.html