springcloud 整合 rocketmq

Spring Cloud整合RocketMQ可以通过使用RocketMQ的Spring Boot Starter来实现。具体步骤如下：

1. 在pom.xml中添加RocketMQ的Spring Boot Starter依赖：

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

2. 配置RocketMQ的相关属性，例如NameServer地址、Producer和Consumer的Group等：

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

3. 创建RocketMQ的Producer和Consumer，并使用RocketMQTemplate发送和接收消息：

@Autowired
private RocketMQTemplate rocketMQTemplate;

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

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