美文网首页
dubbo导致tomcat停机失败,优雅停机

dubbo导致tomcat停机失败,优雅停机

作者: 把爱放下会走更远 | 来源:发表于2019-01-18 09:18 被阅读103次

问题由来

今天运行工程时,发现停止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))  

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

@Override
protected void doClose() throws Throwable {
    /*try {
        bootstrap.releaseExternalResources();
    } catch (Throwable t) {
        logger.warn(t.getMessage());
    }*/
}

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

static {
    Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
        public void run() {
            if (logger.isInfoEnabled()) {
                logger.info("Run shutdown hook of netty client now.");
            }
            try {
                channelFactory.releaseExternalResources();
            } catch (Throwable t) {
                logger.warn(t.getMessage());
            }
        }
    }, "DubboShutdownHook-NettyClient"));
}

但这个方案其实并不能释放Netty的资源,正常关闭java进程时,因为有非daemon线程存在,所以shutdownhook并不会执行,这就是个死循环。

解决方案

最后使用反射解决了此问题。

//先释放dubbo所占用的资源
ProtocolConfig.destroyAll();
//用反射释放NettyClient所占用的资源, 以避免不能优雅shutdown的问题
releaseNettyClientExternalResources();
private void releaseNettyClientExternalResources() {
    try {
        Field field = NettyClient.class.getDeclaredField("channelFactory");
        field.setAccessible(true);
        ChannelFactory channelFactory = (ChannelFactory) field.get(NettyClient.class);
        channelFactory.releaseExternalResources();
        field.setAccessible(false);
        LOGGER.info("Release NettyClient's external resources");
    } catch (Exception e){
        LOGGER.error("Release NettyClient's external resources error", e);
    }
}

相关文章

  • dubbo导致tomcat停机失败,优雅停机

    问题由来 今天运行工程时,发现停止tomcat时,java进程并不会退出,而是必须kill -9杀掉tomcat进...

  • Dubbo ShutdownHook 优雅停机整理

    Dubbo优雅停机的机制 Dubbo是通过JDK的ShutdownHook来完成优雅停机的所以如果用户使用 kil...

  • Dubbo在Docker中的优雅停机

    Dubbo在Docker中的优雅停机 优雅停机 优雅停机是指在停止应用时,执行的一系列保证应用正常关闭的操作。这些...

  • 这个Map你肯定不知道,毕竟存在感确实太低了。

    这是why哥的第 75 篇原创文章 从Dubbo的优雅停机说起 好吧,其实本文并不是讲 Dubbo 的优雅停机的。...

  • dubbo - 优雅停机

    开篇 这篇文章主要的目的是想分析下dubbo优雅停机的过程,整个文章参考网上很多现成的文章,本着尊重原创的精神会在...

  • dubbo优雅停机

    1 概要说明 我们在关闭或重启dubbo服务时往往会出现请求超时而导致pv lost。 2 原因分析 关闭dubb...

  • Dubbo 优雅停机

    之前的几个章节都在讲解Dubbo的种种流程性的逻辑,首先讲到了服务启动和服务调用,然后又讲到了服务治理的一些内容。...

  • Dubbo优雅停机

    简介 Dubbo 是通过 JDK 的 ShutdownHook 来完成优雅停机的,所以如果用户使用 kill -9...

  • Dubbo 优雅停机

    优雅停机特性是所有 RPC 框架中非常重要的特性之一,因为核心业务在服务器中正在执行时突然中断可能会出现严重后果,...

  • SmartLifecycle之RocketMq优雅停机

    SmartLifecycle之RocketMq优雅停机 前言 线上环境发布重启时,经常会导致mq消费失败,不够优雅...

网友评论

      本文标题:dubbo导致tomcat停机失败,优雅停机

      本文链接:https://www.haomeiwen.com/subject/ycugdqtx.html