MQ 之间的对比

三种常用的 MQ 对比，ActiveMQ、Kafka、RocketMQ

性能方面：

• 三种 MQ 吞吐量级别为：万，百万，十万
• 消息发送时延：毫秒，毫秒，微秒
• 可用性：主从，分布式，分布式

扩展性方面：

• 水平伸缩能力：均支持
• 技术栈：Java，Java/Scala，Java

功能维度方面：

• 消息重试能力：均支持
• 消息堆积能力：跟吞吐量成正相关，三种 MQ 分别为：弱，强，强
• 消息过滤：支持，不支持，支持
• 延迟消息：均支持
• 消息回溯（用于消费者宕机恢复后，回溯到宕机前消费的位置）：不支持，支持，支持

RocketMQ 领域模型

• Topic：主题，可以理解为类别、分类的概念

• MessageQueue：消息队列，存储数据的一个容器（队列索引数据），默认每个 Topic 下有 4 个队列被分配出来存储消息

• Message：消息，真正携带信息的载体概念

• Producer：生产者，负责发送消息

• Consumer：消费者，负责消费消息

• ConsumerGroup：众多消费者构成的整体或构成的集群，称之为消费者组

• Subscription：订阅关系，消费者得知道自己需要消费哪个 Topic 下的哪个队列的数据

• Message Queue：一个 Topic 下可以设置多个消息队列，发送消息的时候，RocketMQ 会轮询该 Topic 下的所有队列将消息发送出去（下图中 Broker 中 Topic 指向的 Q1、Q2、Q3、Q4 就是 MessageQueue）

• Tag：对 Topic 的进一步细化

• Broker：Broker 是 Rocket MQ 的主要角色，主要管理消息的存储、发送、查询等功能

• Name Server：提供轻量级的服务发现，用于存储 Topic 和 Broker 关系信息

  主要功能：

  1. 接收 Broker 的注册，并提供心跳机制去检查 Broker 是否存活
  2. 路由管理，每个 nameserver 都有整个 Broker 集群的路由信息和客户端的查询队列

Rocket MQ 单机服务启动

RocketMQ 官方下载地址：https://rocketmq.apache.org/zh/download/

单机服务启动，选择二进制文件进行下载：

将二进制文件上传至服务器，进行解压：

# 安装 unzip 命令
yum install unzip
# 解压
unzip rocketmq-all-5.1.4-bin-release.zip

修改 RocketMQ 的 JVM 配置

原本分配的 JVM 堆内存太大，如果启动时分配的内存不足就会报错，需要修改 bin 目录下的：runbroker.sh 和 runserver.sh 文件：

runbroker.sh 文件修改后的内容如下图：

runserver.sh 文件修改后的内容如下图：

配置 broker.conf 文件

在 conf/broker.conf 文件中追加如下内容：

brokerIP1=【填服务器的公网 ip 地址】
namesrvAddr=localhost:9876

linux 安装 jdk 环境

rocketmq 是 java 写的，因此还需要安装 jdk 环境，并且有 JAVA_HOME 环境变量

安装 jdk 流程如下：

# 创建目录
mkdir /usr/lib/jvm
# 解压到 /usr/lib/jvm 目录下
tar -xvf jdk-8u144-linux-x64.tar.gz -C /usr/lib/jvm
# 配置环境变量，Linux 环境变量在 /etc/profile 中配置
vi /etc/profile
# 在结尾添加如下内容
export JAVA_HOME=/usr/lib/jvm/jdk1.8.0_144
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar# 激活修改的配置
source /etc/profile
# 检查安装的 jdk
java -version

启动

# 1.启动 nameserver， nohup 和 & 可以让程序在后台运行
nohup sh bin/mqnamesrv &
# 查看日志，判断是否启动成功
tail ‐f ~/logs/rocketmqlogs/namesrv.log
# 2023-12-15 15:17:10 INFO main - The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876
# 2.启动 broker，-n 是 nameserver 的地址
nohup sh bin/mqbroker -c conf/broker.conf ‐n localhost:9876 &
# 查看日志，判断是否启动成功
tail ‐f ~/logs/rocketmqlogs/broker.log
# 2023-12-15 15:17:56 INFO main - The broker[broker-a, 218.95.37.160:10911] boot success. serializeType=JSON and name server is localhost:9876

启动后，使用 jps 查看是否启动成功：

关闭命令

sh bin/mqshutdown broker
sh bin/mqshutdown namesrv