@JmsListener和持久化到数据库

Question

我正在开发一个服务，在该服务中，我侦听队列，反序列化接收到的消息，并将它们持久化到数据库（Oracle）。大致情况：

@JmsListener(destination="some-destination")
public void onMessage(Message message) throws Exception {
    String message = ((TextMessage) message).getText();
    service.save(deserialize(message));
    // includes exception handling etc
}

在缺省消息侦听器bean中，我设置并发性和setSessionTransactived（true）。这足以使整个onMessage具有事务性吗？因此，在一个事务中接收并保存一条消息，并在其中任何一点出现故障时回滚？当试图保存特定消息时，我尝试对其抛出异常，消息确实被回滚到队列，侦听器再次尝试使用它们，这是一种理想的行为。在研究这个问题时，我偶然发现了分布式事务，即jta事务管理器，但我仍然不确定除了SetSessionTransact（true）之外是否还需要配置更多事务，或者Spring Boot是否自动处理XA资源的事务。寻求建议。非常感谢。

Answer 1

如果您的侦听器的onMessage（）正在与事务性资源交互，而不是从JMS代理接收消息，那么调用setSessionTransactived（true）不足以使所有交互都是事务性的。

JMS中的“事务化”会话仅涵盖该特定会话的JMS操作。它不包括使用任何其他事务性资源（例如数据库）的工作。

如果您想要一个涉及监听器对消息的使用以及监听器所做的任何其他事务工作（例如，更新或插入数据库中的记录，向另一个代理发送JMS消息等）的事务，那么您需要一个JTA事务管理器，它可以与XA资源一起工作，以协调各个事务阶段（例如，准备、提交、回滚）。这些类型的事务有时称为“分布式”事务。

这是一个相当常见的用例，因为它将JMS消息转换为一种“工作单元”，您知道如果消息被使用，那么与该消息相关的所有工作也会成功完成，反之亦然。这是MDB在Java EE中提供的主要内容之一，但同样的重要工作也可以在Spring中完成。

根据Spring Boot文档，您可以与一些不同的事务管理器（例如Atomikos、Bitronix、Narayana等）集成来完成这类工作。

需要明确的是，在某些情况下，您现有的安排将以这样一种方式工作，使这两个操作看起来是在同一事务中。例如，如果您的数据库操作引发异常，并且该异常是从onMessage（）引发的，则消息将回滚到队列中。然而，在这种情况下，这两个操作只是相互关联的。它们不在同一事务中，因此它们实际上不会是原子的。相反，如果数据库操作成功，然后由于某种原因，监听器的onMessage（）引发了另一个异常，或者JMS代理在提交事务会话之前崩溃，那么消息最终将回滚到队列中，但数据也将仍然在数据库中，这样，如果再次使用消息，表面上就可以编写将相同的数据再次发送到数据库。