@JmsListener并坚持到数据库

问题描述

我正在研究一种服务，在该服务中，我侦听队列，反序列化收到的消息，并将其持久化到数据库（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中，我设置了并发性和setSessionTransacted(true)。这足以使整个onMessage具有事务性吗？这样一来，就可以接收一条消息并将其保存在一个事务中，如果在任何这些点上出现故障，则回滚该消息？ 当尝试保存特定消息时，我尝试将异常抛出-消息确实已回滚到队列，并且侦听器尝试再次使用它们，这是一种期望的行为。 在研究这个问题时，我偶然发现了分布式事务jta事务管理器，但是我不确定除了setSessionTransacted（true）还是Spring Boot是否自动处理XA资源事务之外，是否还需要配置更多事务。 寻求建议。谢谢。

解决方法

如果您的侦听器的onMessage()与接收消息的JMS代理（而不是呼叫setSessionTransacted(true)的JMS代理）进行交互，则不是足以使所有交互都具有事务性。

JMS中的“事务处理”会话仅涵盖具有该特定会话的JMS操作。它不涉及与任何其他事务性资源（例如数据库）一起使用。

如果您要进行的事务涉及侦听器消耗消息，以及侦听器完成的任何其他事务处理工作（例如，在数据库中更新或插入记录，将JMS消息发送给另一个代理等），那么您需要一个可以使用XA资源的JTA事务管理器，以便协调各个事务阶段（例如，准备，提交，回滚）。这类交易有时称为“分布式”交易。

这是一个相当普遍的用例，因为它使JMS消息成为一种“工作单元”，并且您知道消息是否被消耗掉了，那么与该消息有关的所有工作也都可以成功完成，反之亦然。这是MDB在Java EE中提供的主要功能之一，但是在Spring中也可以完成相同的基本工作。

根据Spring Boot documentation，您可以与少数几个不同的交易管理器（例如Atomikos，Bitronix，Narayana等）集成以完成此类工作。

要清楚，在某些情况下，您现有的安排将以某种方式工作，以使这两个操作似乎在同一事务中。例如，如果您的数据库操作引发异常，并且该异常从onMessage()引发，则消息将回滚到队列中。但是，在这种情况下，这两个操作只是相关。它们不在同一个事务中，因此它们实际上不会是原子的。如果取而代之的是数据库操作成功，然后由于某种原因从侦听器的onMessage()引发了另一个异常，或者JMS代理在可以提交事务会话之前崩溃了，那么该消息最终将回滚到队列中，但是数据也将保留在数据库中，以便再次使用该消息时，表面上又会将相同的数据写入数据库。