使用Spring AMQP向侦听器发送延迟消息

Question

我需要在一定的持续时间后将消息发送给MessageListener，所以有没有任何方法可以使用SpringAMQP实现。

如。Producer生成消息并将消息发送到RabbitMQ Q，该消息立即被侦听器接收到，我想延迟消费者端接收到的消息，比如说在一些配置参数（比如1000ms）之后

Answer 1

如果你使用Spring引导，它可以是这样的：

@Bean
Queue queue() {
    return QueueBuilder.durable(queueName)
            .withArgument("x-dead-letter-exchange", dlx)
            .withArgument("x-dead-letter-routing-key", dlq)
            .build();
}


@Bean
TopicExchange exchange() {
    return (TopicExchange) ExchangeBuilder.topicExchange(topicExchangeName)
            .delayed()
            .build();

@Bean
Binding binding() {
    return BindingBuilder.bind(queue()).to(exchange()).with(queueName);
}

Answer 2

RabbitMQ为此提供了延迟交换功能。

从1.6版开始，Spring AMQP还提供了关于此问题的高级API：http://docs.spring.io/spring-amqp/reference/html/_reference.html#delayed-信息交换：

<rabbit:topic-exchange name="topic" delayed="true" />

MessageProperties properties = new MessageProperties();
properties.setDelay(15000);
template.send(exchange, routingKey,
        MessageBuilder.withBody("foo".getBytes()).andProperties(properties).build());

使现代化

在Spring AMQP1.6之前，您应该这样做：

@Bean
CustomExchange delayExchange() {
    Map<String, Object> args = new HashMap<String, Object>();
    args.put("x-delayed-type", "direct");
    return new CustomExchange("my-exchange", "x-delayed-message", true, false, args);
}

...

MessageProperties properties = new MessageProperties();
properties.setHeader("x-delay", 15000);
template.send(exchange, routingKey,
        MessageBuilder.withBody("foo".getBytes()).andProperties(properties).build());

另请参见此问题及其答案：Spring AMQP RabbitMq中的计划/延迟消息传递