本文介紹了MDP JMS事務(wù)回滾，然后在無限循環(huán)中重新處理消息的處理方法，對(duì)大家解決問題具有一定的參考價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)吧！
問題描述
如果通過指定sessionTransacted=true或transactionManager=jmsTransactionManager在DefaultMessageListenerContainer上啟用事務(wù)管理，則只要MDP中發(fā)生異常，事務(wù)就會(huì)回滾，消息就會(huì)放回隊(duì)列。這會(huì)導(dǎo)致消息被再次處理，事務(wù)一次又一次地回滾，從而創(chuàng)建一個(gè)無限循環(huán)。
我想我的問題是..。我錯(cuò)過了什么嗎？如果消息只是意味著它將被反復(fù)處理，那么為什么要讓它回到隊(duì)列中呢？
<!-- jms connection factory -->
<bean name="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="java:ConnectionFactory" />
</bean>
<!-- jms transaction manager -->
<bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager">
<property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>
<!-- Destination for Inbound_Email_Q -->
<bean name="inboundEmailDestination" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="queue/inbound_Email_Queue" />
</bean>
<!-- JmsTemplate for Inbound_Email_Q -->
<bean name="jmsInboundEmailTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="defaultDestination" ref="inboundEmailDestination" />
<property name="messageConverter" ref="xmlMessageConverter" />
</bean>
<!-- jms asynchronous listener -->
<bean id="emailMessageServiceMdp" class="org.site.wso.core.jms.EmailMessageServiceMdp" />
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory"/>
<!-- <property name="transactionManager" ref="jmsTransactionManager" /> -->
<!-- <property name="sessionTransacted" value="true"/> -->
<property name="destination" ref="inboundEmailDestination"/>
<property name="messageListener" ref="messageListener"/>
</bean>
<!-- jms message listener adapter -->
<bean id="messageListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg>
<bean class="org.site.wso.core.jms.EmailMessageServiceMdp"/>
</constructor-arg>
<property name="messageConverter" ref="xmlMessageConverter"/>
</bean>
這是我的MDP：
public class EmailMessageServiceMdp implements MessageDelegate {
public void handleMessage(Object object) {
EmailMessageRequestVO requestVO = (EmailMessageRequestVO) object;
try {
//Service call that throw exception
} catch (Exception e) {
throw new ApplicationException(e);
}
}
}
JMS
消息重新傳遞只是您的[已配置]推薦答案實(shí)現(xiàn)的默認(rèn)行為。這是一個(gè)無休止的爭論，它的相對(duì)用處是什么，但看起來，與其丟棄包含一些可能無法恢復(fù)的數(shù)據(jù)的消息，某種形式的重試是一種明智和保守的方法。例如，在您的示例中，您似乎要將JMS消息轉(zhuǎn)換為電子郵件消息并調(diào)度到SMTP服務(wù)器。如果SMTP網(wǎng)關(guān)關(guān)閉，您可能希望保留JMS消息，并在網(wǎng)關(guān)重新啟動(dòng)時(shí)重新處理它們。
一般來說，我認(rèn)為您處理失敗的消息的選項(xiàng)有(取決于JMS實(shí)現(xiàn))：
-
丟棄郵件。
將消息寫入錯(cuò)誤隊(duì)列。
延遲n秒后重新傳遞郵件。
重新傳遞消息n次，然后將消息寫入錯(cuò)誤隊(duì)列。
在延遲n秒x次后重新傳遞消息，然后將消息寫入錯(cuò)誤隊(duì)列。
如果您喜歡#1，那么只需取消異常，提交事務(wù)并向消息揮手告別即可。對(duì)于睡覺，應(yīng)該由jms配置(或者目的地特定配置)來處理。
此外，如果您需要更具體的內(nèi)容，可以查詢消息的getJMSRedelivered()和/或特定于實(shí)現(xiàn)的消息頭屬性，該屬性指示消息已重新傳遞了多少次(受大多數(shù)JMS實(shí)現(xiàn)支持，但不是標(biāo)準(zhǔn)的)，并相應(yīng)地處理該消息。
這篇關(guān)于MDP JMS事務(wù)回滾，然后在無限循環(huán)中重新處理消息的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，
