RocketMQ 学习教程——（二）SpringBoot 集成 RocketMQ

在上一篇教程中，我们简要介绍了 RocketMQ 的概念、特点和基本使用。今天，我们将重点讲解如何在 SpringBoot 项目中集成 RocketMQ，实现消息的发送与接收。以下是详细的步骤和代码示例。
一、添加依赖
在 SpringBoot 项目中集成 RocketMQ，首先需要在项目的 pom.xml 文件中添加 RocketMQ 的相关依赖。具体如下：

<dependencies>
<!-- 其他依赖项... -->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>最新版本</version>
</dependency>
</dependencies>

请确保替换 <version>最新版本</version> 为当前 RocketMQ 的最新版本号。
二、配置 RocketMQ
在 application.properties 或 application.yml 文件中配置 RocketMQ 的相关属性，如生产者和消费者的名称、地址等。以下是一个简单的配置示例：
application.properties 文件内容：

rocketmq.name=your-producer-name
rocketmq.broker-name=your-broker-name
rocketmq.producer.group=your-producer-group
rocketmq.consumer.group=your-consumer-group
rocketmq.consumer.name=your-consumer-name
rocketmq.producer.namesrv-addr=127.0.0.1:9876
rocketmq.consumer.namesrv-addr=127.0.0.1:9876

其中，namesrv-addr 是 RocketMQ 集群的地址，需要根据你的实际环境进行修改。多个地址之间用逗号分隔。
三、编写消息发送代码
在 SpringBoot 项目中，可以通过注入 RocketMQProducer 类来发送消息。以下是一个简单的消息发送示例：

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class MessageService {
@Autowired
private RocketMQTemplate rocketMQTemplate;
public void sendMessage(String topic, String message) {
rocketMQTemplate.convertAndSend(topic, message);
}
}

在上述代码中，我们通过 @Autowired 注解将 RocketMQTemplate 注入到 MessageService 类中，然后使用 convertAndSend 方法发送消息。其中，topic 是消息的主题，message 是要发送的消息内容。
四、编写消息接收代码
在 SpringBoot 项目中，可以通过实现 MessageListener 接口来接收消息。以下是一个简单的消息接收示例：
java import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus; import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently; import org.apache.rocketmq.common.message.MessageExt; import org.springframework.stereotype.Service; @Service public class MessageReceiver implements MessageListenerConcurrently { @Override public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {\ // 处理接收到的消息...}\n}\n在上述代码中，我们实现了 MessageListenerConcurrently 接口，并重写了 consumeMessage 方法来处理接收到的消息。你可以根据实际需求在 consumeMessage 方法中编写处理逻辑。注意，你还需要在配置文件中指定消费者组名和名称服务器地址等属性。
五、启动和测试
启动 SpringBoot 项目后，你可以通过调用 MessageService 类的 sendMessage 方法发送消息，并通过查看日志或控制台输出等来检查消息是否被