MQ 之 RocketMQ整合进SpringBoot项目

分类：菜鸟笔记作者：qq_41404112

前言

前面已经将RocketMQ的相关知识与应用进行了记录，这一章就来整合SpringBoot，这也是一个重头戏，因为在我们的实际运用中不可能还去向前面那样写代码，我们会用到SpringBoot框架。这一章就详细记录如何整合的吧。

步骤

0、前提

因是整合进SpringBoot，所以，RocketMQ的安装以及Dashboard的安装使用就不再本文赘述，感兴趣的可以看看本人前面写的文章哈。
还有，本文是将生产和消费放在两个module项目中，也是可以在一个项目里测的哈。

1、创建父工程项目

我们使用IDEA创建一个Maven项目，项目名为 rocketmq-test，POM类型。

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.zhangdl</groupId>
    <artifactId>rocketmqtest</artifactId>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>rocketmq-producer</module>
    </modules>

    <packaging>pom</packaging>

    <!--  版本管理  -->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <springboot.version>2.3.2.RELEASE</springboot.version>
        <rocketmq.version>2.2.0</rocketmq.version>
    </properties>

    <!--  依赖管理  -->
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${springboot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.apache.rocketmq</groupId>
                <artifactId>rocketmq-spring-boot-starter</artifactId>
                <version>${rocketmq.version}</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <!--  插件  -->
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

2、创建Producer项目

2.1 修改POM文件

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>rocketmqtest</artifactId>
        <groupId>com.zhangdl</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>rocketmq-producer</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
        </dependency>
    </dependencies>
</project>

2.2 建application.yml文件

rocketmq必须要有name-server和group两个属性。

server:
  port: 8881

rocketmq:
  name-server: 192.168.61.101:9876
  producer:
    group: test-boot-producer

2.3 写主启动类

public class RocketMQProducerApplication {
    public static void main(String[] args) {
        ApplicationContext run = SpringApplication.run(RocketMQProducerApplication.class);
    }
}

2.4 业务类

需要：网页访问localhost:8881/send 进行发送十条消息到RocketMQ。
实际应用中不写原生代码，我们需要借助一个类RocketMQTemplate，通过它能够很方便的进行消息发送。

@RestController
public class ProducerService {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @GetMapping("/send")
    public String send(){
        for (int i = 0; i < 10; i++) {
            rocketMQTemplate.convertAndSend("BootTopic1", "hello~"+i);
        }
        return "SEND_OK";
    }
}

3、创建Consumer项目

3.1 修改POM

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>rocketmqtest</artifactId>
        <groupId>com.zhangdl</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>rocketmq-consumer</artifactId>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
        </dependency>
    </dependencies>
</project>

3.2 application.yml文件

server:
  port: 8886

rocketmq:
  name-server: rocketmq:9876
  consumer:
    group: test-boot-consumer

3.3 主启动类

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

3.4 业务类

@Component
@RocketMQMessageListener(topic = "BootTopic1",consumerGroup = "${rocketmq.consumer.group}")
public class ConsumerService implements RocketMQListener<String> {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;


    @Override
    public void onMessage(String s) {
        System.out.println(s);
    }
}

4、测试

浏览器测试地址：http://localhost:8881/send
页面显示：

在这里插入图片描述


消费者端：打印出接收到的消息，可以看出不是顺序的，这很正常，因为这本就是普通消息不是顺序消息。

在这里插入图片描述

5、扩展

普通消息的三种发送方式：同步发送、异步发送、单向发送。

5.1 同步消息发送

	/**
	 * 同步消息
	 */
	@GetMapping("/syncSend")
	public SendResult syncSend() {
	    String str = "同步消息";
	    SendResult sendMessage = rocketMQTemplate.syncSend("BootTopic1", str);
	    System.out.println("send over");
	    return sendMessage;
	}

测试地址：http://localhost:8881/syncSend

在这里插入图片描述


可以看出，有很多返回结果信息。

5.2 异步消息发送

    /**
     * 异步消息
     */
    @GetMapping("/asyncSend")
    public void asyncSend() {
        String str = "异步消息";
        SendCallback callback = new SendCallback() {
            @Override
            public void onSuccess(SendResult sendResult) {
                System.out.println("success~");
            }

            @Override
            public void onException(Throwable throwable) {
                System.out.println("throw exception~");
            }
        };

测试地址：http://localhost:8881/asyncSend

在这里插入图片描述


生产端成功执行回调方法。

在这里插入图片描述


消费端接收到消息

5.3 单向消息发送

    /**
     * 单向消息
     */
    @GetMapping("/onewaySend")
    public void onewaySend() {
        String str = "单向消息";
        rocketMQTemplate.sendOneWay("BootTopic1", str);
        System.out.println("send over");
    }

消费端接收到消息

在这里插入图片描述

结束语

SpringBoot 整合 RocketMQ 的基础知识就是上述内容，当然，在实际开发时用到的东西是不止这些的，后续，我也会持续更新。

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

java-rocketmqrocketmq

相关推荐

如何学习编程？新手菜鸟如何学编程？
学习编程是顺着互联网的发展潮流，是一件好事。新手如何学习编程？其实不难，不过在学习编程之前你得先了解你的目的是什么？这个很重要，因为目的决定你的发展方向、决定你的发展速度。
it行业都是什么工作？it行业主要做什么？
IT行业是什么工作做什么？IT行业的工作有：产品策划类、页面设计类、前端与移动、开发与测试、营销推广类、数据运营类、运营维护类、游戏相关类等，根据不同的分类下面有细分了不同的岗位。
女生学Java好就业吗？女生适合学Java编程吗？
女生学Java好就业吗？女生适合学Java编程吗？目前有不少女生学习Java开发，但要结合自身的情况，先了解自己适不适合去学习Java，不要盲目的选择不适合自己的Java培训班进行学习。只要肯下功夫钻研，多看、多想、多练
mysql-connect-confused
Can’t connect to local MySQL server through socket \'/var/lib/mysql/mysql.sock问题 1.进入mysql路径
oracle基本命令
oracle基本命令 一、登录操作 1.管理员登录 # 管理员登录 sqlplus / as sysdba 2.普通用户登录
shell判断服务是否启动
一、背景 因为项目中需要通北京网络，所以需要连vpn，但是服务器有时候会断掉，所以写个shell脚本每五分钟去判断是否连接，于是就有下面的shell脚本。
SQL BETWEEN 操作符
BETWEEN 操作符选取介于两个值之间的数据范围内的值。这些值可以是数值、文本或者日期。
​​windows上传ipa到开发者中心app store的方法
假如你已经使用过苹果开发者中心上架app，你肯定知道在苹果开发者中心的web界面，无法直接提交ipa文件，而是需要使用第三方工具，将ipa文件上传到构建版本，开...
SQL 入门篇之什么是别名？
下面的 SQL 语句指定了两个别名，一个是 name 列的别名，一个是 country 列的别名。**提示：**如果列名称包含空格，要求使用双引号或方括号：
windows上传ipa文件到app store的方法​
在使用H5混合开发的app打包后，需要将ipa文件上传到appstore进行发布，就需要去苹果开发者中心进行发布。​
SQL AND & OR 运算符
+----+--------------+---------------------------+-------+---------+
C++ 数组
数组的声明并不是声明一个个单独的变量，比如 number0、number1、...、number99，而是声明一个数组变量，比如 numbers，然后使用 nu...
最全iOS 应用上架流程提交到AppStore
第一步：到appuploader官网下载辅助工具和iCloud驱动，使用前面创建的AppID登录。
SQL ALTER TABLE 语句
如需删除表中的列，请使用下面的语法（请注意，某些数据库系统不允许这种在数据库表中删除列的方式）：
dism操作巨慢
前不久在制作win11pe，制作了一版，1.26GB，太大了，不满意，想再裁剪下，发现这次dism mount正常，commit或discard巨慢，以前都很快...
三种方法卸载Symantec Endpoint Protection 赛门铁克
赛门铁克各个版本概览：https://knowledge.broadcom.com/external/article?legacyId=tech163829
python3.6、python3.10用什么版本的pip
实测Python 3.6.6用pip 21.3.1，再高就报错了，Python 3.10.7用pip 22.3.1是可以的
博通和诺顿
Broadcom Corporation （博通公司，股票代号AVGO）是全球领先的有线和无线通信半导体公司。其产品实现向家庭、 办公室和移动环境以及在这些环境...
高版本c4d在低版本windows系统上打开后不显示窗格
发现个问题，server2016上安装了c4d这些版本，低版本的正常显示窗格，但红色圈出的高版本c4d打开后不显示窗格，
基础网络windows不要使用TAT、如何卸载TAT
TAT：https://cloud.tencent.com/document/product/1340
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot