就像在日常生活中,事情有轻重缓急一样。我们对于需要处理的消息也有这样的需求。
例如重要的消息我要尽快的得到处理,当然我们可以给重要的消息开个“VIP通道”,但是VIP数量很多,并且VIP也分层次呢?
这时给消息加上优先级是一个很好的选择。
在RMQ中想要使用需要优先级特性需要的版本为3.5+。
然后我们只需做两件事情:
1. 将队列声明为优先级队列,即在创建队列的时候添加参数 x-max-priority 以指定最大的优先级,值为0-255(整数)。
2. 为优先级消息添加优先级。
注意,没有指定优先级的消息会将优先级以0对待。 对于超过优先级队列所定最大优先级的消息,优先级以最大优先级对待。对于相同优先级的消息,后进的排在前面。
时间: 2024-11-03 09:48:49