[000-01-022].第03节：RabbitMQ中的优先级队列

9.2. 优先级队列

9.2.1. 利用场景

• 1在我们体系中有一个订单催付的场景，我们的客户在天猫下的订单,淘宝会及时将订单推送给我们，如果在用户设定的时间内未付款那么就会给用户推送一条短信提醒，很简单的一个功能对吧；
  
• 2.但是上述情况，tmall商家对我们来说，肯定是要分大客户和小客户的对吧，比如像苹果，小米如许大商家一年起码能给我们创造很大的利润，所以理应固然，他们的订单必须得到优先处置惩罚，而曾经我们的后端体系是利用 redis 来存放的定时轮询，大家都知道 redis 只能用 List 做一个简简单单的消息队列。
  
• 3.redis并不能实现一个优先级的场景，所以厥后，当订单量大了后接纳 RabbitMQ 进行改造和优化,如果发现是大客户的订单给一个相对比力高的优先级，否则就是默认优先级。
  

9.2.2.优先级的添加方法；

• a.控制台页面添加
  
• b.队列中代码添加优先级
  

1. Map<String, Object> params = new HashMap();
2. params.put("x-max-priority", 10);
3. channel.queueDeclare("hello", true, false, false, params);

复制代码

• c.消息中代码添加优先级
  

1. AMQP.BasicProperties properties = new
2. AMQP.BasicProperties().builder().priority(5).build();

复制代码

• d.注意事项
  
  
  
  • 要让队列实现优先级需要做的事变有如下事变:
    
    
    
    • 1.队列需要设置为优先级队列
      
    • 2.消息需要设置消息的优先级
      
    • 3.消费者需要等候消息已经发送到队列中才去消费因为，如许才有机会对消息进行排序
      
    
    
  
  

9.2.3. 实战

9.3.惰性队列：

9.3.1.利用场景

• 1.RabbitMQ 从 3.6.0 版本开始引入了惰性队列的概念。惰性队列会尽可能的将消息存入磁盘中，而在消费者消费到相应的消息时才会被加载到内存中，它的一个重要的计划目的是能够支持更长的队列，即支持更多的消息存储。当消费者由于各种各样的原因(比如消费者下线、宕机亦大概是由于维护而关闭等)而致使长时间内不能消费消息造成堆积时，惰性队列就很有须要了。
  
• 2.默认情况下，当生产者将消息发送到 RabbitMQ 的时间，队列中的消息会尽可能的存储在内存之中，如许可以更加快速的将消息发送给消费者。即使是持久化的消息，在被写入磁盘的同时也会在内存中驻留一份备份。当 RabbitMQ 需要释放内存的时间，会将内存中的消息换页至磁盘中，这个利用会耗费较长的时间，也会壅闭队列的利用，进而无法接收新的消息。固然 RabbitMQ 的开发者们一直在升级相关的算法，但是效果始终不太理想，尤其是在消息量特殊大的时间。
  

9.3.2. 两种模式

• 1.队列具备两种模式：default 和 lazy。默认的为 default 模式，在 3.6.0 之前的版本无需做任何变动。lazy模式即为惰性队列的模式，可以通过调用 channel.queueDeclare 方法的时间在参数中设置，也可以通过Policy 的方式设置，如果一个队列同时利用这两种方式设置的话，那么 Policy 的方式具备更高的优先级。如果要通过声明的方式改变已有队列的模式的话，那么只能先删除队列，然后再重新声明一个新的。
  
• 2.在队列声明的时间可以通过“x-queue-mode”参数来设置队列的模式，取值为“default”和“lazy”。下面示例中演示了一个惰性队列的声明细节：
  

1. Map<String, Object> args = new HashMap<String, Object>();
2. args.put("x-queue-mode", "lazy");
3. channel.queueDeclare("myqueue", false, false, false, args)

复制代码

---

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。