事务和异步处理

Question

假定一些弹簧bean有事务方法和它做两两件事：

• 异步发送JMS消息
• 更新DB

的问题是，当消息被消耗，DB事务有时不提交，并且处理程序无法在DB期望值中找到。

明显的解决方案是发送事务，但是我使用ActiveMQ上的异步发送来提高吞吐量。如果我发送交易，我会放弃异步，也有可能获得OuOfMemory。

你会如何解决这个问题？

Answer 1

您需要使用支持XA的事务管理器，并发送JMS消息并在同一分布式事务中对数据库执行更新。

这不会改变任何异步：发送呼叫将在接收者收到消息之前返回。但是当它收到它时，事务将被提交，接收者将在数据库中找到更新。

我没有看到OutOfMemoryErrors与此有什么关系。