一流的聊城网站建设广东网站设计品牌设计

说来也奇怪，RocketMQ 不能很好的兼容Springboot3，刚开始上手Springboot3集成RocketMQ会发现总是不能实例化RocketMQTemplate，老是启动时报错。本项目采用Springboot3，JDK21 ，Maven 3.9，提供一个非常简单的示例。

案例就只有这5个类，没有建package。

提前工作

我的RocketMQ服务部署在虚拟机Linux服务器，ip地址是 192.168.218.128，Linux部署RocketMQ比较简单。
运行Springboot3项目之前，需要先把Linux中 mqnamesrv和mqbroker两个服务启动起来。

引入依赖

注意rocketmq-spring-boot-starter版本 2.3.1 不要改动，目前2.3.1版本可以兼容5.3.1，其他版本可能出现注入IOC容器失败。

	 <dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.3.1</version></dependency><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>5.3.1</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>

yaml中添加RocketMQ配置信息

配置类 application.yaml，注意rocketmq标签不是 spring 标签的子标签，二者是并立的。

spring:application:name: rocketmq-demorocketmq:name-server: 192.168.218.128:9876# 必须初始化生产者，才会实例化RocketMQTemplateproducer:group: producer-groupconsumer:group: consumer-group// 配置后端服务端口是8081
server:port: 8081

建立配置类

手动配置RocketMQConfig注入：配置 RocketMQ 消息中间件的相关参数，并通过 Spring 的依赖注入机制将其集成到 Spring Boot 应用程序中。

@Configuration
public class RocketMQConfig {@Value("${rocketmq.name-server}")private String nameServer;@Value("${rocketmq.producer.group}")private String producerGroup;@Beanpublic RocketMQTemplate rocketMQTemplate() {RocketMQTemplate rocketMQTemplate = new RocketMQTemplate();DefaultMQProducer defaultMQProducer = new DefaultMQProducer();defaultMQProducer.setProducerGroup(producerGroup);defaultMQProducer.setNamesrvAddr(nameServer);rocketMQTemplate.setProducer(defaultMQProducer);return rocketMQTemplate;}
}

创建生产者

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** @author 10463*/
@Service
public class RocketMQProducer {@Autowiredprivate RocketMQTemplate rocketMQTemplate;public void sendMessage(String topic, String message) {rocketMQTemplate.convertAndSend(topic, message);}
}

创建消费者

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;/*** @author 10463*/
@Component
@Service
@RocketMQMessageListener(topic = "test-topic", consumerGroup = "consumer-group")
public class RocketMQConsumer implements RocketMQListener<String> {@Overridepublic void onMessage(String message) {System.out.println("消费者收到 message: " + message);}
}

创建控制类

@Controller
public class MessageController {@Autowiredprivate RocketMQProducer rocketMQProducer;@GetMapping("/sendMessage")public String sendMessage(@RequestParam(value = "message", required = true) String message) {System.out.println("进入方法");rocketMQProducer.sendMessage("test-topic", message);return "消息发送成功";}
}

测试

启动Application类，代码如下，我没有添加任何额外注解：

@SpringBootApplication
public class MqServiceApplication {public static void main(String[] args) {SpringApplication.run(MqServiceApplication.class, args);}
}

使用postMan ,执行GET 请求模拟：
http://localhost:8081/sendMessage?message=HelloRocketMQ
没有postman也没关系，直接在网址中复制回车。

如果部署没问题，在控制台会输出

进入方法
消费者收到 message: HelloRocketMQ

该案例没有任何复杂注解和层级关系，部署成功后可以进行后续的复杂RocketMQ学习。