RabbitMQ延迟队列过期处理怎么实现的？

RabbitMQ 的延迟队列是一种特殊的消息模式，它允许消息在特定的“延迟”期间不会立即被消费者消费，而是等到设定的时间过后才进入队列。过期处理通常是通过结合两个关键特性实现的：

1. **Dead Letter Exchange (DLX)**：当消息超过预定的延迟时间还未被消费者消费时，RabbitMQ 默认将这些过期消息路由到 Dead Letter Exchange。你可以设置 DLX，使其自动删除过期消息或将其移动到另一个交换机，以便后续的检查或通知。

2. **Expiration Policy**：在创建队列时，可以指定一个 Expiration Policy，比如设置一个消息存活的最大秒数。一旦达到这个时间限制，未被处理的消息会被自动删除。如果想要更复杂的策略，可以自定义一个回调函数（如 `x-message-ttl`），该函数会在消息过期时触发。

在配置中，通常需要设置相应的 Exchange 和 Queue，以及绑定规则（binding），确保过期消息按照预期的行为进行处理。例如：

{
   "exchange": {
      "type": "direct",
      "name": "delayed_queue",
      "arguments": { "x-dead-letter-exchange": "dlx" }
   },
   "queue": {
      "name": "my_delayed_queue",
      "arguments": { "x-message-ttl": 60000, "x-expires": 300000 } // 指定消息存活时间和超时时间
   },
   "binding_keys": [
      "#".concat("delayed_key"), // 使用通配符匹配所有键，然后根据队列策略决定是否过期
      "delayed_key.*" // 可以使用模式匹配，例如处理特定类型的延迟消息
   ]
}