文章收录在网站：http://hardyfish.top/

文章收录在网站：http://hardyfish.top/

文章收录在网站：http://hardyfish.top/

文章收录在网站：http://hardyfish.top/

基本原理

消息的可靠性投递

RabbitMQ 消息的投递路径为：

• 生产者 ------> 交换机 ------> 队列 ------> 消费者

在 RabbitMQ 工作的过程中，每个环节消息都有可能传递失败，可以通过以下三种模式来监听消息时候投递成功：

• 确认模式（Confirm）：可以监听消息是否从生产者成功传递到交换机。

• 退回模式（Return）：可以监听消息是否从交换机成功传递到队列。

• 消费者消息确认（Consumer Ack）：可以监听消费者是否成功处理消息。

高级特性

消费端限流

RabbitMQ 提供了一种 Qos（Quality Of Service，服务质量）服务质量保证功能。

即在非自动确认消息的前提下，如果一定数目的消息未被确认之前，不再进行消费新的消息。

通过消费端限流的方式限制消息的拉取速度，达到保护消费端的目的。

不公平分发

在 RabbitMQ 中，多个消费者监听同一条队列，则队列默认采用的轮询分发。

但是在某种场景下这种策略并不是很好，例如消费者1 处理任务的速度非常快，而其他消费者处理速度却很慢。

• 此时如果采用公平分发，则消费者1 有很大一部分时间处于空闲状态。
• 此时可以采用不公平分发，即谁处理的快，谁处理的消息多。

消息存活时间

可以设置消息的存活时间（Time To Live，简称TTL），单位是毫秒，当消息到达存活时间后还没有被消费，会被移出队列。

RabbitMQ 可以对队列的所有消息设置存活时间，也可以对某条消息设置存活时间。

• 消息到达存活时间未被消费时，消息会被放入死信队列。

优先级队列

RabbitMQ 优先级队列（Priority Queue）是一种特殊的队列，它根据消息的优先级将其放置在队列中。

当消费者从队列中获取消息时，它将按照优先级从高到低的顺序获取消息。

优先级队列可以用于处理一些需要按照优先级处理的消息，例如日志记录、任务调度等。