RabbitMQ优先级队列（七）

以你之姓@ 2022-09-02 01:21 204阅读 0赞

优先级队列，顾名思义就是说该队列中的消息有优先级，优先级越高的消息越先被消费。如果当前队列中只有一条消息，那么优先级就没有存在的意义，即消费速度大于生产速度的时候优先级队列就没有存在的价值。

可以通过设置队列的x-max-priority来设置队列的最大优先级（0-255，超过255之后声明队列会报错），然后发送消息的时候通过priority设置消息的优先级，最小优先级为0，最大优先级不能超过队列的最大优先级，否则不生效。

Map<String, Object> map = new HashMap<>();
            map.put("x-max-priority", 255);
            channel.queueDeclare(queueName, true, false, false, map);
            channel.queueBind(queueName,exchangeName,"pri.#");
            AMQP.BasicProperties.Builder builder1 = new AMQP.BasicProperties.Builder();
            builder1.priority(5);
            channel.basicPublish(exchangeName,"pri.message",builder1.build(),"我的优先级5".getBytes());
            AMQP.BasicProperties.Builder builder2 = new AMQP.BasicProperties.Builder();
            builder2.priority(20);
            channel.basicPublish(exchangeName,"pri.message",builder2.build(),"我的优先级20".getBytes());
            AMQP.BasicProperties.Builder builder3 = new AMQP.BasicProperties.Builder();
            builder3.priority(10);
            channel.basicPublish(exchangeName,"pri.message",builder3.build(),"我的优先级10".getBytes());

发表评论取消回复

表情：

评论列表（有 0 条评论，204人围观）

还没有评论，来说两句吧...

相关阅读

相关 RabbitMQ（幂等性、优先级队列、惰性队列）

目录 1、幂等性 1.1 消息重复消费 1.2 消费端的幂等性保障 2、优先级队列 2.1 使用场景 2.2 设置优先级队列（在web页面添加） 2.3 设置优先

小灰灰/ 2023年09月23日 14:19/ 0 赞/ 48 阅读

相关 RabbitMQ学习(二十)：消费者优先级和优先级队列

说明在之前的博文中我对RabbitMQ的一些扩展特性进行了翻译学习，本篇博文我将继续翻译学习RabbitMQ的消费者优先级（Consumer Priorities）和优

刺骨的言语ヽ痛彻心扉/ 2023年06月10日 12:26/ 0 赞/ 8 阅读

相关 pika python rabbitmq 优先级队列、查看队列剩余数目

话不多说，直接上代码。 python3.6 pika 实现rabbitmq 优先级队列 Send import pika import sys

谁践踏了优雅/ 2023年02月11日 03:22/ 0 赞/ 10 阅读

相关 Rabbitmq使用优先级队列实现消息插队

简单示例在消息发送方给队列设置最大优先级，同时给消息设置优先级，优先级大小 0-255 1.消息发送方 import com.rabbitmq.client

亦凉/ 2022年10月19日 00:47/ 0 赞/ 175 阅读

相关 RabbitMQ优先级队列（七）

优先级队列，顾名思义就是说该队列中的消息有优先级，优先级越高的消息越先被消费。如果当前队列中只有一条消息，那么优先级就没有存在的意义，即消费速度大于生产速度的时

以你之姓@/ 2022年09月02日 01:21/ 0 赞/ 205 阅读

相关 RabbitMQ3.5.0版本之后关于RabbitMQ实现队列优先级

RabbitMQ到3.5.0版本实现队列优先级 RabbitMQ到3.5.0版本之前，官方没有实现优先级队列，只实现了Consumer的优先级处理。但是社区已经有相关优

客官°小女子只卖身不卖艺/ 2022年08月20日 13:20/ 0 赞/ 5 阅读

相关优先级队列

前面说过普通队列以及循环队列的使用。关于队列还有一种常用的数据结构：优先级队列。先来看一下下面实际背景：在办公的时候，桌面上会有一堆需要处理的文件。但是事有轻重缓急，

心已赠人/ 2022年07月18日 00:26/ 0 赞/ 263 阅读

相关 RabbitMQ学习笔记 - 优先级队列

参考：<<RabbitMQ实战指南>> 优先级队列，也就是具有高优先级的队列具有高的优先权，优先级高的消息具备优先被消费的特权。注：优先级默认最低为0，最高为队

比眉伴天荒/ 2022年01月21日 11:03/ 0 赞/ 344 阅读

相关 rabbitmq TTL及死信队列,优先级队列

一. TTL 过期时间 1. 消息TTL ttl与网络包跳数超时原理一致，消息在队列中生存的时间超过ttl，就会成为"死信" 消费者无法再接收处理该消息，除非放入死信

逃离我推掉我的手/ 2021年12月24日 08:25/ 0 赞/ 430 阅读

相关 RabbitMQ优先级队列实战

一代码 package com.rabbitmq.priority; import com.rabbitmq.client.AMQP; i

偏执的太偏执、/ 2021年07月24日 14:15/ 0 赞/ 563 阅读