面试题：RabbitMQ 怎么实现延迟队列？

1. 使用 RabbitMQ 官方插件 rabbitmq_delayed_message_exchange

这是最直接的方式。RabbitMQ 提供了一个官方插件 rabbitmq_delayed_message_exchange，它允许你创建一个延迟交换机，消息可以在指定的延迟时间后再被路由到队列。

步骤：

1. 安装插件：首先需要安装 rabbitmq_delayed_message_exchange 插件。

   rabbitmq-plugins enable rabbitmq_delayed_message_exchange

2. 声明延迟交换机：在代码中声明一个延迟交换机，类型为 x-delayed-message。

   Map<String, Object> args = new HashMap<>();
   args.put("x-delayed-type", "direct");
   channel.exchangeDeclare("delayed_exchange", "x-delayed-message", true, false, args);

3. 发送延迟消息：发送消息时，设置 x-delay 头来指定延迟时间（毫秒）。

   AMQP.BasicProperties.Builder props = new AMQP.BasicProperties.Builder();
   props.headers(new HashMap<>()).header("x-delay", 5000); // 延迟5秒
   channel.basicPublish("delayed_exchange", "routing_key", props.build(), message.getBytes());

2. 使用 TTL + 死信队列（DLX）

如果没有安装插件，可以通过 TTL（Time-To-Live）和死信队列（DLX）来实现延迟队列。

步骤：

1. 创建死信交换机和队列：首先创建一个死信交换机（DLX）和一个死信队列（DLQ）。

   channel.exchangeDeclare("dlx_exchange", "direct");
   channel.queueDeclare("dlx_queue", true, false, false, null);
   channel.queueBind("dlx_queue", "dlx_exchange", "dlx_routing_key");

2. 创建主队列并设置 TTL 和 DLX：创建一个主队列，并设置消息的 TTL 和死信交换机。

   Map<String, Object> args = new HashMap<>();
   args.put("x-message-ttl", 5000); // 消息5秒后过期
   args.put("x-dead-letter-exchange", "dlx_exchange");
   args.put("x-dead-letter-routing-key", "dlx_routing_key");
   channel.queueDeclare("main_queue", true, false, false, args);

3. 发送消息到主队列：发送消息到主队列，消息会在 TTL 过期后被转发到死信队列。

   channel.basicPublish("", "main_queue", null, message.getBytes());

4. 消费死信队列：消费者从死信队列中消费消息，实现延迟效果。

3. 使用外部调度器

如果不想依赖 RabbitMQ 的特性，可以使用外部调度器（如 Redis、数据库等）来实现延迟队列。外部调度器在指定的延迟时间后将消息推送到 RabbitMQ 队列中。

步骤：

1. 外部调度器：使用 Redis 或数据库等工具来存储消息和延迟时间。
2. 定时任务：通过定时任务检查是否有消息到达延迟时间，如果有，则将消息推送到 RabbitMQ 队列中。
3. 消费消息：消费者从 RabbitMQ 队列中消费消息。

总结

• 插件方式：最简单直接，推荐使用 rabbitmq_delayed_message_exchange 插件。
• TTL + DLX：无需插件，但配置稍复杂。
• 外部调度器：灵活性高，但增加了系统复杂性。