Spring Boot AMQP怎么开启confirm模式?
时间: 2024-05-11 07:18:20 浏览: 131
要开启Spring Boot AMQP的Confirm模式,可以通过以下步骤完成:
1. 首先,在application.yml或application.properties文件中添加以下配置:
```yaml
spring.rabbitmq.publisher-confirm-type: correlated
```
2. 然后,在你的RabbitMQ配置类中,添加以下代码:
```java
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
if (ack) {
log.info("消息发送成功:correlationData({}),ack({}),cause({})", correlationData, ack, cause);
} else {
log.error("消息发送失败:correlationData({}),ack({}),cause({})", correlationData, ack, cause);
}
});
return rabbitTemplate;
}
```
这段代码将设置Confirm模式,并在消息发送成功或失败时记录日志。
现在,当你发送消息时,RabbitMQ将会确认消息是否被成功接收。如果消息发送成功,你将会在日志中看到“消息发送成功”;如果发送失败,你将会看到“消息发送失败”。
阅读全文