在 Spring Boot 中使用 RocketMQ

在 Spring Boot 中使用 RocketMQ 非常简单，你只需要按照如下步骤进行操作即可。

1. 在 pom.xml 文件中添加 RocketMQ 依赖：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.7.1</version>
</dependency>

2. 在 application.properties 文件中配置 RocketMQ 相关参数，例如：

rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=my-group

3. 创建生产者和消费者，并使用 @EnableRocketMQ 注解开启 RocketMQ 支持。

4. 在生产者中使用 RocketMQTemplate 发送消息，在消费者中使用 @RocketMQMessageListener 注解接收消息。

例如，你可以这样创建一个生产者：

@Component
@EnableRocketMQ
public class MyProducer {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public void sendMessage(String topic, String message) {
        rocketMQTemplate.convertAndSend(topic, message);
    }
}

消费者也是类似的：

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

    @Override
    public void onMessage(String message) {
        // 处理接收到的消息
    }
}

希望这些信息对你有帮助。