消息的确认
RabbitMQ需要对每一条发送的消息进行确认。消费者必须通过AMQP的basic.ack命令显式地向RabbitMQ发送一个确认,或者在订阅到队列的时候就将auto_ack参数设置为true。当auto_ack为true时,一旦消费者接收消息,RabbitMQ会自动视其确认了消息。需要注意的是消费者对消息的确认和告诉生产者消息已经被接收了这两件事毫不相关。以此,消费者通过确认命令告诉RabbitMQ它已经确认地接收到消息,同时RabbitMQ才能安全的把消息从队列中删除。
如果消费者受到一条消息,然后确认之前从RabbitMQ断开连接(或者从队列上取消订阅),RabbitMQ会认为这条消息没有分发,然后重新分发给下一个订阅的消费者。如果你的应用程序崩溃了,这样做可以确保消息会被发送给另一个消费者处理。另一方面,如果应用程序有bug而忘记确认消息的话,RabbitMQ将不会给该消费者发送更多的消息。这是因为在上一条消息被确认之前,Rabbit会认为这个消费者没有准备好接收下一条消息。利用这一点,可以防止rabbit持续不断的消息涌向你的应用而导致过载。
在收到消息后,如果想要拒接而不是确认收到消息,有两种做法:
(1)、把消费者从RabbitMQ服务器断开连接,这会导致RabbitMQ自动重新把消息入队并发送给另一个消费者,这样做的好处是所有的RabbitMQ版本都支持。缺点是,这样的连接、断开连接的方式会额外增加RabbitMQ的负担。
(2)、如果使用的是RabbitMQ2.0.0或更高版本,可以使用AMQP的basic.reject命令。顾名思义:basic.reject允许消费者拒绝RabbitMQ发送消息。如果把reject命令的requeue设置为true的话,RabbitMQ会将消息重新发送给下一个订阅者。如果设置为false的话,RabbitMQ会立即把消息从队列中移除,而不会把它发送给新的消费者。
原文地址:https://www.cnblogs.com/oskyhg/p/8521705.html