《RabbitMQ系列教程-第七章-03-消息确认机制之事务处理模式》

ゝ一纸荒年。 2023-01-02 03:29 184阅读 0赞

# 教程说明 #

*  本系列教程目录大纲：[《RabbitMQ系列教程-目录大纲》][RabbitMQ_-]

--------------------

*  本系列教程配套代码：[https://gitee.com/Horizon1024/rabbitmt.git][https_gitee.com_Horizon1024_rabbitmt.git]（码云地址）

--------------------

# 消息确认机制之事务处理模式 #

RabbitMQ提供有事务处理机制，在一个事务中，多条消息要么全部发送成功，要么全部发送失败

编写`spring.xml`配置文件：

在spring配置文件中配置事务管理器

<bean id="transactionManager" class="org.springframework.amqp.rabbit.transaction.RabbitTransactionManager">
        <property name="connectionFactory" ref="connectionFactory"/>
    </bean>

#### 测试代码： ####

/** * rabbitmq事务处理模式 * 事务模式不能与confirms、returns并存,需要去spring配置文件中删除publisher-confirms="true"和publisher-returns="true"配置 * */
    @Test
    @Transactional
    @Rollback(false)        // 是否自动回滚(false:代表不是自动回滚),如果关闭了出现异常也不会回滚(测试异常的时候改为true)
    public void testTx() { 
    
        // 开启rabbitmq对事物的支持
        rabbitTemplate.setChannelTransacted(true);
    	
        // 开启消息回退
        rabbitTemplate.setMandatory(true);
        // 3. 发送消息
        rabbitTemplate.convertAndSend("test_exchange_confirm", "confirm", "message confirm1...");
    
        int i = 1 / 0;          // 模拟异常
    
        rabbitTemplate.convertAndSend("test_exchange_confirm", "confirm", "message confirm2...");
    }

[RabbitMQ_-]: https://blog.csdn.net/Bb15070047748/article/details/112194912
[https_gitee.com_Horizon1024_rabbitmt.git]: https://gitee.com/Horizon1024/rabbitmt.git