电脑版
↑
正在加载...
rocketmq搭建
官网地址:http://rocketmq.apache.org/dowloading/releases
单机版本:
解压:
unzip rocketmq-all-4.2.0-bin-r elease.zip -d ./rocketmq-all-4.2.0-binls
切换到对应目录:
cd rocketmq-all-4.2.0-bin/
启动NameServer:
nohup sh bin/mqnameserver &
打印日志:
tail -f ~/Logs/rocketmqLogs/namesrv.Log
启动Broker:
nohup sh bin/mqbroker -n localhost:9876 &
打印日志:
tail -f ~/Logs/rocketmqLogs/broker.Log
关闭NameServer和Broker:
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv
集群版本:
首先分别在2台机器上启动NameServer
然后修改一台broker为master
namesrvAddr=192.168.100.131:9876;192.168.100.132:9876
brokerClusterName=DefaultCluster
brokerName=broker- a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH
listenPort=10911
storePathRootDir=/home/rocketmq/store-a
接着修改另一台broker为master
namesrvAddr=192.168.100.131:9876;192.168.100.132:9876
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerid=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH
listenPort=10911
storePathRootDir=/home/rocketmq/store-b
接着设置一台从服务器
name srvAddr=192.168.100.131:9876;192.168.100.132:9876
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerid=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
listenPort=11011
storePathRootDir=/home/rocketmq/store-b
最后设置另外一台从服务器:
namesrvAddr=l92.168.100.131:9876;192.168.100.132:9876
brokerClusterName=DefaultCluster
brokerName=broker- a
brokerid=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
listenPort=11011
storePathRootDir=/home/rocketmq/store-a
分别启动4个broker:
nohup sh ./bin/mqbroker -c config_file &
>>>>
首页
动态
工具
抓文