1. 事务
AMQP 协议实现了事务机制,主要用于确保消息的原子性发布和确认。简单来说,它允许你将多个操作(如发送消息、确认消息)绑定在一起,要么全部成功,要么全部失败。
发送消息示例
在 Spring Boot 中,我们可以结合 @Transactional 注解来实现事务控制。下面是一个简单的生产者控制器示例:
@RestController
@RequestMapping("/producer")
public class ProducerController {
@Resource(name = "transRabbitTemplate")
private RabbitTemplate transRabbitTemplate;
@Transactional
@RequestMapping("/trans")
public String trans() {
// 发送第一条消息
transRabbitTemplate.convertAndSend("", Constants.TRANS_QUEUE, "trans test ---> 1");
// 故意抛出异常模拟业务失败,触发事务回滚
int num = 5 / 0;
// 如果上面没有异常,才会执行到这里
transRabbitTemplate.convertAndSend("", Constants.TRANS_QUEUE, "trans test ---> 2");
return "发送成功";
}
}
注意: Spring Boot 的 RabbitMQ 自动配置默认会开启确认模式(Publisher Confirms),但 RabbitMQ 不允许同一个通道同时使用事务模式和确认模式。因此,我们需要显式禁用 publisher confirms。
spring:
rabbitmq:
publisher-confirm-type: none
publisher-returns:


