springboot集成rocketMQ消费端设置重试次数java

在Spring Boot中集成RocketMQ消费端，可以通过设置消费者的`maxReconsumeTimes`属性来实现消息消费失败自动重试的功能。具体步骤如下：

1. 在Spring Boot项目中添加RocketMQ依赖：

<dependency>
  <groupId>org.apache.rocketmq</groupId>
  <artifactId>rocketmq-spring-boot-starter</artifactId>
  <version>${rocketmq.version}</version>
</dependency>

2. 创建消费者：

@Component
@RocketMQMessageListener(topic = "test-topic", consumerGroup = "test-group")
public class TestConsumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        // 处理消息
        try {
            // do something
        } catch (Exception e) {
            throw new RuntimeException("消息处理失败，重试", e);
        }
    }
}

3. 在消费者上设置`maxReconsumeTimes`属性，例如：

rocketmq:
  consumer:
    groupName: test-group
    maxReconsumeTimes: 3

上述配置表示消息消费失败最多重试3次。

需要注意的是，每次重试之间会有一定的时间间隔，默认为5秒，可以通过设置`delayLevelWhenNextConsume`属性来调整，例如：

rocketmq:
  consumer:
    groupName: test-group
    maxReconsumeTimes: 3
    delayLevelWhenNextConsume: 2

上述配置表示每次重试之间间隔10秒（delayLevelWhenNextConsume默认值为2）。