如何解决JMS DefaultMessageListenerContainer 无法在 Spring 应用程序 context.close()
我正在听使用 spring 集成的 Solace 动态主题,如下所示:
<int-jms:message-driven-channel-adapter
id="myJmsAdapter" channel="receiveChannel" container="jmsContainer" />
<bean id="jmsContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="solaceConnectionFactory" />
<property name="destinationName" value="${my.topic}/#{main.getCar_type_value()}" />
<property name="pubSubDomain" value="true" />
<property name="sessionTransacted" value="false" />
</bean>
我能够聆听主题、使用消息并处理它。
但是在 System.exit(0)
上,即使 Spring 应用程序上下文在 ShutdownHook 内关闭,JMS 侦听器线程挂起并且无法正常关闭:
ctxt.registerShutdownHook();
...
trigger = new ShutdownTrigger(maxWaitForResponseMillis,ctxt);
trigger.startShutdownTimer();
Runtime.getRuntime().addShutdownHook(new Thread() {
public void run() {
log.info("Exiting Main Thread!");
ctxt.close();
}
});
应用程序在超时时正确关闭,但是当我尝试使用 System.exit(0) 形成其他类的计时器之前退出时,它不会关闭并且线程挂起。
定时器功能如下:
public void startShutdownTimer() {
timer.schedule(new TimerTask() {
@Override
public void run() {
log.info("Timer max wait has elapsed - triggering graceful
shutdown");
// perform some task here on timeout..
}
log.info("Returning with exit code: " + exitCode);
System.exit(exitCode); //this one works and it properly shutsdown
}
},maxWaitForResponseMillis);
}
我还尝试在关闭主类上的上下文之前添加 Timer.cancel ,如下所示,但没有奏效:
Runtime.getRuntime().addShutdownHook(new Thread() {
public void run() {
log.info("Cancelling current timer task..")
trigger.getTimer().cancel(); //it didnt work and the thread still hangs
log.info("Exiting Main Thread!");
ctxt.close();
}
});
我尝试取出 Timer 函数及其所有引用,以查看是否是导致此问题的计时器线程,但没有。即使删除了计时器任务,应用程序也会挂起。
以下是挂起期间的线程堆栈:
"Thread-3" #26 prio=5 os_prio=0 tid=0x00007fcf48024800 nid=0x60ad in Object.wait() [0x00007fd026ef1000]
java.lang.Thread.State: TIMED_WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
at org.springframework.jms.listener.DefaultMessageListenerContainer.doShutdown(DefaultMessageListenerContainer.java:568)
- locked <0x00000000ee0c9ec0> (a java.lang.Object)
at org.springframework.jms.listener.AbstractJmsListeningContainer.shutdown(AbstractJmsListeningContainer.java:237)
请帮忙找出问题和解决方案...
解决方法
您正在侦听器容器线程上调用 System.exit()
"jmsContainer-1" #24 prio=5 os_prio=0 tid=0x00007fdbd8e50800 nid=0xb77 in Object.wait() [0x00007fdb9f1bc000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waiting on <0x00000000f02cfb68> (a com.tdsecurities.fxts.vs.FxVsCashBalanceApp$1)
at java.lang.Thread.join(Thread.java:1245)
- locked <0x00000000f02cfb68> (a com.tdsecurities.fxts.vs.FxVsCashBalanceApp$1)
at java.lang.Thread.join(Thread.java:1319)
at java.lang.ApplicationShutdownHooks.runHooks(ApplicationShutdownHooks.java:106)
at java.lang.ApplicationShutdownHooks$1.run(ApplicationShutdownHooks.java:46)
at java.lang.Shutdown.runHooks(Shutdown.java:123)
at java.lang.Shutdown.sequence(Shutdown.java:167)
at java.lang.Shutdown.exit(Shutdown.java:212)
- locked <0x00000000c04335c8> (a java.lang.Class for java.lang.Shutdown)
at java.lang.Runtime.exit(Runtime.java:109)
at java.lang.System.exit(System.java:971)
这会导致应用程序上下文(线程 3 和线程 5)中的死锁(关闭容器)。
您可能需要将 System.exit()
调用移交给另一个线程,但我需要知道您使用的是哪个版本的 Spring 以进一步分析。否则很难关联转储中的行号。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。