RocketMQ

本篇文章是RocketMQ视频笔记的第三章，重点介绍了如何将RocketMQ集成到Spring Boot框架中。通过学习该文章，读者能够掌握如何使用RocketMQ和Spring Boot进行消息传递和处理。

SpringBoot集成RocketMQ 首先依旧是引入依赖 然后就可以编写发送不同类型消息的代码了

MQ 镜像 可视化平台镜像 创建 nameserver 挂载目录 创建 broker 目录 创建 broker 配置文件目录 目录：/home/zibo/docker/rocketmq/data/conf vim broker.conf 启动 nameserver docker run : 这是Docker命令，用于创建和管理Docker容器。 -d : 这是一个选项，指示Docker在后台运行容器。 --restart=always : 这是一个

检查jdk环境 RocketMQ是基于java开发的，安装之前请先查看是否有jdk环境 如果没有请去官网（https://www.oracle.com/java/technologies/downloads/#java8）下载 下载RocketMQ安装包 前往官网（https://rocketmq.apache.org/download）下载，选择二进制文件 在Linux环境中安装 把下载好的文件传入Linux系统中，

参考文档： 官方文档 Topic 与 Tag 都是业务上用来归类的标识，区别在于 Topic 是一级分类，而 Tag 可以理解为是二级分类。使用 Tag 可以实现对 Topic 中的消息进行过滤。 注： Topic：消息主题，通过 Topic 对不同的业务消息进行分类。 Tag：消息标签，用来进一步区分某个 Topic 下

下载RocketMQ         http://rocketmq.apache.org/release_notes/release-notes-4.4.0/ 环境要求         Linux 64位操作系统         64bit JDK 1.8+ 1 上传文件到Linux系统         /usr/local/rocketMQ 2 解压到安装目录         unzip rocketmq-all-4.4.0-bin-release.zip 3 解压后的文件夹名为 rocketmq-4

在 Maven 仓库【https://mvnrepository.com/】中搜索 RocketMQ 依赖： 在 SpringBoot 项目的 Pom.xml 文件中添加对应 MQ 版本的依赖： YAML 配置 在 SpringBoot 项目的 yml 配置文件中添加以下配置： 创建监听器 创建一个 MQMsgListener 类用于监听 RocketMQ 的消息，类上标注注解： @Component 、 @RocketMQMe

       本文解析将 RocketMQ Client 端集成为 spring-boot-starter 框架的开发细节，然后通过一个简单的示例来一步一步的讲解如何使用这个 spring-boot-starter 工具包来配置，发送和消费 RocketMQ 消息。 添加maven依赖： 修改application.properties 注意: 请将上述示例配置中的 127.0.0.1:9876 替换

为了向云原生演进，提高资源利用和弹性能力，RocketMQ在5.0进行了架构的调整与升级，先来看新特性之一，增加了Proxy层。 计算存储分离 计算存储分离是一种分层架构，将计算层与存储层分开。 计算层指的是一些消耗计算资源的功能模块比如协议解析、消费管理等，存储指的

在RocketMQ 5.0以前，有两种集群部署模式，分别为主从模式（Master-Slave模式）和Dledger模式。 主从模式 主从模式中分为Master和Slave两个角色，集群中可以有多个Master节点，一个Master节点可以有多个Slave节点。Master节点负责接收生产者发送的写入请求，将消息写入CommitLog文件，Sl

Docker常用命令大全 RocketMQ 是一个分布式的消息中间件，由 NameServer 和Broker两个角色组成，是一种典型的基于发布/订阅模式的消息通信解决方案。 NameServer 是 RocketMQ 的命名服务，可以理解为类似于 DNS 的服务，它主要负责记录 Topic 的路由信息和 Broker 的地址信息。每个 Rocket

在RocketMQ 5.0之前，消费有两种方式可以从Broker获取消息，分别为Pull模式和Push模式。 Pull模式 ：消费需要不断的从阻塞队列中获取数据，如果没有数据就等待，这个阻塞队列中的数据由消息拉取线程从Broker拉取消息之后加入的，所以Pull模式下消费需要不断主动从Broker拉取消息

22.1.1 创建项目，完整的pom.xml 22.1.2 修改配置文件application.yml 22.1.3 我们在测试类里面测试发送消息 往powernode主题里面发送一个简单的字符串消息 运行后查看控制台 22.1.4 查看rocketMq的控制台 查看消息细节

MQ====Message Queue 官网： http://rocketmq.apache.org/ RocketMQ是阿里巴巴2016年MQ中间件，使用Java语言开发，RocketMQ 是一款开源的 分布式消息系统 ，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。同时，广泛应用于多个领域，包括异步通信解耦、企业解决方

RocketMq系列整体栏目 内容 链接地址 【一】RocketMq安装和基本概念 https://zhenghuisheng.blog.csdn.net/article/details/134486709 【二】RocketMq的架构解析和高性能设计/font https://zhenghuisheng.blog.csdn.net/article/details/134559514 在rocketMq中，其整体架构如下，在RocketMqServer中，主要有NameServer，Broker，