0

我正在开发一个使用几个 jms 队列向/从外部系统发送/接收更新的应用程序。为了测试我的应用程序,我使用了 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 项目上打开了一个问题,你可以在这里看到它。

4

1 回答 1

0

经过一番调查,我发现问题在于与 Spring 的不良交互DefaultMessageListenerContainer。该侦听器具有基于轮询的实现,并且鉴于模拟的基础架构在响应请求时非常快,导致 CPU 过载。我通过在响应方法中添加一个丑陋的线程睡眠来修补模拟跑步者,也许这迟早会被修复。

于 2015-03-28T08:10:56.493 回答