阿里云-云小站(无限量代金券发放中)
【腾讯云】云服务器、云数据库、COS、CDN、短信等热卖云产品特惠抢购

Linux分布式消息队列RocketMQ部署与监控–双Master

167次阅读
没有评论

共计 2166 个字符,预计需要花费 6 分钟才能阅读完成。

环境准备:CentOS_6.5_x64

IP:192.168.0.249 dbTest249  Master1
IP:192.168.0.251 webTest251 Master2

下载 alibaba-rocketmq 软件

https://github.com/alibaba/RocketMQ/releases 

一、安装 rocketmq

# tar zxf alibaba-rocketmq-3.2.4-beta1.tar.gz -C /usr/local/
# cd /usr/local/
# ln -s /usr/local/alibaba-rocketmq /usr/local/rocketmq
# cd rocketmq/

二、配置主从

1、分别在 249、251 上编辑配置文件

# hostname 
# vim conf/2m-noslave/broker-a.properties
Linux 分布式消息队列 RocketMQ 部署与监控 -- 双 Master
1 #####################Master1 服务器配置文件 #####################    
 2 brokerClusterName=FusionCluster    
 3 brokerName=broker-a    
 4 brokerId=0    
 5 namesrvAddr=dbTest249:9876;webTest251:9876    
 6 deleteWhen=04    
 7 fileReservedTime=120    
 8 
 9 brokerRole=ASYNC_MASTER    
10 flushDiskType=ASYNC_FLUSH    
11 sstorePathRootDir=/data/rocketmq/store    
12 storePathCommitLog=/data/rocketmq/store/commitlog
Linux 分布式消息队列 RocketMQ 部署与监控 -- 双 Master
Linux 分布式消息队列 RocketMQ 部署与监控 -- 双 Master
1 #####################Master2 服务器配置文件 #####################    
 2 brokerClusterName=FusionCluster    
 3 brokerName=broker-b    
 4 brokerId=1    
 5 namesrvAddr=dbTest249:9876;webTest251:9876    
 6 deleteWhen=04    
 7 fileReservedTime=120    
 8 
 9 brokerRole=ASYNC_MASTER    
10 flushDiskType=ASYNC_FLUSH    
11 listenPort=10911 
12 sstorePathRootDir=/data/rocketmq/store    
13 storePathCommitLog=/data/rocketmq/store/commitlog
Linux 分布式消息队列 RocketMQ 部署与监控 -- 双 Master

2、编辑 Java 内存块

# vim bin/runbroker.sh

如果服务器内存不够,可以修改 runserver.sh 脚本(mqnamesrv 文件中通过 runserver.sh 脚本调用 Name Server 的主函数 com.alibaba.rocketmq.namesrv.NamesrvStartup 启动 Name Server)中的 JAVA_OPT_1 参数
[plain] view plaincopy 在 CODE 上查看代码片派生到我的代码片

1 JAVA_OPT_1="-server -Xms512m -Xmx1g -XX:PermSize=128m -XX:MaxPermSize=320m"

3、创建数据目录

# mkdir -p /data/rocketmq/store/commitlog
# mkdir /data/logs
# cd conf/
# sed -i 's#${user.home}#/data#g' *.xml      // 将 conf 目录下所有 xml 文件中的 ${user.home} 替换成 /data, 进入 rocketmq/conf 目录下执行该命令 

4、启动 RocketMQ

# cd ../bin/
# nohup sh mqnamesrv >/var/log/ns.log &
# nohup sh mqbroker -c ../conf/2m-noslave/broker-a.properties > /var/log/mq.log 2>&1 &

5、查看启动日志

# tail -f /var/log/ns.log 
# tail -f /var/log/mq.log

6、查看启动端口

Linux 分布式消息队列 RocketMQ 部署与监控 -- 双 Master
# netstat -tunpl
# jps
# kill -9 22596
# kill -9 22564
# kill -9 9967
# netstat -tunpl
# netstat -tunpl |grep java
Linux 分布式消息队列 RocketMQ 部署与监控 -- 双 Master

7、关闭 RocketMQ

# sh mqshutdown
1 Useage: mqshutdown broker | namesrv
# sh mqshutdown broker
# sh mqshutdown namesrv

8、再次启动

# nohup sh mqnamesrv >/var/log/ns.log &
# nohup sh mqbroker -c ../conf/2m-noslave/broker-a.properties > /var/log/mq.log 2>&1 &

9、验证状态

# jps

RocketMQ 消息队列简单部署  http://www.linuxidc.com/Linux/2014-09/106842.htm

本文永久更新链接地址 :http://www.linuxidc.com/Linux/2015-10/124112.htm

正文完
星哥说事-微信公众号
post-qrcode
 0
星锅
版权声明:本站原创文章,由 星锅 于2022-01-21发表,共计2166字。
转载说明:除特殊说明外本站文章皆由CC-4.0协议发布,转载请注明出处。
【腾讯云】推广者专属福利,新客户无门槛领取总价值高达2860元代金券,每种代金券限量500张,先到先得。
阿里云-最新活动爆款每日限量供应
评论(没有评论)
验证码
【腾讯云】云服务器、云数据库、COS、CDN、短信等云产品特惠热卖中