上传服务器
安装包下载https://download.csdn.net/download/weixin_41716049/88441732
1.创建目录【/jar/RocketMQ】用于存放 MQ 文件并将下载的文件上传到服务器文件夹中
mkdir /jar/RocketMQ
2.安装 unzip 命令用于解压压缩包:
yum -y install unzip
3.解压压缩包 rocketmq-all-4.9.2-bin-release.zip:
unzip rocketmq-all-4.9.2-bin-release.zip
- Benchmark:包含一些性能测试的脚本;
- Bin:可执行文件目录;
- Conf:配置文件目录;
- Lib:第三方依赖;
- LICENSE:授权信息;
- NOTICE:版本公告。
配置环境变量
- 打开配置文件
vim /etc/profile
- 添加环境变量
export NAMESRV_ADDR=公网IP:9876
- 刷新配置文件
source /etc/profile
修改 runserver.sh
切换到【/jar/RocketMQ/rocketmq-4.9.2/bin】目录下:
cd /jar/RocketMQ/rocketmq-4.9.2/bin
编辑文件【runserver.sh】:
vim runserver.sh
修改运行时占用内存大小,由于 Java 环境为 jdk8,所以修改关于 Java9 之前的版本的(注意哈 内存大小根据您自己的服务器来控制哈 我就是一台2核4G的小服务器 不改允许内存是启动不起来的):
修改后:
JDK1.8 如下
JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn128m -XX:MetaspaceSize=32m -XX:MaxMetaspaceSize=64m"
JDK1.9及以上 如下
JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -XX:MetaspaceSize=32m -XX:MaxMetaspaceSize=64m"
修改 runbroker.sh
- 编辑【runbroker.sh】:
vim runbroker.sh
- 修改配置
修改前:
修改后内容:
修改 broker.conf
切换【/jar/RocketMQ/rocketmq-4.9.2/conf】目录:
cd /jar/RocketMQ/rocketmq-4.9.2/conf
编辑【broker.conf】:
vim broker.conf
添加配置文件
namesrvAddr = 公网IP:9876
autoCreateTopicEnable = true
brokerIP1 = 公网IP
namesrvAddr:nameServer 地址,当 nameServer 和 broker 在一个服务器时可以写 localhost。
autoCreateTopicEnable:自动创建 Topic。
brokerIP1:公网 ip 地址。
启动
1.创建目录【/jar/RocketMQ/rocketmq-4.9.2/logs】用于存放日志:
mkdir /jar/RocketMQ/rocketmq-4.9.2/logs
2.切换到【/jar/RocketMQ/rocketmq-4.9.2】目录,启动 nameSrv:
nohup sh bin/mqnamesrv > ./logs/namesrv.log &
3.启动 broker,
-c
指定配置文件:
nohup sh bin/mqbroker -c conf/broker.conf > ./logs/broker.log &
4.查看 Java 程序进程:
jps -l
要是提示没有jps 命令
解决方法:需要安装java-1.X.X-openjdk-devel这个包,他提供了jps这个工具。
1.查找可用的包 yum list |grep jdk-devel
java-1.6.0-openjdk-devel.x86_64 1:1.6.0.41-1.13.13.1.el7_3 base
java-1.7.0-openjdk-devel.x86_64 1:1.7.0.181-2.6.14.8.el7_5 updates
java-1.8.0-openjdk-devel.i686 1:1.8.0.171-8.b10.el7_5 updates
java-1.8.0-openjdk-devel.x86_64 1:1.8.0.171-8.b10.el7_5 updates
java-1.8.0-openjdk-devel-debug.i686 1:1.8.0.171-8.b10.el7_5 updates
java-1.8.0-openjdk-devel-debug.x86_64 1:1.8.0.171-8.b10.el7_5 updates
————————————————
2.安装java-1.8.0-openjdk-devel.x86_64
yum install java-1.8.0-openjdk-devel.x86_64
3.验证
[root@supervisor2 ]# jps
13121 logviewer
16689 Jps
16205 QuorumPeerMain
安装 RocketMQ 控制台
1.上传服务器
将rocketmq-dashboard-1.0.1-SNAPSHOT.jar 上传服务器目录下
2.命令运行
rocketmq-dashboard-1.0.0.jar
包:
nohup java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar --server.port=8081 rocketmq.config.namesrvAddr=公网IP:9876 > rocketmq-4.9.2/logs/dashboard.log &
3.访问前查看防火墙是否开启,【9876、8081】端口是否未开放 。
Linux 防火墙命令
- 查看防火墙状态:
systemctl status firewalld
关闭防火墙:
systemctl stop firewalld
开启防火墙:
systemctl start firewalld
开放指定端口:
firewall-cmd --zone=public --add-port=8081/tcp --permanent
重启防火墙:
firewall-cmd --reload
4.浏览器访问:http://公网ip:8081:
进入控制台后要是出现下列错误
RemotingConnectException: connect to <172.17.0.1:10:109011>
当我们去连接远端的RocketMQ发送消息时,报错如下:org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.0.1: 10911> failed
但是我们在启动我们nameserver命名服务器和消息服务器时却没报错,一切正常。
此时,我们需要修改配置,进入RocketMQ的安装目录下的conf目录
我的如下,各人的不一样
进入broker.conf文件,并编辑
vim broker.conf
在conf文件中加入两行(建议直接复制,然后再修改为自己的IP),一定是大写IP!!!!!
namesrvAddr=127.0.0.1:9876
brokerIP1=192.168.200.130#是大写的IP一定要注意!!!修改成自己的IP地址
版权归原作者 程序猿邱先森 所有, 如有侵权,请联系我们删除。