技术提升：学会消息确认，提高SpringBoot中RabbitMQ可靠性

见解分享

2023-12-10 10:41:45

队列概念简析

在分布式系统中，队列作为一种重要的通信机制，能够异步地传递消息。如果将消息比作快递，那么队列就是中转站。它接收来自不同发送者的消息，并根据一定规则将消息存储起来，以便接收者取用。

什么是消息确认

消息确认，顾名思义，是指发送者确认消息已被队列成功接收。这种确认机制的意义在于，当发送者收到确认信息后，它才能保证消息已经安全地到达队列中，从而避免了消息丢失的可能性。

RabbitMQ中的消息确认

在RabbitMQ中，消息确认是一种可选的机制，并不是默认开启的。如果需要使用消息确认，则需要在发布消息时指定一个确认模式。RabbitMQ提供三种确认模式：

客户端确认 ：这种模式需要客户端在收到消息后向服务器发送确认信息，以确认消息已经被处理。
服务端确认 ：这种模式下，当服务器接收到消息时，会自动向客户端发送确认信息。
事务确认 ：这种模式下，消息确认与事务处理紧密相关。如果事务提交成功，则消息被确认；如果事务回滚，则消息不被确认。

如何使用消息确认

要使用消息确认，需要在发送消息时指定确认模式。在SpringBoot中，可以使用RabbitTemplate来发送消息。下面是一个使用客户端确认模式的示例代码：

RabbitTemplate template = new RabbitTemplate(connectionFactory);
template.setConfirmCallback((correlationData, ack, cause) -> {
    if (ack) {
        System.out.println("消息已确认");
    } else {
        System.out.println("消息未确认，原因：" + cause);
    }
});
template.convertAndSend("my-queue", "Hello, RabbitMQ!");