配置RabbitMQ延时消息

延时消息（Delayed Message）指的是发送后不会立即被消费者接收，而是延迟指定时间后才进入队列供消费者消费的消息。

您可以通过以下任意一种方式实现延时消息。

设置消息延时时间：为每条消息设置不同大小的延时时间，可实现不同消息的差异化延时。 设置消息过期时间和死信队列：消息过期后会自动路由至死信队列。 约束与限制 RabbitMQ 3.x.x版本不支持延时交换机功能，仅AMQP-0-9-1版本支持。

配置延时消息 您可以通过以下任意一种方式实现延时消息。

设置延时交换机：发送至延时交换机的消息默认携带相同的延时时间。 设置消息延时时间：为每条消息设置不同大小的延时时间，可实现不同消息的差异化延时。 设置消息过期时间和死信队列：消息过期后会自动路由至死信队列。 配置延时交换机 设置消息延时时间 设置消息过期时间和死信队列 发送至延时交换机的消息默认携带相同的延时时间。

以下示例演示在Java客户端配置延时交换机：

Map args = new HashMap();

args.put("x-delayed-type", "direct");

channel.exchangeDeclare("exchange", "x-delayed-message", true, false, args); 为每条消息设置不同大小的延时时间，可实现不同消息的差异化延时。

以下示例演示在Java客户端设置消息延时时间：

final HashMap headers = new HashMap<>();

headers.put("x-delay", 10000);

final AMQP.BasicProperties.Builder properties = new AMQP.BasicProperties().builder().headers(headers);

// publish a batch of messages to the main exchange

for (int i = 0; i < messageCount; i++) {

channel.basicPublish(exchangeName, routingKey, properties.build(),

("x-delayed-message-" + i).getBytes());

} 消息过期后会自动路由至死信队列。

以下示例演示在Java客户端设置消息过期时间和死信队列：

channel.queueDeclare("dlq", false, false, false, null);

channel.exchangeDeclare("dlx", BuiltinExchangeType.DIRECT);

channel.queueBind("dlq", "dlx", "rt");

HashMap arguments = new HashMap<>();

arguments.put("x-dead-letter-exchange", "dlx");

arguments.put("x-dead-letter-routing-key", "rt");

arguments.put("x-message-ttl", 5000);

channel.exchangeDeclare("normal", BuiltinExchangeType.DIRECT);

channel.queueDeclare("normal", true, false, false, arguments);

channel.queueBind("normal", "normal", "key");

channel.basicPublish("normal", "key", null, "ttl".getBytes());