首页 文章

JMS消息在JMS侦听器中重新发送异常

提问于
浏览
4

Javadoc为 org.springframework.jms.listener.AbstractMessageListenerContainer 表示,如果

“sessionAcknowledgeMode”设置为“CLIENT_ACKNOWLEDGE”:成功侦听器执行后自动确认消息;如果抛出异常,则无法重新发送 .

我猜,“在抛出异常的情况下没有重新传递”意味着,即使jms监听器中抛出异常,该消息也不会被重新传递(因此,我的猜测,它会得到确认) . 但是,从侦听器抛出的异常意味着对它的调用不成功,并且由于没有确认应该重新发送 .

问题是:
What actually should happen with message acknowledgement in case of exception thrown in the jms listener?

从这个堆栈跟踪中可以看到真正发生的事情:

at org.springframework.jms.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:98)
at org.springframework.jms.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:66)
at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:660)
at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:620)
at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:591)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:308)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:246)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1142)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1134)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1031)

堆栈跟踪的第5行是特别感兴趣的 . 那里的代码基本上意味着,(大多数情况下)从侦听器抛出的任何异常都将绕过在 org.springframework.jms.listener.AbstractMessageListenerContainer#commitIfNecessary 中完成的确认 .
That's ok, but what does "no redelivery in case of exception thrown" mean then?

附加信息:
spring JMS:4.1.2

<bean id="someListenerContainerFactory" class="org.springframework.jms.config.DefaultJmsListenerContainerFactory">
    <property name="connectionFactory" ref="connectionFactory"/>
    <property name="concurrency" value="1-10"/>
    <property name="sessionAcknowledgeMode">
        <util:constant static-field="javax.jms.Session.CLIENT_ACKNOWLEDGE"/>
    </property>
</bean>

1 回答

  • 4

    这取决于您使用的侦听器容器;当使用AUTO ack模式时,侦听器返回后的 SimpleMessageListenerContainer acks(即传统的JMS MessageListener ) . 调用侦听器之前的 DefaultMessageListenerContainer 确认,因此您需要 acknowledgeMode="transacted" 来防止消息丢失 .

    这方面的javadocs有点误导,并且已经improved recently .

    使用CLIENT_ACKNOWLEDGE,您可以自行完成任务 . 那个doc只是意味着你是经纪人的心血来潮 . 根据JMS消息javadoc:

    可以重新传送已收到但未确认的消息

    根据我的经验,最好使用带有 SMLC 的auto ack和带有 DMLC 的事务 .

相关问题