1、RocketMQ-Console介绍

RocketMQ-Console现在已更名为Rocketmq-Dashboard，为了方便，下面还是使用RocketMQ-Console

Git地址: https://github.com/apache/rocketmq-dashboard

包含了多个功能：运维、驾驶舱、集群、主题、消费者、生产者、消息、消息轨迹、connector 等

2、环境信息

  • 服务器
服务器 操作系统 硬件配置 版本 说明
Linux CentOS 7 4C16G 64位 生产环境建议Linux/Unix
  • 软件
工具/环境 版本 说明
JDK 1.8 RocketMQ Console要求版本在1.7以上
Git 1.8.3.1 源码方式安装需要，版本无要求
Maven 3.6.3 源码方式安装需求，版本无要求

3、安装

安装RocketMQ-Console，可以通过两种方式:

  • 通过Docker镜像安装；
  • 通过GitHub拉取源代码，进行编译，然后启动安装；

具体如下：

通过Docker方式

# 拉取镜像
# 还可以自己通过源码的方式打包镜像，需要有镜像仓库。打镜像命令：mvn clean package -Dmaven.test.skip=true docker:build
$ docker pull styletang/rocketmq-console-ng
# 启动,默认端口号是8080端口，映射到服务器里面可以按照需求进行更改
$ docker run -e "JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8080:8080 -t styletang/rocketmq-console-ng

通过源码方式（推荐）

# 从GitHub上面拉取代码
$ git clone https://github.com/apache/rocketmq-dashboard.git
$ cd rocketmq-dashboard

默认端口号是8080，可以到rocketmq-dashboard/src/main/resources/application.properties进行修改。

#这个填写自己的nameserver的地址，默认是localhost:9876
rocketmq.config.namesrvAddr=192.168.113.11:9876
#rocketmq-console的数据目录，默认为 /tmp/rocketmq-console/data
rocketmq.config.dataPath=/usr/local/rocketmq-console/data
#开启认证登录功能，默认为false
rocketmq.config.loginRequired=true

修改了以上参数之后，使用maven进行编译

# maven打包
$ mvn clean package -Dmaven.test.skip=true
$ nohup java -jar target/rocketmq-dashboard-1.0.0.jar &

4、开放防火墙对应端口号

如果你的服务器开通了防火墙，需要对端口号进行开放

#查看默认防火墙状态（关闭后显示notrunning，开启后显示running）
$ firewall-cmd --state 
# 开启一个指定端口号
# --permanent 永久生效，没有此参数重启后失效 
$ firewall-cmd --zone=public --add-port=8080/tcp --permanent   
#重载防火墙规则
firewall-cmd --reload

5、访问

地址：http://localhost:8080 端口如果更改过就用更改过的

6、设置登录验证的账号密码

前面我们虽然开启了登录验证的功能，但是并没有设置账户密码，这里默认的账户密码为 admin/admin。我们修改下这个密码。 在 rocketmq-console的数据目录下新建账户文件 users.properties 。

vim /usr/local/rocketmq-console/data/users.properties

下面是文件的内容

# 该文件支持热修改，即添加和修改用户时，不需要重新启动console
# 格式， 每行定义一个用户， username=password[,N]  #N是可选项，可以为0 (普通用户)； 1 （管理员）  

#定义管理员 
admin=test123456,1

#定义普通用户
#user1=user1
#user2=user2

然后我们杀进程，重启这个jar包即可。