Spring AMQP AsyncRabbitTemplate延迟消息发送失效问题咨询

问题分析 #

使用RabbitTemplate发送延迟消息时延迟效果正常，但切换到AsyncRabbitTemplate后消息立即投递，通常是因为消息属性传递过程中丢失，或使用了自动封装消息的方法导致原有延迟属性被覆盖，另外你代码中还存在变量名不一致的笔误。

解决方案 #

1. 先确认延迟交换机基础配置 #

确保你的延迟交换机是x-delayed-type类型，这是RabbitMQ延迟消息生效的前提：

@Bean
public CustomExchange delayExchange() {
    Map<String, Object> args = new HashMap<>();
    args.put("x-delayed-type", "direct"); // 根据实际路由类型调整，比如topic
    return new CustomExchange("delay-exchange", "x-delayed-message", true, false, args);
}

2. 使用正确的异步发送方法 #

避免使用convertSendAndReceiveAsType这类自动封装消息的方法，直接调用send方法传递预先构建好的带延迟属性的Message对象，确保延迟属性不被覆盖：

// 构建带延迟属性的消息（修正你代码中变量名不一致的问题）
MessageProperties delayedMessageProperties = new MessageProperties();
delayedMessageProperties.setDelay(45000);
byte[] messageBody = objectMapper.writeValueAsString(reversalMessage).getBytes();
Message amqpDelayedMessage = MessageBuilder.withBody(messageBody)
        .andProperties(delayedMessageProperties)
        .build();

// 用AsyncRabbitTemplate的send方法异步发送
ListenableFuture<SendResult> sendResultFuture = asyncRabbitTemplate.send("delay-exchange", "delay-routing-key", amqpDelayedMessage);

// 可选：监听发送结果
sendResultFuture.addCallback(
        result -> System.out.println("延迟消息异步发送成功"),
        ex -> System.err.println("延迟消息异步发送失败：" + ex.getMessage())
);

3. 检查消息转换器是否干扰属性传递 #

如果AsyncRabbitTemplate配置了自定义MessageConverter，确保它不会过滤或修改MessageProperties中的delay属性（setDelay本质是设置x-delay请求头），默认的SimpleMessageConverter不会影响该属性。

4. 修正代码笔误 #

你提供的代码中，构建消息时使用的是reversalMessageProperties，但前面定义的延迟属性对象是delayedMessageProperties，这会导致延迟属性根本没被设置到消息中，这很可能是问题的直接原因！

内容的提问来源于stack exchange，提问作者İlkay Gunel