欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

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

程序员文章站 2022-04-22 21:56:14
...

前言

之前的写的轻量级的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的线程需要退出