RocketMQ 及 Rocket-console 安装

向右看齐 2022-11-28 00:42 180阅读 0赞

**Table of Contents**

1.jdk环境搭建

2.安装

3. 配置环境变量

4. 优化内存

5. 启动

6.关闭命令

7.管理界面

8.问题补充

--------------------

## 1.jdk环境搭建 ##

[java环境][java]，已搭建请忽略

## 2.安装 ##

下载：[https://mirror.bit.edu.cn/apache/rocketmq][https_mirror.bit.edu.cn_apache_rocketmq]

下载：
    wget https://mirror.bit.edu.cn/apache/rocketmq/4.7.1//rocketmq-all-4.7.1-bin-release.zip
    解压：
    unzip rocketmq-all-4.7.1-bin-release.zip

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70][]

## 3. 配置环境变量 ##

为了在任意位置都可以执行rocketmq的操作命令，可以配置环境变量

![20200816171458214.png][]

export ROCKETMQ_HOME=/usr/local/rocketmq/rocketmq-all-4.7.1-bin-release
    
    
    PATH 追加 $ROCKETMQ_HOME/bin

修改完后, 让环境变量立即生效

source /etc/profile

## 4. 优化内存 ##

**rocketmq 需要启动两个服务: name `server` 和 `broker`**

`name server `默认配置JVM使用的内存是4g

`broker `默认配置JVM使用的内存是8g

![20200816160820862.png][]

![20200816161243878.png][]

都修改为：-server -Xms256m -Xmx256m -Xmn128m

## 5. 启动 ##

先启动 `name server`

nohup sh mqnamesrv &

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 1][]

启动 `broker`

nohup sh mqbroker -n localhost:9876 &

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 2][]

# 通过环境变量, 告诉客户端程序name server的地址
    export NAMESRV_ADDR=localhost:9876
    
    # 启动生产者来测试发送消息
    sh tools.sh org.apache.rocketmq.example.quickstart.Producer
    
    # 启动消费者来测试接收消息
    sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

## 6.关闭命令 ##

#关闭 broker
    mqshutdown broker
    
    #关闭 name server
    mqshutdown namesrv

![20200816192456860.png][]

## 7.管理界面 ##

`rocketmq-externals` 中提供了rocketmq 的管理界面  **rocketmq-console **，地址为：

github:  [https://github.com/apache/rocketmq-externals][https_github.com_apache_rocketmq-externals]

gitee:  [https://gitee.com/mirrors/RocketMQ-Externals][https_gitee.com_mirrors_RocketMQ-Externals]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 3][]

拉取项目，mvn 打包即可

#clone项目
    git clone https://gitee.com/mirrors/RocketMQ-Externals
    
    #
    cd RocketMQ-Externals/rocketmq-console
    
    # 打包
    mvn clean package -Dmaven.test.skip=true

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 4][]

启动

nohup java -jar rocketmq-console-ng-2.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=localhost:9876 &

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 5][]

注意：防火墙问题

#
    systemctl status firewalld
    
    # 关闭防火墙
    systemctl stop firewalld.service
    
    # 禁止防火墙开机启动
    systemctl disable firewalld.service

**访问**：[http://192.168.71.128:8080][http_192.168.71.128_8080]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 6][]

## 8.问题补充 ##

报错：emotingTooMuchRequestException: sendDefaultImpl call timeout

原因：由于项目配置 name-server: 192.168.71.128:9876 ，而rocket-console 里面 cluster 的ip为：172.17.0.1（虚拟机内网ip）导致

解决：增加文件 broker.properties，配置服务器（虚拟机）ip

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 7][]

![20200817001856505.png][]

brokerIP1=192.168.71.128

启动broker

nohup sh mqbroker -n 192.168.71.128:9876 -c ../conf/broker.propertie

![20200817002115645.png][]

[java]: https://blog.csdn.net/weixin_42032199/article/details/107955192
[https_mirror.bit.edu.cn_apache_rocketmq]: https://mirror.bit.edu.cn/apache/rocketmq/4.7.1/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70]: /images/20221124/b5bcd57fff074ad880b3f37b10a9c082.png
[20200816171458214.png]: /images/20221124/31678c1718334ae0810e5cd0559c44dc.png
[20200816160820862.png]: /images/20221124/553c90f419094bc98483b5a003677d4c.png
[20200816161243878.png]: /images/20221124/192fd2b4e54f4284ac65d11e001a469b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 1]: /images/20221124/aaacc2e501f54cfead3f8201b0264095.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 2]: /images/20221124/49d13bce32ca4e4fb9bb63a642ace549.png
[20200816192456860.png]: /images/20221124/b0068fc6bd1a4988804a31d3d0cf4d0d.png
[https_github.com_apache_rocketmq-externals]: https://github.com/apache/rocketmq-externals
[https_gitee.com_mirrors_RocketMQ-Externals]: https://gitee.com/mirrors/RocketMQ-Externals
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 3]: /images/20221124/4471aeeccd50485c980790941c00b9b0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 4]: /images/20221124/4e876987e8ce488da4d10dc0d5052084.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 5]: /images/20221124/a10ec27455c8419d82ef3c5ae53e5101.png
[http_192.168.71.128_8080]: http://192.168.71.128:8080/#/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 6]: /images/20221124/ff08ba4e9aa04a4c993f555f7badb51a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 7]: /images/20221124/a96f69bc40f64f75b9ed4a4b6e90955c.png
[20200817001856505.png]: /images/20221124/eb2261d7c1ea41cca45d1d3dc57a5e1b.png
[20200817002115645.png]: /images/20221124/decc6e637f9541f7a2cf6ef0e447b725.png