面试题：RocketMQ 中的死信消息是什么？

在面试中，关于 RocketMQ 中的死信消息问题，可以从以下几个方面进行回答：

1. 死信消息的概念

死信消息（Dead-Letter Message）是指那些无法被消费者正常消费的消息。这些消息通常是因为以下原因被标记为死信：

消费失败次数过多：消息被消费者多次重试后仍然无法成功消费。
消息过期：消息在队列中存活时间超过设定的 TTL（Time-To-Live）。
队列已满：消息无法被存储到队列中。

死信消息会被 RocketMQ 自动转移到死信队列（Dead-Letter Queue, DLQ）中，以便后续处理。

2. 死信队列的作用

死信队列的主要作用包括：

隔离异常消息：将无法正常消费的消息隔离到死信队列，避免影响正常消息的处理。
问题排查：通过分析死信队列中的消息，定位消费失败的原因。
消息恢复：在问题解决后，可以从死信队列中重新消费这些消息。

3. 死信消息的处理流程

3.1 消息消费失败

消费者拉取消息并进行消费。
如果消费失败，消费者会返回 RECONSUME_LATER 状态，触发消息重试。

3.2 消息重试

RocketMQ 会根据重试策略（如重试次数、重试间隔）重新投递消息。
如果消息重试次数达到最大重试次数（默认 16 次），消息会被标记为死信。

3.3 转移到死信队列

被标记为死信的消息会被自动转移到死信队列。
死信队列的命名规则为：%DLQ% + 消费者组名。

4. 死信队列的配置与使用

4.1 配置死信队列

RocketMQ 默认启用死信队列，无需额外配置。如果需要调整死信队列的行为，可以通过以下参数进行配置：

最大重试次数：默认 16 次，可以通过 maxReconsumeTimes 参数调整。
```
  consumer.setMaxReconsumeTimes(10); // 设置最大重试次数为 10
```

重试间隔：可以通过 suspendCurrentQueueTimeMillis 参数调整。

  consumer.setSuspendCurrentQueueTimeMillis(5000); // 设置重试间隔为 5 秒

4.2 消费死信队列

创建一个新的消费者，订阅死信队列。

   DefaultMQPushConsumer dlqConsumer = new DefaultMQPushConsumer("dlq_consumer_group");
   dlqConsumer.subscribe("%DLQ%consumer_group", "*"); // 订阅死信队列

实现消息监听器，处理死信队列中的消息。

   dlqConsumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
       for (MessageExt msg : msgs) {
           System.out.println("Dead-letter message: " + new String(msg.getBody()));
           // 处理死信消息
       }
       return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
   });
   dlqConsumer.start();