springboot集成rocketmq

Spring Boot是一个快速开发框架，可以帮助开发者快速构建应用程序。RocketMQ是一个高性能、可靠的分布式消息队列，用于大规模数据传输和数据处理。本文介绍如何在Spring Boot中集成RocketMQ。

1. 添加依赖

首先，在pom.xml文件中添加RocketMQ的依赖：

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

2. 配置RocketMQ

在application.properties文件中添加RocketMQ的配置：

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

其中，name-server是RocketMQ的名称服务器地址，producer.group和consumer.group是生产者和消费者的分组名称。

3. 编写生产者

创建一个RocketMQ生产者，发送消息到指定的主题：

@RestController
public class ProducerController {
 
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
 
    @GetMapping("/send")
    public String sendMsg() {
        rocketMQTemplate.convertAndSend("my-topic", "Hello RocketMQ!");
        return "Message sent successfully!";
    }
}

4. 编写消费者

创建一个RocketMQ消费者，从指定的主题消费消息：

@Component
@RocketMQMessageListener(topic = "my-topic", consumerGroup = "my-group")
public class Consumer implements RocketMQListener<String> {
 
    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

5. 运行程序

启动Spring Boot应用程序，访问/send接口发送消息，可以在控制台中看到消费者接收到的消息。

至此，Spring Boot集成RocketMQ完成。