优先级队列
队列需要设置优先级队列，消息需要设置消息的优先级。消费者需要等待消息已经发送到队列中，然后对队列中的消息进行排序，最后再去消费。
Map arguments = new HashMap<>();
arguments.put("x-max-priority", 10); //设置优先级队列
channel.queueDeclare(QUEUE_NAME, false, false, false, arguments);
for (int i = 1; i < 11; i++){
String message = "info" + i;
if (i == 7) {
//设置消息的优先级
AMQP.BasicProperties properties = new AMQP.BasicProperties().builder().priority(7).build();
channel.basicPublish("",QUEUE_NAME,properties,message.getBytes());
}else {
channel.basicPublish("",QUEUE_NAME,null,message.getBytes());
}
} 生产者先发送消息到队列
由于第7条消息设置了优先级为7，其它消息没有设置优先级，默认优先级最低，所以先消费者优先消费掉优先级高的消息
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
如需转载请保留出处：https://bianchenghao.cn/hz/134341.html