手机版
你好,游客 登录 注册 搜索
背景:
阅读新闻

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

[日期:2015-10-14] 来源:Linux社区  作者:babywaa [字体: ]

环境准备: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
复制代码
 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
复制代码
复制代码
 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
复制代码

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、查看启动端口

复制代码
# netstat -tunpl
# jps
# kill -9 22596
# kill -9 22564
# kill -9 9967
# netstat -tunpl
# netstat -tunpl |grep java
复制代码

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

linux
本文评论   查看全部评论 (0)
表情: 表情 姓名: 字数

       

评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款