当前位置：首页 > article >正文

Rabbitmq高级特性之消费方确认

article 2025/1/22 5:35:53

背景：

发送方发送消息之后，到达消费端之后，可能会有以下情况：消息处理成功，消息处理异常。RabbitMQ在向消费者发送消息之后，就会把这条消息给删除掉，那么第二种情况，就会造成消息丢失，为了保证是顺利到达消费方，RabbitMQ提供了消息确认机制。消费者在订阅队列时，可以指定autoAck参数，根据这个参数设置，消息确认机制分为以下两种：自动确认和手动确认。

RabbitMQ原生api中的消费消息的方法：

ps：接下的代码都是基于AMQP来实现的（基于Spring对RabbitMQ进行了一层封装）

1.手动确认

当autoAck为false的时候，RabbitMQ会等待消费者显式的调用Basic.Ack命令，回复确认信号后才从内存或磁盘中移去消息，该种方式适合对消息可靠性要求比较高的场景。

（1）application.yml配置

要基于AMQP实现手动确认，只需修改application.yml（或.properities）的配置：

manual：手动确认，必须显示调用basicAck方法来确认消息，如果消息未被确认，RabbitMQ会认为消息尚未被成功处理，并且会在消费者可用时重新投递该消息，这种模式提高了消息处理的可靠性，因为即使消费方消费失败，消息也不会消失，而是可以被重新处理。

auto：自动确认，这种模式下，消费者在消息处理成功时会自动确认消息，但是如果处理过程中出现异常，则不会确认消息。

none：这种模式下，无论消费者有没有处理成功消息，RabbitMQ都会自动确认消息，从RabbitMq中移除消息，如果消息处理失败，那么可能会导致丢失。

（2）manual方式示例

config配置类：

controller类：

listen类：

现在开启手动确认，但是却没有手动确认，此时访问对应接口（127.0.0.1:8080/producer/ack）：

启动台打印：

RabbitMQ管理界面：

未被确认的消息会在合适时机重新入队，有消费者监听队列时，投递给消费者进行消费。

现在进行修改代码：

刚才滞留的消息，会立即被重新消费，此时已经进行了手动确认：

查看RabbitMQ管理界面：

滞留的消息确认已经被重新消费了。

2.自动确认

自动确认开启的情况下，会自动把发送出去大的消息置为确认，然后从内存中（或者硬盘）删除，而不管消费者是否真正地消费到了这些消息，自动确认模式适合对于消息可靠性要求不高的场景。

有auto和none，两者在未发生异常的情况下是相同：自动确认消息。

2.1 auto方式示例

（1）application.yml配置文件：

（2）controller类：

（3）producer类：

（4）正常启动，并访问接口127.0.0.1:8080/producer/ack:

观察RabbitMQ管理界面：（消息发送到消费端后，消费成功后就从RabbitMQ上移除了）

（5）设置异常，然后启动并访问接口127.0.0.1:8080/producer/ack:

可以看到客户端在不断报错：

这是因为在auto模式下，如果在消费过程中出现异常，消费会立即重新入队进行消费，由于还是一个消费方，所以会一直报错（一直重复上述过程），观察RabbitMQ管理界面也可以看到中有一条消息处于Ready状态（这也是会一直重新入队消费的原因，不同manual方式下如果没有手动确认的消息会处于Unacked状态下，只有进行了手动确认才会从RabbitMQ中移除）