springboot 整合 rocketmq 完整教程 包括配置

好的，这是你的问题：springboot 整合 rocketmq 完整教程 包括配置。

下面是完整的 Spring Boot 整合 RocketMQ 教程：

1. 添加 Maven 依赖

在 pom.xml 文件中添加以下 Maven 依赖：

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

此外，还需要添加 RocketMQ 的客户端依赖和名称服务器依赖：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>${rocketmq-client-version}</version>
</dependency>
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-namesrv</artifactId>
    <version>${rocketmq-namesrv-version}</version>
</dependency>

2. 添加 RocketMQ 配置

在 application.properties 文件中添加以下配置：

rocketmq.name-server=namesrv地址:端口号
rocketmq.producer.group=生产者分组名
rocketmq.consumer.group=消费者分组名
rocketmq.consumer.topics=消费者订阅的主题

3. 实现生产者

实现一个生产者类，用于发送消息到 RocketMQ：

@Service
public class RocketMQProducer {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

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

4. 实现消费者

实现一个消费者类，用于从 RocketMQ 接收消息：

@Service
@RocketMQMessageListener(topic = "TOPIC_NAME", consumerGroup = "CONSUMER_GROUP")
public class RocketMQConsumer implements RocketMQListener<String> {

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

5. 发送消息

在需要发送消息的地方，例如在 Spring MVC 的控制器中，注入生产者并发送消息：

@Controller
public class MyController {

    @Autowired
    private RocketMQProducer rocketMQProducer;

    @RequestMapping("send")
    @ResponseBody
    public String sendMessage() {
        rocketMQProducer.sendMessage("Hello, RocketMQ!");
        return "发送消息成功！";
    }
}

6. 运行应用程序

现在启动应用程序，就可以在 RocketMQ 中看到生产者发送的消息，并且由消费者处理它们。

这就是一个完整的 Spring Boot 整合 RocketMQ 的方法。希望这对你有所帮助！