文章收录在网站: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,监听,消息 From: https://blog.csdn.net/qq_35508033/article/details/140886662RabbitMQ 优先级队列(Priority Queue)是一种特殊的队列,它根据消息的优先级将其放置在队列中。
当消费者从队列中获取消息时,它将按照优先级从高到低的顺序获取消息。
优先级队列可以用于处理一些需要按照优先级处理的消息,例如日志记录、任务调度等。