database - Spring boot：Exchange 发生错误时的 RabbitMq 和数据库管理

Question

如果找不到交换，我在管理 RabbitMQ 和数据库事务时遇到问题。这是简单的顺序：

1. 将消息发送到 Exchange
2. 在数据库中将已发送消息标记为已发送

当找不到 Exchange 时，不会发送消息，但是会在数据库中更新行，这不尊重事务行为。针对其他错误情况（DB 错误或 RabbitMQ 不可用）正确管理事务。

如何将此用例作为事务处理进行管理？

配置中启用的事务：

@Bean
@ConditionalOnMissingClass("org.springframework.orm.jpa.JpaTransactionManager")
public RabbitTransactionManager rabbitTransactionManager(ConnectionFactory connectionFactory) {
    return new RabbitTransactionManager(connectionFactory);
}

@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
    RabbitTemplate template = new RabbitTemplate(connectionFactory);
    template.setMessageConverter(jacksonMessageConverter());
    template.setChannelTransacted(true);
    return template;
}

我的服务：

@Override
@Transactional
public void push(Message message) {

    rabbitTemplate.convertAndSend(
                "MessageExchange",
                "binding.key",
                objectMapper.writeValueAsString(message));

    repository.markAsSent(message.getId());
}

离开方法后引发的错误，不在rabbitTemplate.convertAndSend方法中：

[AMQP Connection] ERROR o.s.a.r.c.CachingConnectionFactory.log : Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no exchange 'MessageExchange' in vhost '/', class-id=60, method-id=40)
[ThreadPoolTaskScheduler1] ERROR o.s.t.s.TransactionSynchronizationUtils.invokeAfterCompletion : TransactionSynchronization.afterCompletion threw exception
java.lang.IllegalStateException: Channel closed during transaction
    at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:1171)
    at com.sun.proxy.$Proxy143.txCommit(Unknown Source)
    at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.commitAll(RabbitResourceHolder.java:153)
    at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils$RabbitResourceSynchronization.afterCompletion(ConnectionFactoryUtils.java:332)

标签： databasespring-boottransactionsrabbitmq