Spring JMS 侦听器收到空消息,导致 CPU 消耗
Spring JMS listener receives empty messages causing CPU consumption
我正在开发一个使用几个 jms 队列 send/receive 更新 to/from 外部系统的应用程序。为了测试我的应用程序,我使用了 Mockrunner,特别是 jms 模块。
我遇到了一个奇怪的行为:当我启动我的应用程序时,我可以看到 CPU 以 100% 的速度飙升,并且通过分析线程转储,我可以看到主要原因与我拥有的 jms 侦听器有关比如收到空消息这会导致消息如下:
Consumer ... did not receive a message
现在我想了解这个问题是与我的应用程序和 mockrunner 的不良交互有关还是配置错误。
配置的相关部分是:
<bean id="destinationManager" factory-bean="mockRunnerJMSObjectFactory" factory-method="getDestinationManager" />
<bean id="mockJmsConnectionFactory" factory-bean="mockRunnerJMSObjectFactory" factory-method="createMockConnectionFactory" lazy-init="true"/>
和导致 CPU 无限旋转的侦听器是:
<jms:listener-container concurrency="5" connection-factory="mockJmsConnectionFactory" destination-type="queue" message-converter="myMessageConverter" acknowledge="transacted" >
<jms:listener
id="myListener"
destination="myQueue"
ref="myConsumer"
method="consume"
/>
</jms:listener-container>
<bean id="myConsumer"... />
更新
我在 Mockrunner 项目上开了一个 issue,你可以看看here。
经过一番调查,我发现问题出在与 Spring DefaultMessageListenerContainer
的不良交互上。该 Listener 具有基于轮询的实现,并且考虑到模拟基础结构在响应请求时非常快,导致 CPU 过载。我通过在响应方法中添加一个丑陋的线程睡眠来修补模拟运行器,也许这迟早会被修复。
我正在开发一个使用几个 jms 队列 send/receive 更新 to/from 外部系统的应用程序。为了测试我的应用程序,我使用了 Mockrunner,特别是 jms 模块。 我遇到了一个奇怪的行为:当我启动我的应用程序时,我可以看到 CPU 以 100% 的速度飙升,并且通过分析线程转储,我可以看到主要原因与我拥有的 jms 侦听器有关比如收到空消息这会导致消息如下:
Consumer ... did not receive a message
现在我想了解这个问题是与我的应用程序和 mockrunner 的不良交互有关还是配置错误。
配置的相关部分是:
<bean id="destinationManager" factory-bean="mockRunnerJMSObjectFactory" factory-method="getDestinationManager" />
<bean id="mockJmsConnectionFactory" factory-bean="mockRunnerJMSObjectFactory" factory-method="createMockConnectionFactory" lazy-init="true"/>
和导致 CPU 无限旋转的侦听器是:
<jms:listener-container concurrency="5" connection-factory="mockJmsConnectionFactory" destination-type="queue" message-converter="myMessageConverter" acknowledge="transacted" >
<jms:listener
id="myListener"
destination="myQueue"
ref="myConsumer"
method="consume"
/>
</jms:listener-container>
<bean id="myConsumer"... />
更新 我在 Mockrunner 项目上开了一个 issue,你可以看看here。
经过一番调查,我发现问题出在与 Spring DefaultMessageListenerContainer
的不良交互上。该 Listener 具有基于轮询的实现,并且考虑到模拟基础结构在响应请求时非常快,导致 CPU 过载。我通过在响应方法中添加一个丑陋的线程睡眠来修补模拟运行器,也许这迟早会被修复。