Linux RocketMQ4.x 部署和安装可视化控制台
Linux部署和安装可视化控制台RocketMQ4.x
文章目录
- RocketMQ4.x快速部署
-
- 一、安装
-
- 1、准备如下环境:
- 2、安装
- 二、启动
-
- 1.启动NameServer
- 2.启动broker
- 3.关闭nameserver broker执行的命令
- 4.使用jps查看进程
- 三、验证是否成功
- 常见错误
-
- 1.NameServer内存不够
- 2.Broker内存不足
- 源码安装Rocket4.x可视化控制台
-
- 1、下载项目
- 2、将项目包放在指定目录下并编译打包
- 3、运行启动
RocketMQ4.x快速部署
一、安装
1、准备如下环境:
centos7.9 2核4G以上
jdk1.8
maven3.2.x
下载安装包:http://mirror.bit.edu.cn/apache/rocketmq/4.4.0/rocketmq-all-4.4.0-source-release.zip
2、安装
#解压缩unzip rocketmq-all-4.9.3-source-release.zip#安装该项目所有的依赖包cd /usr/local/rocketmq-all-4.9.3/distribution/target/rocketmq-4.9.3/rocketmq-4.9.3mvn -Prelease-all -DskipTests clean install -U
二、启动
1.启动NameServer
Name Server概念:给生产和消费者提供路由信息,提供轻量级的服务发现、路由、元数据信息,可以多个部署,互相独立(比zooleeper更轻量)
nohup sh bin/mqnamesrv &
成功:查看日志 tail -f nohup.out (结尾:The Name Server boot success. serializeType=JSON 表示启动成功)
2.启动broker
Broker概念:MQ程序,接收生产的消息,提供给消费者消费的程序。
启动Broker(-n指定nameserver地址,nameserver服务端口为9876, broker默认端口 10911):
启动命令:nohup sh bin/mqbroker -n localhost:9876 -c ./conf/broker.conf &原因:阿里云存在多网卡,rocketmq都会根据当前网卡选择一个IP使用,当你的机器有多块网卡时,很有可能会有问题。比如,我遇到的问题是我机器上有两个IP,一个公网IP,一个私网IP, 因此需要配置broker.conf 指定当前的公网ip, 然后重新启动broker 新增配置:conf/broker.conf (属性名称brokerIP1=broker所在的公网ip地址 )新增这个配置:brokerIP1=120.76.62.13
3.关闭nameserver broker执行的命令
#先关闭brokersh bin/mqshutdown brokersh bin/mqshutdown namesrv
4.使用jps查看进程
三、验证是否成功
#进入目录cd /usr/local/rocketmq-all-4.9.3/distribution/target/rocketmq-4.9.3/rocketmq-4.9.3#设置名称服务地址export NAMESRV_ADDR=localhost:9876#投递消息sh bin/tools.sh org.apache.rocketmq.example.quickstart.ProducerSendResult [sendStatus=SEND_OK, msgId= ...#消费消息sh bin/tools.sh org.apache.rocketmq.example.quickstart.ConsumerConsumeMessageThread_please_rename_unique_group_name_4_3 Receive New Messages: [MessageExt······
常见错误
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12)## There is insufficient memory for the Java Runtime Environment to continue.# Native memory allocation (mmap) failed to map 8589934592 bytes for committing reserved memory.# An error report file with more information is saved as:# /usr/local/rocketmq-all-4.9.3/distribution/target/rocketmq-4.9.3/rocketmq-4.9.3/hs_err_pid16326.log[1]+ Exit 137 nohup sh bin/mqnamesrv
1.NameServer内存不够
编辑 bin/runserver.sh:
vi /uar/local/rocketmq-all-4.9.3/distribution/target/rocketmq-4.9.3/rocketmq-4.9.3/bin/runserver.sh JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
2.Broker内存不足
编辑 runbroker.sh
vi /uar/local/rocketmq-all-4.9.3/distribution/target/rocketmq-4.9.3/rocketmq-4.9.3/bin/runbroker.sh JAVA_OPT="${JAVA_OPT} -server -Xms528m -Xmx528m -Xmn256m"
源码安装Rocket4.x可视化控制台
1、下载项目
官网(太慢了): https://github.com/apache/rocketmq-externals.
或者网盘下载:
链接:https://pan.baidu.com/s/1kA7bH8bGZWDk9n7U1-8-Cw.
提取码:qtrb
2、将项目包放在指定目录下并编译打包
cd /usr/local/install/rocketmq-externals/rocketmq-console# 清除原来的包 跳过测试 编译打包mvn clean package -Dmaven.test.skip=true
3、运行启动
#进入目录cd /usr/local/install/rocketmq-externals/rocketmq-console/target#守护进程方式启动 nohup java -jar rocketmq-console-ng-1.0.0.jar &
结果:
查看rocketmq控制台:
http://ip:8080/
最近想要面试的同学可以可以看看下面的链接
链接: https://kyi.h5.xeknow.com/s/1WpcB1.