大家好，又见面了，我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。
Jetbrains全系列IDE稳定放心使用
优先级队列
队列需要设置优先级队列，消息需要设置消息的优先级。消费者需要等待消息已经发送到队列中，然后对队列中的消息进行排序，最后再去消费。
Map<String, Object> 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://javaforall.net/190283.html原文链接：https://javaforall.net
