强制关服的危害
linux中关服如果我们使用
kill -9 pid号
或者在windows中使用
taskkill /f /pid pid号
来关服的话,相当于是突然断电的方式,会导致如下几种情况。
- 缓存中的数据丢失
- 正在进行文件的写操作,没有更新完成,突然退出会导致文件损坏
- 线程消息队列中的消息丢失
- 句柄资源没有及时释放等其他问题
如何优雅退出
方法1.使用JDK的ShutdownHook的方式来实现。调用System.exit(0)会调用到这个注册的方法。同时是用Kill -15 也是会调用这个钩子方法。
//第一种方式注册JDK的ShutdownHook来实现优雅关机
Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
public void run() {
System.out.println("ShutdownHook关服了");
}
},"shutdown"));
方法2.使用信号量的方式来实现。具体的逻辑如下
具体的代码实现如下
//第二中方式:监听信号量并注册SignalHandler的方式来是优雅关服
String type = System.getProperties().getProperty("os.name").toLowerCase().startsWith("win")?"INT":"TERM";
Signal sig = new Signal(type);
SignalHandler shutdownHandle = new MySignalHandler();
Signal.handle(sig,shutdownHandle);
public class MySignalHandler implements SignalHandler {
public void handle(Signal signal) {
System.out.println("通过信号量的方式来关闭服务器");
System.exit(0);
}
}
上面的方法可以使用Ctrl+C来触发。
注意:这里使用的 System.exit(0);可以触发方法1中的钩子方法。因此可以两个方法都写到同一个项目中。
方案1和2的劣势
通过注册ShutdownHook退出要注意的问题如下
- JVM崩溃、无法接收信号量和Kill -9 pid等,是不会被执行的
- 多个ShutdownHook存在时,是无法保证他们的执行顺序
- JVM关闭期间不能动态添加或者去除ShutdownHook
- 不能在ShutdownHook中调用System.exit(),它会卡住JVM,导致进程无法退出
通过注册SignalHandler实现的退出要注意如下
- 要避免阻塞操作,否则会导致已经注册的ShutdownHook无法执行,系统无法退出
Netty优雅退出
netty优雅退出设计到的主要操作和资源对象
Netty优雅退出源码分析
优雅退出的入口是如下代码
group.shutdownGracefully();
我们跟进去看看都做了什么神秘的操作。
workerGroup.shutdownGracefully();
|-io.netty.util.concurrent.AbstractEventExecutorGroup#shutdownGracefully
|-io.netty.util.concurrent.MultithreadEventExecutorGroup#shutdownGracefully //这里是将多个子工作进程进行关服
|-io.netty.util.concurrent.SingleThreadEventExecutor#shutdownGracefully
上述的操作完成之后将状态改为了 ST_SHUTTING_DOWN
private static final int ST_NOT_STARTED = 1;
private static final int ST_STARTED = 2;
private static final int ST_SHUTTING_DOWN = 3;
private static final int ST_SHUTDOWN = 4;
private static final int ST_TERMINATED = 5;
由于NioEventLoop中有一个无线循环的操作因此进来这里
io.netty.channel.nio.NioEventLoop#run
|-io.netty.channel.DefaultSelectStrategy#calculateStrategy //选择策略(选择的是NioEventLoop、EpollEventLoop还是KQueueEventLoop)
|-io.netty.channel.nio.NioEventLoop#processSelectedKeys 处理多了选择器的Key
|-io.netty.channel.AbstractChannel.AbstractUnsafe#close(io.netty.channel.ChannelPromise)
//关掉channel
//包括:
//将发送消息队列清空,不在允许发送新的消息
//判断当前链路是否还有消息正在发送,有则将SelectionKey的去注册操作封装成Task放到eventLoop中稍后再执行
|-io.netty.channel.nio.NioEventLoop#closeAll //把注册在selector中的所有的Channel都关闭掉
|-io.netty.util.concurrent.SingleThreadEventExecutor#confirmShutdown //检查是否已关闭,若关闭成功则退出线程
//操作如下:
//1.光雕所有的定时器任务ScheduledFutureTask
//2.轮询任务队列中的所有任务,并执行他们
//3.运行所有的ShutdownHook任务
上面就是netty关服的一些关键类以及方法。方便后续自己查找。这是我跟踪Netty关服的一些记录。希望对大家有用。