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

我会带着你远行 2022-04-25 01:34 563阅读 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直接关闭了。

  1. //绑定端口
  2. ChannelFuture future=b.bind(port);
  3. future.channel().closeFuture();
  4. } catch (InterruptedException e) {
  5. e.printStackTrace();
  6. } finally {
  7. //释放资源退出
  8. //bossGroup.shutdownGracefully();
  9. //workerGroup.shutdownGracefully();
  10. }

Netty优雅退出(同步方式)

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

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

Netty优雅退出(异步方式)

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

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

Netty退出做了一些事情

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

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

发表评论

表情:
评论列表 (有 0 条评论,563人围观)

还没有评论,来说两句吧...

相关阅读

    相关 golang

    目录 1、go 的调度 2、 golang中 map的底层实现 3、go 的垃圾回收机制 4、数组与切片的区别 5、go struct能不能比较 6、select