RocketMQ单机环境部署

Dear 丶 2024-03-22 17:27 83阅读 0赞

#### 文章目录 ####

*   *  1. 前置条件
     *  2. 下载源码
     *  3. 编译源码
     *  4. Rocket MQ启动JVM参数配置
     *  5. 启动RocketMQ
     *  6. 安装DashBoard
     *  7. 测试RocketMQ
     *  9. 查看dashboard情况

不太懂RocketMQ基本概念的看我 [这篇博客][Link 1]

### 1. 前置条件 ###

（看我[这篇博客][Link 2]，注意版本要改成3.2.\*，maven的版本）

*  由于RocketMQ需要java环境，所以需要按照JDK：JDK 8+（看我这篇博客）
 *  由于我们需要编译RocketMQ源码，所以需要MAVAN：Maven 3.2.X+

### 2. 下载源码 ###

[官网下载][Link 3]RocketMQ源码，这里我将DashBoard也下载了

创建解压目标文件夹

mkdir /usr/local/rocketMQ

通过FinalShell将源码包上传到虚拟机中（Xshell也可以）  
![在这里插入图片描述][b49c2f5fd17e4163917de8920ce4c515.png]

### 3. 编译源码 ###

进入源码的文件夹

cd rocketmq-all-5.1.0/

编译源码，跳过测试阶段（不跳过可能会报错）

mvn -Prelease-all -DskipTests clean install -U

可以看到我们下载的jar包了  
![在这里插入图片描述][f175837fbb49436db3fcb2ca27bc7b80.png]

### 4. Rocket MQ启动JVM参数配置 ###

由于RocketMQ默认的启动内存是4G，而我们的虚拟机的实际内存可能没这么大，所以需要修改启动参数

*  修改nameserve内存

cd bin
    vim bin/runbroker.sh

![在这里插入图片描述][d8fd78c51fd4467c8e30236c40a54b82.png]

*  修改broker内存

vim runbroker.sh

![在这里插入图片描述][f7efa0ac286c4a1996c6329298dcc86a.png]

### 5. 启动RocketMQ ###

*  先启动nameserver

#创建日志目录
    mkdir logs
    #启动nameserver
    nohup sh bin/mqnamesrv > logs/mqnamesrv.log 2>&1 &

> nohub是后台启动的意思，不用它就是前台启动

*  查看启动日志

tail -f -n 30 logs/mqnamesrv.log

![在这里插入图片描述][31f2e008ed2b4032a90f3db5a7da5fea.png]

*  启动broker

在 conf 目录下，RocketMQ 提供了多种 Broker 的配置文件：  
![在这里插入图片描述][97296b525b2e48a897d3c97d06ce22b4.png]

1.  `broker.conf` ：单主，异步刷盘。
2.  `2m/` ：双主，异步刷盘。
3.  `2m-2s-async/`：两主两从，异步复制，异步刷盘。
4.  `2m-2s-sync/` ：两主两从，同步复制，异步刷盘。
5.  `dledger/` ：Dledger 集群，至少三节点。

这里，我们只启动一个 RocketMQ Broker 服务，所以使用 broker.conf 配置文件。命令行操作如下：

nohup sh bin/mqbroker -n localhost:9876 > logs/broker.log 2>&1 &

*  查看日志

tail -f -n 30 logs/broker.log

![在这里插入图片描述][146e354c6cf748d288f45d6177a0d1ae.png]

*  停止服务

停止`nameserver`

sh bin/mqshutdown namesrv

停止`broker`

sh bin/mqshutdown broker

### 6. 安装DashBoard ###

*  同样到官网下载DashBoard的源码包，放到指定目录下，然后解压

unzip rocketmq-dashboard-1.0.0-source-release.zip

*  进入dashboard的包下

cd rocketmq-dashboard-1.0.0/

包内容如下：  
![在这里插入图片描述][39f49123103343d5b9d1e2583f6d55a9.png]

*  修改配置DashBoard的配置文件，配置nameserver地址和端口（端口jps查看）

![在这里插入图片描述][42d4e2164bad4ee58176d80edc1ca7f4.png]  
（熟悉springboot项目的知道application配置文件在哪里，上面的端口自己要查看，我这里nameserver端口自己设置成了70216）

*  maven对源码包进行编译

由于我们的RocketMQ版本是最新的5.1，而DashBoard是4.9，所以编译的时候会遇到异常，所以

mvn clean package -Dmaven.test.skip=true

> 清理项目生产的临时文件,一般是模块下的target目录。同时执行模块安装命令 将打包的的jar/war文件复制到你的本地仓库中,供其他模块使用 -Dmaven.test.skip=true 跳过测试(同时会跳过test compile)，而-U强制更新

若出现异常使用下面命令

mvn clean install -U -Dmaven.test.skip=true

![在这里插入图片描述][9b22da2ca03a49efba55d8ee51271a0e.png]

target下出现了dashboard打包好的jar包  
![在这里插入图片描述][4f56a2c289a34888bc06d427532c3de6.png]  
最后运行jar包就启动DashBoard了

java -jar rocketmq-dashboard-1.0.0.jar

![在这里插入图片描述][ab9b35d807f84ca380ad9be1700a583b.png]

网页访问DashBoard

![在这里插入图片描述][ed6168a5590e4665b897d4890975330f.png]

### 7. 测试RocketMQ ###

这个文件`bin/tools.sh org.apache.rocketmq.example.quickstart.Producer`模拟了生产者生产消息，下面执行这个文件即可模拟发送消息（在rocketmq文件中）

#"export NAMESRV_ADDR=127.0.0.1:9876" 这个命令用于设置一个名为 "NAMESRV_ADDR" 的环境变量，其值为 "127.0.0.1:9876"。先执行这么命令
    export NAMESRV_ADDR=127.0.0.1:9876
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

![在这里插入图片描述][e5da3d4acd1f460b87050e0fb4202900.png]  
消费者消费消息

# 设置 Namesrv 服务器的地址
    export NAMESRV_ADDR=127.0.0.1:9876
    
    # 执行消费者 Consumer 消费测试消息
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

![在这里插入图片描述][610b2ea3b6824b9bb60b2d64f9d013dd.png]

### 9. 查看dashboard情况 ###

*  查看驾驶舱：驾驶舱消息当前数量和最近的趋势，如图左侧为当前消息总数量，右侧为消息数量趋势。

![在这里插入图片描述][18e8cced3dbc400e92962ee6f48c40ed.png]

> 图1（左上）：按broker实例为类目（比如说集群中有3个broker实例）展示当前的消息数为1000条  
> 图2（左下）：按topic为类目（比如说当前所有broker中存在10个topic）展示当前的消息数

*  查看主题  
    ![在这里插入图片描述][6d12c84265e94cdebe173ba2b3e333ac.png]

> 可以看到消息的Topic都相同，但属于不同的队列中

[Link 1]: https://blog.csdn.net/qq_43456605/article/details/130696901?spm=1001.2014.3001.5501
[Link 2]: https://blog.csdn.net/qq_43456605/article/details/130698145?spm=1001.2014.3001.5502
[Link 3]: https://rocketmq.apache.org/download/
[b49c2f5fd17e4163917de8920ce4c515.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/1fa309acf0104ed7b9bf815fc45f4181.png
[f175837fbb49436db3fcb2ca27bc7b80.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/daa9c86a397e4bfc8829a8d9d906b525.png
[d8fd78c51fd4467c8e30236c40a54b82.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/96012df5be0640a1bc88a1c244ef4995.png
[f7efa0ac286c4a1996c6329298dcc86a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/9c7044ee030143159b0ea8fa9481b01b.png
[31f2e008ed2b4032a90f3db5a7da5fea.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/ff0a0ebeba4b4a099f501cc281c3793a.png
[97296b525b2e48a897d3c97d06ce22b4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/e68b01fd6fb54c72816de4428b0aefc9.png
[146e354c6cf748d288f45d6177a0d1ae.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/4eaefa43d833416e8432ab14a17faeee.png
[39f49123103343d5b9d1e2583f6d55a9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/36ce693d83924bc8b04b27b2f74b0a88.png
[42d4e2164bad4ee58176d80edc1ca7f4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/ae465153385344dfadbca729542573e4.png
[9b22da2ca03a49efba55d8ee51271a0e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/3dea395624574547ad2c1674d61ecac6.png
[4f56a2c289a34888bc06d427532c3de6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/076abf426cd7474e91fa19bc8d009328.png
[ab9b35d807f84ca380ad9be1700a583b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/2952396dbdf14a1ead7a149eec04ce78.png
[ed6168a5590e4665b897d4890975330f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/19671313c9ea46409cc014d9d4bf7570.png
[e5da3d4acd1f460b87050e0fb4202900.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/1311a4a8bd534c5daf482e44c5e1e9d0.png
[610b2ea3b6824b9bb60b2d64f9d013dd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/dcba30cda4894c4cae1075c0c30cf74f.png
[18e8cced3dbc400e92962ee6f48c40ed.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/3a92d58188b8486794eece6023726539.png
[6d12c84265e94cdebe173ba2b3e333ac.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/a51101dafa3c43bdbae7dd87389aed41.png