如何解决@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代理在可以提交事务会话之前崩溃了,那么该消息最终将回滚到队列中,但是数据也将保留在数据库中,以便再次使用该消息时,表面上又会将相同的数据写入数据库。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。