spring boot集成rocket mq

Spring Boot集成RocketMQ可以使用官方提供的RocketMQ Spring Boot Starter，该Starter提供了RocketMQ的自动配置，使得我们可以非常方便地在Spring中使用RocketMQ。

以下是基于RocketMQ Spring Boot Starter的示例代码：

首先，在pom.xml文件中添加以下依赖：

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

然后，在application.yml文件中添加RocketMQ的配置：

rocketmq:
  name-server: localhost:9876
  producer:
    group: my-group
  consumer:
    group: my-group

其中，name-server是RocketMQ的Name Server地址，producer和consumer分别是生产者和消费者的配置。

接下来，创建生产者：

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 send(String message) {
        rocketMQTemplate.convertAndSend("my-topic", message);
    }
}

在MyProducer中，通过RocketMQTemplate来发送消息，convertAndSend方法中的第一个参数是消息的主题，第二个参数是消息内容。

最后，创建消费者：

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-group")
public class MyConsumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在MyConsumer中，通过@RocketMQMessageListener注解来指定消费者的主题和消费者组，在onMessage方法中处理收到的消息。

至此，我们就完成了Spring Boot集成RocketMQ的示例代码。