延迟队列:简单说就是先级详解发送出去的消息经过给定的时间后,消费者才能看见消息(消费消息)。整合
这里简单说下步骤:
优先级队列是队列队列在RabbitMQ3.5.0之后的版本才支持的。
具有高优先级的队列具有高的优先权,优先级高的消息具备优先被消费的特权。
队列的优先级通过x-max-priority参数设置。
建立一个priority-exchange交换机,类型:direct。
图片
建立一个priority-queue队列,并与priority-exchange绑定。
图片
设置x-max-priority参数的值为100,表示最大优先级为100。
注意:x-max-priority参数的值应该介于1到255。建议使用1到10之间的队列。如果设置的优先级更大将使用更多的Erlang进程消耗更多的CPU资源。运行时调度也会受到影响。
接下来演示优先级队列
我们先只发送消息,然后再把消息的消费功能打开。
发送消息接口:
@GetMapping("/sendPriority")public Object sendPriority(String msg, Integer priority) { ms.sendPriorityQueue(msg, priority) ; return "success" ;}public void sendPriorityQueue(String msg, Integer priority) { logger.info("准备发送消息:{ }", msg); Message message = MessageBuilder.withBody(msg.getBytes()).setPriority(priority).build() ; rabbitTemplate.convertAndSend("priority-exchange", "pe.msg", message) ;}
发送4条消息:
// 第一条消息msg=第一条消息&priority=2 // 第二条消息msg=第二条消息&priority=10// 第三条消息msg=第三条消息&priority=1// 第四条消息msg=第四条消息&priority=7
查看消息队列:
图片
消息消费端:
@RabbitListener(queues = { "priority-queue" })@RabbitHandlerpublic void listenerPriority(Message message, Channel channel) { System.out.println("接受到消息.....income"); byte[] body = message.getBody(); MessageProperties mps = message.getMessageProperties(); String content = new String(body, Charset.forName("UTF-8")); try { System.out.println("接受到消息来自交换机: 【" + mps.getReceivedExchange() + "】, 队列:【" + mps.getConsumerQueue()+ "】:\n内容: " + content); channel.basicAck(message.getMessageProperties().getDeliveryTag(), true); } catch (Exception e) { e.printStackTrace(); try { channel.basicReject(mps.getDeliveryTag(), false); } catch (IOException e1) { e1.printStackTrace() ; } }}
启动服务
图片
根据打印出的结果,正好是我们设置优先级的顺序输出。
上面设置的消息优先级都是在指定的范围<100,如果消息的优先级超过这个值会怎么样呢?
发送8条消息:
// 第一条消息msg=第一条消息&priority=2 // 第二条消息msg=第二条消息&priority=10// 第三条消息msg=第三条消息&priority=1// 第四条消息msg=第四条消息&priority=7// 第五条消息msg=第五条消息&priority=101
消费消息:
图片
同样是按照顺序输出的。
(责任编辑:探索)
ST地矿(000409.SZ)公布消息:2021年度累计购买理财产品不超5亿元
山东重工:潍柴动力荣获“中国百强企业奖”和“中国明星企业奖”
上985大学有多难?看看高考大省2019年的招生人数及位次你就明白了
北京汽车(01958.HK)年度净利跌59.4% 每股收益为人民币0.24元
多部门已“出实招”为企业“护航” 降低汇率波动扰动增加融资渠道