对于新手(我自己)来说,管理查看RocketMQ最好的办法是通过图形化界面。RocketMQ的源码并没有提供对应的图形化管理工具,但是我们可以使用RocketMQ-Console这个图形化工具。下面我们介绍下怎么安装,具体大家可以参考 github 这里 ,中文的使用手册 点我 。
1. 环境准备
rocketmq-console依赖java环境,官方要求JDK要在1.7以上,这里我使用的是jdk1.8;此外,由于需要编译java代码,所以还需要maven环境,这里我使用的是 maven3.6。
最好还安装好git,可以用来下载github的源码。
2.下载rocketmq-console源码并进行编译安装
2.1 下载源码
点击该链接下载rocket-externals的源代码,里面包含rocket-console项目。
#使用wget下载
wget https://codeload.github.com/apache/rocketmq-externals/zip/master -O rocketmq-externals.zip
#解压
unzip rocketmq-externals.zip
cd rocketmq-externals-master/rocketmq-console/
2.2 修改部分参数并编译
rocketmq-console默认情况下是免登陆的,为了安全起见我们设置用户名密码登录,修改 src目录下的 application.properties 文件。
vim 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进行编译
mvn clean package -Dmaven.test.skip=true
注意:
mvn的下载速度可能有点慢,建议修改为国内的源。修改 maven的配置文件,conf/settings.xml 。找到 mirrors 标签修改
<mirror>
<id>alimaven</id>
<name>aliyun maven</name>
<url>http://maven.aliyun.com/nexus/content/groups/public/</url>
<mirrorOf>central</mirrorOf>
</mirror>
3. 运行编译后的jar包
编译完成后,在target目录下会生成对应的jar包,我们运行它。
#新建一个目录用来存放rocketmq-console的文件
mkdir /usr/local/rocketmq-console
cp target/rocketmq-console-ng-1.0.1.jar /usr/local/rocketmq-console/
#运行这个jar包
cd /usr/local/rocketmq-console/
nohup java -jar rocketmq-console-ng-1.0.1.jar &
4. 打开浏览器验证
rocketmq-console默认开启8080端口,我们使用浏览器打开。
前面我们虽然开启了登录验证的功能,但是并没有设置账户密码,这里默认的账户密码为 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包即可。
更多内容请参考最上面提到的中文手册。