如何使用StreamBridge向RabbitMQ发送带优先级的消息

你直接通过MessageBuilder.setHeader("priority", priority)设置的是Spring Messaging层的自定义消息头，Spring Cloud Stream RabbitMQ Binder默认不会将该自定义头映射到RabbitMQ AMQP协议原生的priority消息属性，因此消息到达Broker后优先级始终取默认值0，最终按FIFO规则投递，和你观察到的现象一致。

不需要修改队列配置或Binder全局配置，发送消息时使用Spring AMQP提供的标准AMQP消息头常量设置优先级即可，Binder内置的RabbitHeaderMapper会自动将该头的值映射到RabbitMQ原生消息属性上。
调整后的生产者核心代码如下：

// 引入AMQP头常量类
import org.springframework.amqp.support.AmqpHeaders;

@GET
@Path("test/")
public void test(@Context HttpServletRequest request) {
    System.out.println("inside test");
    try {
        String payload = "hello world";
        logger.info("going to send a message : {}", payload);
        int priority = 5;
        Message<String> message = MessageBuilder.withPayload(payload)
                        // 替换原有的"priority"头为标准AMQP优先级头
                        .setHeader(AmqpHeaders.PRIORITY, priority)
                        .build();
        boolean res = STREAM_BRIDGE.send("testWriter-out-0", message);
        System.out.println(message);
        System.out.println(res);
    } catch (Exception e) {
        logger.error(e);
    }
}

修改后重启服务发送消息，可通过两点确认优先级配置生效：

• 登录RabbitMQ管理GUI查看队列中的消息，Properties区域的priority字段会显示你设置的数值（示例中为5）
• 消费者打印的消息头中会出现amqp_priority=5的键值对，此时消息会严格遵循优先级规则：高优先级消息先被消费，同优先级消息按发送顺序消费

扩展说明：其他RabbitMQ原生消息属性（如持久化模式deliveryMode、消息过期时间expiration等），都可以通过AmqpHeaders类中定义的对应常量设置消息头，Binder会自动完成协议层属性映射，无需额外自定义头映射规则。

内容的提问来源于stack exchange，提问作者amey