【RocketMQ】基本使用：安装、使用、可视控制台（阿里云搭建踩坑记录）

桃扇骨 2022-12-22 06:26 271阅读 0赞

## 1.安装 ##

1).下载安装包

下载地址：[http://rocketmq.apache.org/dowloading/releases/][http_rocketmq.apache.org_dowloading_releases]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center]

2). 解压

unzip rocketmq-all-4.5.0-bin-release.zip

## 2.使用 ##

**1). 启动 nameserver**

默认情况下，nameserver监听的是9876端口

nohup sh namesrv & 
    
    # 若在云服务器，那么启动时要-n加上公网IP
    nohup sh namesrv -n 39.105.136.112:9876 &

两点注意：

*  日志在用户目录下（root/logs），查看启动日志`tail -f ~/logs/rocketmqlogs/namesrv.log`

![在这里插入图片描述][20201118134459839.png_pic_center]

*  若启动时内存不足，需要修改JVM相关配置 `vim runserver.sh`，修改原来的4g为1g  
    ![在这里插入图片描述][20201118141453160.png_pic_center]
    
    >  *  Xms 是指设定程序启动时占用内存大小。一般来讲，大点，程序会启动的快一点，但是也可能会导致机器暂时 间变慢。
    >  *  Xmx 是指设定程序运行期间最大可占用的内存大小。如果程序运行需要占用更多的内存，超出了这个设置值， 就会抛出OutOfMemory异常。
    >  *  xmn 年轻代的heap大小，一般设置为Xmx的3、4分之一

**2). 启动broker**

默认情况下，broker监听的是10911端口

nohup sh mqbroker -n localhost:9876 &
    
    # 若在云服务器还需加上： -n 公网IP -c 配置文件 auto..=true
    nohup sh mqbroker -n 39.105.136.112:9876 -c ../conf/broker.conf autoCreateTopicEnable=true &

特别注意以下两点：

*  若是云服务器，需要将公网IP配置进broker.conf，`brokerIP=公网IP`
    
    ![在这里插入图片描述][20201118141728485.png_pic_center]
 *  `tail -f ~/logs/rocketmqlogs/broker.log` 查看日志，如果提示找不到文件，则打开当前目录下的 nohup.out 日志文件查看，出现如下日志表示启动失败，提示内存无法分配。修改所需内存`vim runbroker.sh`，修改8g为512m

![在这里插入图片描述][20201118144033681.png_pic_center]

**3). 停止服务**

sh mqshutdown broker
    sh mqshutdown namesrv

## 3.broker.conf文件分析 ##

默认情况下，启动broker会加载conf/broker.conf文件，这个文件里面就是一些常规的配置信息

![在这里插入图片描述][20201118145726180.png_pic_center]

*  brokerClusterName：Cluster名称，如果集群机器数比较多，可以分成多个cluster，每个cluster提供 给不同的业务场景使用
 *  brokerName：broker名称，如果配置主从模式，master和slave需要配置相同的名称来表名关系
 *  brokerId=0：在主从模式中，一个master broker可以有多个slave，0表示master，大于0表示不同 slave的id
 *  brokerRole=SYNC\_MASTER/ASYNC\_MASTER/SLAVE：表示slave和master消息同步完成后再返回信息给客户端
 *  autoCreateTopicEnable = true：topic不存在的情况下自动创建

## 4.可视控制台 ##

rocket官方提供了一个可视化控制台，地址：[https://github.com/apache/rocketmq-externals][https_github.com_apache_rocketmq-externals]。这个是rocketmq的扩展，里面不仅包含控制台的扩展，也包含对大数据ﬂume、hbase等组件的对接和扩展。

![在这里插入图片描述][20201118145825185.png_pic_center]

**1.安装**

1). 下载源码包并解压

注：其实对于rocketmq而言，直接用git clone只下载rocketmq-console也行

2). 修改rocketmq-console项目中的application.properties 的`namesrvAddr`属性

![在这里插入图片描述][20201118145839226.png_pic_center]

3). 在rocketmq-console目录下打开命令行，启动springboot项目`mvn spring-boot:run`

注：若命令行关闭，服务就停了

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center 1]

**2.使用**

在浏览器8080端口进行访问

1.  首页：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center 2]

1.  topic：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center 3]

1.  Consumer：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center 4]

[http_rocketmq.apache.org_dowloading_releases]: http://rocketmq.apache.org/dowloading/releases/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/be4c83d8db9644789c84677a41e5f5d8.png
[20201118134459839.png_pic_center]: /images/20221120/566c3f12c5fe41008705c1e27ec6aa72.png
[20201118141453160.png_pic_center]: /images/20221120/e64b9adc9b8f46b0b8096c4e28f3f415.png
[20201118141728485.png_pic_center]: /images/20221120/4cf8cb6eed934b45b25bf1f6f2a2a053.png
[20201118144033681.png_pic_center]: /images/20221120/85f85260027d4aa28c8e857f2db830fd.png
[20201118145726180.png_pic_center]: /images/20221120/002a409b412746b28249100eb987562f.png
[https_github.com_apache_rocketmq-externals]: https://github.com/apache/rocketmq-externals
[20201118145825185.png_pic_center]: /images/20221120/7eaaa41b27b149059a9f50b5f4531957.png
[20201118145839226.png_pic_center]: /images/20221120/66edb704f0ff4fcf82d579dc25fc6157.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/2046dc66bb1a49d39d5b64c77db191a6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221120/c6ede5f8aa6145aea819dd3a257fdc0e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221120/d83815b05d44473291077aac74713033.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221120/f6ce542f47044c108ca4c8b17de74dde.png