rocketmq-4.9.3 安装部署
前提准备
| 序号 | 软件 |
|---|
| 1 | jdk-8u192-linux-x64.rpm |
| 2 | rocketmq-all-4.9.3-bin-release.zip |
安装说明
| 内容 | 描述 |
|---|
| 服务器IP | 192.168.16.128 |
| 安装位置 | /usr/local/rocketmq |
| srv配置文件 | /usr/local/rocketmq/conf/namesrv.properties |
| broker配置文件 | /usr/local/rocketmq/conf/broker.conf |
| 日志文件 | /usr/local/rocketmq/logs/{server.log, broker.log} |
| server端口 | 9678 |
| broker端口 | 10911 |
安装步骤
安装解压工具
$ yum -y install unzip
安装JDK
$ rpm -ivh jdk-8u192-linux-x64.rpm
$ java -version
# 配置环境变量
$ vim /etc/profile
export JAVA_HOME=/usr/java/jdk1.8.0_192-amd64
export JRE_HOME=$JAVA_HOME/jre
export PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin;
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib
$ source /etc/profile
解压及安装
$ unzip rocketmq-all-4.9.3-bin-release.zip
$ mv rocketmq-4.9.3 /usr/local/rocketmq
$ vim /usr/local/rocketmq/bin/runserver.sh
# 根据情况调整内存参数
JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
$ vim /usr/local/rocketmq/bin/runbroker.sh
# 修改后
JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g"
# 修改server默认端口
$ vim /usr/local/rocketmq/conf/namesrv.properties
listenPort=9678
$ vim /usr/local/rocketmq/conf/broker.conf
# 添加配置
namesrvAddr=192.168.16.128:9678 # 修改默认端口
brokerIP1=192.168.16.128
# listenPort=9911 # 默认10911
# 创建日志存储目录
$ mkdir /usr/local/rocketmq/logs
启动
# 启动server
$ nohup sh /usr/local/rocketmq/bin/mqnamesrv -c /usr/local/rocketmq/conf/namesrv.properties >> /usr/local/rocketmq/logs/server.log 2>&1 &
# 启动broker
$ nohup sh /usr/local/rocketmq/bin/mqbroker -n 192.168.16.128:9678 -c /usr/local/rocketmq/conf/broker.conf >> /usr/local/rocketmq/logs/broker.log 2>&1 &
停止
$ sh /usr/local/rocketmq/bin/mqshutdown namesrv
$ sh /usr/local/rocketmq/bin/mqshutdown broker
常用命令
# 查看帮助
$ sh mqadmin help
# 查看集群信息
$ sh mqadmin clusterList -n 192.168.16.128:9678
# 查看所有topic
$ sh mqadmin topicList -n 192.168.16.128:9678
# 查看某个topic详情
$ sh mqadmin topicstatus -n 192.168.16.128:9678 -t function-test-13
# 查看所有消费组
$ sh mqadmin consumerProgress -n 192.168.16.128:9678
# 查看某个消费组
$ sh mqadmin consumerProgress -n 192.168.16.128:9678 -g GroupConsumer
# 新增topic
$ sh mqadmin updateTopic –n 192.168.16.128:9678 –c DefaultCluster –t Example01
# 删除topic
$ sh mqadmin deleteTopic –n 192.168.16.128:9678 –c DefaultCluster –t Example01
# 查询TOPIC被哪些Consumer Group订阅了
$ sh mqadmin statsAll -n 192.168.16.128:9678 | grep
# 查看Consumer Group订阅了哪些TOPIC
$ sh mqadmin consumerProgress -g -n 192.168.16.128:9678
# 查询消息详情
$ sh mqadmin queryMsgById -i -n 192.168.16.128:9678
# 查询Producer的网络连接情况
$ sh mqadmin producerConnection -n 192.168.16.128:9678 -g -t
# 查询Consumer的网络连接情况
$ sh mqadmin consumerConnection -n 192.168.16.128:9678 -g
# 查询Consumer的消费状态
$ sh mqadmin consumerProgress -n 192.168.16.128:9678 -g
