Springboot整合RocketMq

Spring Boot整合RocketMQ主要涉及到生产者和消费者的配置。以下是一个简单的例子：

1. 添加依赖到pom.xml：

<dependencies>
    <!-- RocketMQ Spring Boot Starter -->
    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>rocketmq-spring-boot-starter</artifactId>
        <version>2.2.1</version>
    </dependency>
</dependencies>

2. 在application.properties或application.yml中配置RocketMQ参数：

# RocketMQ Config
spring.rocketmq.name-server=127.0.0.1:9876
spring.rocketmq.producer.group=my-group

3. 创建一个消息生产者：

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
public class ProducerController {
 
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
 
    @GetMapping("/sendMessage")
    public String sendMessage() {
        rocketMQTemplate.convertAndSend("topic:test", "Hello, RocketMQ!");
        return "Message sent successfully!";
    }
}

4. 创建一个消息消费者：

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
 
@Component
@RocketMQMessageListener(topic = "topic:test", consumerGroup = "my-consumer_test")
public class Consumer implements RocketMQListener<String> {
 
    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

确保你的RocketMQ服务器正在运行并且配置正确。当你访问/sendMessage端点时，生产者将发送消息到名为topic:test的主题，消费者将监听这个主题并打印接收到的消息。