RabbitMQ–基础–10.4–优先级队列
1、优先级队列
- 指的是 具有高优先级的队列,优先级高的消息具备优先被消费的特权
- 可以通过 设置 x-max-priority 来设置 优先级队列
- 如果在消费者的消费速度远大于生产者的速度,且 Broker 没有消息堆积的情况下,对发送的消息设置优先级没有什么实际意义,因为生产者生产的消息,都能很快的被消费者立刻消灭掉
2、使用场景
在我们系统中有一个订单催付的场景,我们的客户在天猫下的订单,淘宝会及时将订单推送给我们,如果在用户设定的时间内未付款那么就会给用户推送一条短信提醒。
但是,tmall商家对我们来说,肯定是要分大客户和小客户的,比如像苹果,小米这样大商家,理所当然,他们的订单必须得到优先处理。
采用rabbitmq进行改造和优化,如果发现是大客户的订单给一个相对比较高的优先级,否则就是采用默认优先级。
3、设置优先级
3.1、设置队列的优先级(生产者)
Map<String, Object> arguments = new HashMap<>();
//官方允许是0-255之间,此处设置为10,允许优先级范围为1-10,不要设置过大,浪费CPU与内存
arguments.put("x-max-priority",10);
channel.queueDeclare(QUEUE_NAME,false,false,false,arguments);
3.1.1、要让队列实现优先级需要做如下事情
- 设置队列的优先级
- 设置消息的优先级
- 消费者需要等待
- 消息已经发送到队列中去,消费者才去消费,因为这样队列才有机会对消息进行排序。
3.2、设置消息的优先级
AMQP.BasicProperties properties = new AMQP.BasicProperties().builder().priority(5).build();
channel.basicPublish("",QUEUE_NAME,properties,message.getBytes());