Rabbitmq 消息延迟消费、延迟重试

延迟消费过程（每个消息可以单独设置失效时间）：

• 1. 声明 delay_queue_per_message_ttl 队列：死信队列，设置 DLX 参数，包含 x-dead-letter-exchange 表示失效后进入的 exchange（值为 delay_exchange，即实际消费交换机）、x-dead-letter-routing-key 表示失效后的路由键（值为 delay_process_queue，即实际消费队列）。
• 2. 声明 delay_process_queue 队列：实际消费队列。
• 3. 声明 delay_exchange 交换机：实际消费交换机，类型为 Direct（一一对应）。
• 4. 声明 dlx_binding 绑定：将实际消费队列和实际消费交换机绑定（路由键规则值为 delay_process_queue）。
• 5. 发布一个消息，路由键为 delay_queue_per_message_ttl（发送到死信队列），并通过 header 单独设置每个消息的过期时间：当过期时间生效后，消息会转到实际消费队列。
• 6. 声明一个消费者，监听 delay_process_queue 队列（即实际消费队列）：消息正常被消费掉，达到延迟消费的目的。

延迟消费过程（所有消息统一设置失效时间）：

• 1. 声明 delay_queue_per_queue_ttl 队列：死信队列，设置 DLX 参数，包含 x-dead-letter-exchange 表示失效后进入的 exchange（值为 delay_exchange，即实际消费交换机）、x-dead-letter-routing-key 表示失效后的路由键（值为 delay_process_queue，即实际消费队列）、x-message-ttl 表示队列消息过期时间。
• 2. 声明 delay_process_queue 队列：实际消费队列。
• 3. 声明 delay_exchange 交换机：实际消费交换机，类型为 Direct（一一对应）。
• 4. 声明 dlx_binding 绑定：将实际消费队列和实际消费交换机绑定（路由键规则值为 delay_process_queue）。
• 5. 发布一个消息，路由键为 delay_queue_per_queue_ttl（发送到死信队列）：当过期时间生效后，消息会转到实际消费队列。
• 6. 声明一个消费者，监听 delay_process_queue队列（即实际消费队列）：消息正常被消费掉，达到延迟消费的目的。

延迟重试过程：

• 1. 声明 delay_process_queue 队列：实际消费队列。
• 2. 声明 delay_queue_per_queue_ttl 队列：死信队列，设置 DLX 参数，包含 x-dead-letter-exchange 表示失效后进入的 exchange（值为 delay_exchange，即实际消费交换机）、x-dead-letter-routing-key 表示失效后的路由键（值为 delay_process_queue，即实际消费队列）、x-message-ttl 表示队列消息过期时间。
• 3. 声明 delay_exchange 交换机：实际消费交换机，类型为 Direct（一一对应）。
• 4. 声明 per_queue_ttl_exchange 交换机：死信交换机，类型为 Direct（一一对应）。
• 5. 声明 dlx_binding 绑定：将实际消费队列和实际消费交换机绑定（路由键规则值为 delay_process_queue）。
• 6. 声明 queue_ttl_binding 绑定：将死信队列和死信交换机绑定（路由键规则值为 delay_queue_per_queue_ttl）。
• 7. 发布一个消息，路由键为 delay_process_queue（发送到实际消费队列）。
• 8. 声明一个消费者，监听 delay_process_queue 队列（即实际消费队列）：消费者监听到消息，当处理过程中发生异常，消息重新发送到私信队列，然后等待过期时间生效后，消息再转到实际消费队列，重新消费，以达到延迟重试的目的。

需要注意：在延迟消费的过程中，我们是没有创建死信交换机的，那为什么还可以发布消息呢？原因是 RabbitMQ 会使用默认的 Exchange，并且创建一个默认的 Binding（类型为 Direct），通过rabbitmqadmin list bindings命令，可以看到结果。