如何实现spring boot rocketmq-client接入的具体操作步骤-CFANZ编程社区

Spring Boot与RocketMQ集成指南

引言

RocketMQ是一款高性能、高吞吐量的分布式消息中间件，被广泛应用于各种场景下的异步消息传递。Spring Boot是一款用于简化Spring应用开发的框架，它提供了一种快速构建应用的方式。本文将介绍如何使用Spring Boot集成RocketMQ，实现应用与消息中间件之间的交互。

准备工作

在开始之前，我们需要确保以下准备工作已经完成：

安装RocketMQ并启动RocketMQ服务。
创建一个Spring Boot项目。

添加依赖

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

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

配置RocketMQ

在application.properties文件中，我们需要配置RocketMQ的相关信息：

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

创建消息生产者

接下来，我们需要创建一个消息生产者。在Spring Boot中，我们可以使用RocketMQTemplate来发送消息。我们可以通过注入RocketMQTemplate来实现消息的发送。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.apache.rocketmq.spring.core.RocketMQTemplate;

@Component
public class MessageProducer {
    
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

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

}

创建消息消费者

除了消息生产者，我们还需要创建一个消息消费者。在Spring Boot中，我们可以使用@RocketMQMessageListener注解来实现消息的消费。

import org.springframework.stereotype.Component;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;

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

}

测试消息发送与消费

为了测试消息发送与消费的过程，我们可以在一个Controller中添加如下代码：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MessageController {
    
    @Autowired
    private MessageProducer messageProducer;
    
    @GetMapping("/send")
    public String sendMessage() {
        messageProducer.sendMessage("my-topic", "Hello, RocketMQ!");
        return "Message sent!";
    }
    
}

启动Spring Boot应用后，访问/send接口，即可发送一条消息到RocketMQ，并在控制台中打印出接收到的消息。