首页 > 代码库 > RabbitMQ-优先级(priority)队列/消息

RabbitMQ-优先级(priority)队列/消息

就像在日常生活中,事情有轻重缓急一样。我们对于需要处理的消息也有这样的需求。

例如重要的消息我要尽快的得到处理,当然我们可以给重要的消息开个“VIP通道”,但是VIP数量很多,并且VIP也分层次呢?

这时给消息加上优先级是一个很好的选择。

在RMQ中想要使用需要优先级特性需要的版本为3.5+


然后我们只需做两件事情:

    1. 将队列声明为优先级队列,即在创建队列的时候添加参数 x-max-priority 以指定最大的优先级,值为0-255(整数)。

    2. 为优先级消息添加优先级。

 

注意,没有指定优先级的消息会将优先级以0对待。 对于超过优先级队列所定最大优先级的消息,优先级以最大优先级对待。对于相同优先级的消息,后进的排在前面。

 

RabbitMQ-优先级(priority)队列/消息