问java 如何通过注解消费 TDMQ RocketMQ ？

在 Java 中，使用注解消费 TDMQ RocketMQ 的方法如下：

1. 首先，确保已经在项目中引入了 TDMQ RocketMQ 的依赖。

2. 在需要消费消息的类中，使用 `@RocketMQMessageListener` 注解，并指定 `topic` 和 `consumerGroup`。

```java

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;

import org.apache.rocketmq.spring.core.RocketMQListener;

import org.springframework.stereotype.Component;

@Component

@RocketMQMessageListener(topic = "${tdmq.topic}", consumerGroup = "${tdmq.consumerGroup}")

public class MyMessageListener implements RocketMQListener<String> {

@Override

public void onMessage(String message) {

System.out.println("Received message: " + message);

}

}

```

3. 在 `application.properties` 或 `application.yml` 中配置 TDMQ RocketMQ 的相关信息。

```properties

# application.properties

tdmq.topic=your_topic_name

tdmq.consumerGroup=your_consumer_group_name

```

或

```yaml

# application.yml

tdmq:

topic: your_topic_name

consumerGroup: your_consumer_group_name

```

4. 如果有多个 topic 需要消费，可以创建多个消费者类，分别指定不同的 `topic` 和 `consumerGroup`。

```java

@Component

@RocketMQMessageListener(topic = "${tdmq.topic1}", consumerGroup = "${tdmq.consumerGroup1}")

public class MyMessageListener1 implements RocketMQListener<String> {

// ...

}

@Component

@RocketMQMessageListener(topic = "${tdmq.topic2}", consumerGroup = "${tdmq.consumerGroup2}")

public class MyMessageListener2 implements RocketMQListener<String> {

// ...

}

```

5. 在 `application.properties` 或 `application.yml` 中配置多个 topic 和 consumerGroup 的相关信息。

```properties

# application.properties

tdmq.topic1=your_topic_name1

tdmq.consumerGroup1=your_consumer_group_name1

tdmq.topic2=your_topic_name2

tdmq.consumerGroup2=your_consumer_group_name2

```

或

```yaml

# application.yml

tdmq:

topic1: your_topic_name1

consumerGroup1: your_consumer_group_name1

topic2: your_topic_name2

consumerGroup2: your_consumer_group_name2

```

这样，你就可以使用注解的方式消费 TDMQ RocketMQ 的多个 topic 了。

---混元大模型