java hashed wheel timer netty_解决dubbo导致tomcat无法优雅shutdown的问题

Myth丶恋晨 2022-11-09 00:57 99阅读 0赞

问题由来

今天运行工程时，发现停止tomcat时，java进程并不会退出，而是必须kill -9杀掉tomcat进程。

问题出现时将线程dump出来后，发现有一个非daemon的线程仍在运行。

"Hashed wheel timer \#1" prio=6 tid=0x000000000ee73800 nid=0x750 waiting on condition \[0x000000001383e000\]

java.lang.Thread.State: TIMED\_WAITING (sleeping)

at java.lang.Thread.sleep(Native Method)

at org.jboss.netty.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:503)

at org.jboss.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:401)

at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)

at java.lang.Thread.run(Thread.java:745)

分析原因

com.alibaba.dubbo.remoting.transport.netty.NettyClient创建了一个NioClientSocketChannelFactory，而NioClientSocketChannelFactory在构造时又会创建一个NioClientBossPool，NioClientBossPool在构造时又会创建一个HashedWheelTimer，而HashedWheelTimer创建时使用的是Executors.defaultThreadFactory()，这个线程工厂创建的线程是非daemon的，因此必须调用NioClientSocketChannelFactory的releaseExternalResources方法才可以优雅地停止这些非daemon线程。而dubbo出于规避netty的一个bug

// 因ChannelFactory的关闭有DirectMemory泄露，

// 采用静态化规避 https://issues.jboss.org/browse/NETTY-424

private static final ChannelFactory channelFactory = new NioClientSocketChannelFactory(Executors.newCachedThreadPool(new NamedThreadFactory("NettyClientBoss", true)),

Executors.newCachedThreadPool(new NamedThreadFactory("NettyClientWorker", true)),

Constants.DEFAULT\_IO\_THREADS);

, 所以注释掉了NettyClient里的doClose方法里的逻辑

@Override

protected void doClose() throws Throwable \{

/\*try \{

bootstrap.releaseExternalResources();

\} catch (Throwable t) \{

logger.warn(t.getMessage());

\}\*/

而采用注册shutdownhook的方式进行资源的释放

static \{