我需要在一定时间后向 MessageListener 发送消息,那么有什么方法可以使用 Spring AMQP 来实现。
例如。 生产者产生消息并将消息发送到 RabbitMQ Q ,消息被接收到监听器立即监听该 Q,我想延迟该消息在消费者端接收,比如在一些配置参数说 1000 毫秒后
最佳答案
RabbitMQ 为此提供了 Delayed Exchange功能。
从 1.6 版开始,Spring AMQP 还提供了一个高级 API:http://docs.spring.io/spring-amqp/reference/html/_reference.html#delayed-message-exchange :
<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 AMQP 1.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());
另请参阅此问题及其答案:Scheduled/Delay messaging in Spring AMQP RabbitMq
关于rabbitmq - 使用 Spring AMQP 延迟消息发送到监听器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40634830/