由EJB事務管理器管理的Rabbit AMQPTemplate消息

Question

我正在使用spring amqp將消息放置在EJB（無狀態會話Bean）中的Rabbit隊列中。

當EJB容器拋出異常時回滾數據更新，是否有辦法讓EJB容器以類似的方式管理消息的發送，以便它只在EJB完成而沒有拋出異常？

Answer 1

做到這一點的最好辦法是：

1. 獲取所有

2. 使用Spring TX經理

3. 而且RabbitTemplate擺脫EJB將做TX同步的東西給你自動。

與EJB TX同步（提交或回滾），其RabbitTemplate沒有看到當前的TX，因爲它不是由Spring管理的問題。

如果可以將該EJB作爲Spring bean，那麼您將能夠爲EJB容器事務提供JtaTransactionManager，並用@Transactional標記EJB方法。但是在這種情況下，EJB並沒有發揮作用，因爲我們在這裏對Spring做了許多工作。

Answer 2

RabbitMQ沒有支持XA的驅動程序，因此不能由容器管理，您可以做的最好的方法是在模板上設置channelTransacted，並使用doInRabbit()方法將EJB代碼範圍設置爲...

template.execute(new ChannelCallback<Object>() { 
    @Override 
    public Object doInRabbit(Channel channel) throws Exception { 
     /// MDB logic + channel.basicPublish() 
    } 
}); 

然後，如果拋出異常，兩個事務都會回滾。

但是，如果EJB提交失敗，rabbit發佈將已經提交併且不會回滾，所以您應該計劃處理（罕見）重複。