2个ActiveMQ实例之间的事务管理？

Question

我有一个独立的应用程序（一个简单的命令行 jar），它已经可以从 ActiveMQ 队列读取或生成消息（无事务）。

我想添加能够从远程 ActiveMQ 队列读取消息并将其放入另一个远程 ActiveMQ 队列的功能。这 2 个 ActiveMQ 可能完全不同，也可能不一样，如果有任何连接问题，我还想确保在传输过程中不会丢失任何消息。

我一直在阅读大量关于事务的文章，据我所知，因为我在两个完全不同的 ActiveMQ 之间进行传输，所以一个简单的 Spring JmsTransactionManager 是不够的，而是需要某种分布式事务管理（比如XA 事务）。

我完全迷失在互联网上找到的关于几个不同库等的代码示例的海洋中。

谁能告诉我找到解决这个问题的最简单方法的方法？我应该以某种方式在 Spring 之上使用 JTA（在非 j2ee 应用程序服务器环境中使用 JTA 是否可行）？我已经在使用 spring 的 jmstemplate 来发送/接收消息，所以如果我可以继续使用 spring（最好没有 xml 上下文配置，因为我今天以编程方式进行所有操作）。

Answer 1

如果您不需要对第二个远程 ActiveMQ 的写入与读取在同一事务范围内，那么您可以在没有分布式事务的情况下执行此操作。您可以保持打开读取事务，直到您成功写入第二个远程 ActiveMQ。一旦成功，您就可以提交读取事务。然而，这意味着，如果在发送之后但在读取提交之前发生故障，您最终将重新发送消息。因此，这假设重复发送是可以的。如果你不能容忍在失败的情况下重复发送，你必须有分布式事务。