我们使用主流的SpringBoot框架整合RocketMQ来讲解，使用方便快捷；
最终项目结构如下：
具体步骤如下：
第一步：新建SpringBoot项目rocketmq-test，引入rocketmq依赖，以及项目配置
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.2.0</version> </dependency>
完整pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVers<mark>来源gaodaimacom搞#^代%!码网</mark>ion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.5.4</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.java1234</groupId>
<artifactId>rocketmq-test</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>rocketmq-test</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.0</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
另外我们项目配置文件需要指定nameserver地址，以及消息生产者和消息消费者组；
所以配置application.yml：
rocketmq:
name-server: 127.0.0.1:9876
producer:
group: producer-demo1
consumer:
group: consumer-demo1
第二步：新建消息生产者Service类ProducerService
package com.java1234.rocketmq;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* 消息生产者
* @author java1234_小锋
* @site www.java1234.com
* @company 南通小锋网络科技有限公司
* @create 2021-08-22 22:16
*/
@Component("producerService")
public class ProducerService {
@Autowired
private RocketMQTemplate rocketMQTemplate;
/**
* 发送简单消息
*/
public void sendMessage(){
for(int i=0;i<1000;i++){
rocketMQTemplate.convertAndSend("java1234-rocketmq","rocketmq大爷，你好！"+i);
}
}
}
SpringBoot给我们提供了RocketMQTemplate模板类，我们利用这个类可以以多种形式发送消息；
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：SpringBoot整合RocketMQ实现消息发送和接收的详细步骤
转载请注明原文链接：SpringBoot整合RocketMQ实现消息发送和接收的详细步骤
