我正在开发一个应用程序,该应用程序使用几个 jms 队列向外部系统发送/接收更新。为了测试我的应用程序,我正在使用Mockrunner,特别是jms模块。我面临着一个奇怪的行为:当我启动我的应用程序时,我可以看到 CPU 以 100% 的速度飙升,通过分析线程转储,我可以看到主要原因与我拥有的 jms 侦听器有关,这些监听器看起来像接收空消息,这会导致以下消息:
Consumer ... did not receive a message
现在我正在尝试了解问题是否与我的应用程序和模拟运行器的不良交互有关,还是配置错误。
配置的相关部分是:
<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项目上打开了一个问题,你可以在这里看到它。
经过一番调查,我发现问题在于与Spring DefaultMessageListenerContainer
的不良交互。该侦听器具有基于轮询的实现,并且鉴于模拟的基础结构在响应请求时非常快,则会导致 CPU 过载。我通过在响应方法中添加一个丑陋的线程睡眠来修补模拟运行器,也许这迟早会得到解决。