5

我有一个使用 Hibernate 和 PostgreSQL 的 Spring 应用程序。它还使用 Spring AMQP (RabbitMQ)。

我正在使用配置如下的 Hibernate 事务管理器：

<bean id="transactionManager"
    class="org.springframework.orm.hibernate3.HibernateTransactionManager"
    p:sessionFactory-ref="sessionFactory" p:dataSource-ref="dataSource" />

我正在使用 SimpleMessageListenerContainer 进行异步消息接收，配置为：

@Resource(name="transactionManager")
private PlatformTransactionManager txManager;

@Autowired
private MyListener messageListener;

@Bean
public SimpleMessageListenerContainer mySMLC()
{
    final SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(rabbitConnectionFactory);
    container.setQueueNames("myQueue");

    final MessageListenerAdapter adapter = new MessageListenerAdapter(messageListener);
    adapter.setMessageConverter(converter);
    container.setMessageListener(adapter);
    container.setChannelTransacted(true);
    container.setTransactionManager(txManager);
    return container;
}

所以基本上我已经指定消息的接收需要是事务性的。消息侦听器调用一个服务，该服务可以具有使用@Transactional 注释的方法，并可能在数据库上执行 CRUD 操作。

我的问题是，使用 HibernateTransactionManager 在 SimpleMessageListenerContainer 级别管理事务是否有问题？使用 DB 事务管理器来包装从 RabbitMQ 接收消息会不会有任何问题？

我不期待 XA 在这里。我只想确保如果服务对数据库的任何操作失败，消息不会被 RabbitMQ 代理确认。

4

1 回答 1

1

根据 Spring 消息，MessageListenerContainer 的 transactionManager 属性的主要目的是在监听器调用之前收到消息开始事务，并在监听器返回或抛出异常后提交或回滚事务。所以不需要创建监听器方法@Transactional，因为在调用监听器方法之前事务已经开始了。

如果监听器出错，会抛出异常，DB 事务会回滚，并且不会向消息代理发送 ack（jms 事务回滚）。但是如果没有 XA，就会有重复的消息。例如，DB事务成功提交后，与消息代理的连接重置，无法向代理发送ack。重新连接代理后，可能会传递重复的消息。如果您承认这一点，则无需处理 XA。

于 2014-09-15T20:34:07.000 回答