rocketmq整合springboot

RocketMQ和Spring Boot的整合可以通过使用RocketMQ的Spring Boot Starter来实现。下面是整合的步骤：

1. 引入RocketMQ的Spring Boot Starter依赖。在你的Spring Boot项目的`pom.xml`文件中添加以下依赖：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.1.1</version>
</dependency>

2. 配置RocketMQ的相关属性。可以在`application.properties`（或者`application.yml`）文件中配置RocketMQ的相关属性，例如：

# NameServer的地址，多个地址使用逗号分隔
rocketmq.name-server=127.0.0.1:9876
# 消费者组名
rocketmq.consumer.group=my-consumer-group
# 生产者组名
rocketmq.producer.group=my-producer-group

3. 创建RocketMQ的生产者。使用`@EnableRocketMQ`注解开启RocketMQ支持，并创建一个生产者实例。例如：

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MyProducer {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

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

4. 创建RocketMQ的消费者。使用`@RocketMQMessageListener`注解创建一个消费者实例，并指定要监听的主题和消费逻辑。例如：

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

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

    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
        // 处理消息的业务逻辑
    }
}

5. 使用RocketMQ的生产者发送消息。在需要发送消息的地方注入生产者实例，并调用`sendMessage`方法发送消息。例如：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyC