RocketMQ安装使用
wget "https://github.com/alibaba/RocketMQ/releases/download/v3.2.6/alibaba-rocketmq-3.2.6.tar.gz" tar -zxvf alibaba-rocketmq-3.2.6.tar.gz -C /usr/local/ cd /usr/local/alibaba-rocketmq/ vim /etc/rc.local #JAVA_HOME=/home/sammy/maven/jdk1.6.0_20 #JAVA_HOME=/home/sammy/maven/jdk1.8.0_25 #JAVA_HOME=/home/sammy/maven/jdk1.7.0_60 JAVA_HOME=/home/sammy/maven/jdk1.8.0_25 #JAVA_HOME=/data/tools/jdk1.8.0_101 PATH=$ANT_HOME/bin:$JAVA_HOME/bin:$PATH CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar export JAVA_HOME #export ANT_HOME export PATH export CLASSPATH export ROCKETMQ_HOME=/usr/local/alibaba-rocketmq export PATH=$JAVA_HOME/bin:$ROCKETMQ_HOME/bin:$PATH mkdir log 单机部署： nohup sh ./bin/mqnamesrv &>./log/mqnamesrv.log & nohup sh ./bin/mqbroker -n "192.168.17.99:9876" &>./log/mqbroker.log & ==================================================================================================== 集群部署： (双namesrv、双master、双slave) 192.168.17.99 192.168.17.116 修改mq配置文件采用异步复制 2m-2s-async 192.168.17.99 cd conf/2m-2s-async vim broker-a.properties namesrvAddr=192.168.17.99:9876;192.168.17.116:9876 brokerClusterName=DefaultCluster brokerName=broker-a brokerId=0 deleteWhen=04 fileReservedTime=48 brokerRole=ASYNC_MASTER flushDiskType=ASYNC_FLUSH storePathRootDir=/usr/local/alibaba-rocketmq/log/store storePathCommitLog=/usr/local/alibaba-rocketmq/log/store/commitlog vim broker-b-s.properties namesrvAddr=192.168.17.99:9876;192.168.17.116:9876 brokerClusterName=DefaultCluster brokerName=broker-b brokerId=1 deleteWhen=04 fileReservedTime=48 brokerRole=SLAVE flushDiskType=ASYNC_FLUSH listenPort=10913 storePathRootDir=/usr/local/alibaba-rocketmq/log/store storePathCommitLog=/usr/local/alibaba-rocketmq/log/store/commitlog 192.168.17.116 cd conf/2m-2s-async vim broker-b.properties namesrvAddr=192.168.17.99:9876;192.168.17.116:9876 brokerClusterName=DefaultCluster brokerName=broker-b brokerId=0 deleteWhen=04 fileReservedTime=48 brokerRole=ASYNC_MASTER flushDiskType=ASYNC_FLUSH storePathRootDir=/usr/local/alibaba-rocketmq/log/store storePathCommitLog=/usr/local/alibaba-rocketmq/log/store/commitlog vim broker-a-s.properties namesrvAddr=192.168.17.99:9876;192.168.17.116:9876 brokerClusterName=DefaultCluster brokerName=broker-a brokerId=1 deleteWhen=04 fileReservedTime=48 brokerRole=SLAVE flushDiskType=ASYNC_FLUSH listenPort=10913 storePathRootDir=/usr/local/alibaba-rocketmq/log/store storePathCommitLog=/usr/local/alibaba-rocketmq/log/store/commitlog 两台机器： nohup sh ./bin/mqnamesrv &>./log/mqnamesrv.log & 192.168.17.99： nohup sh ./bin/mqbroker -c conf/2m-2s-async/broker-a.properties & nohup sh ./bin/mqbroker -c conf/2m-2s-async/broker-b-s.properties & 192.168.17.116： nohup sh ./bin/mqbroker -c conf/2m-2s-async/broker-b.properties & nohup sh ./bin/mqbroker -c conf/2m-2s-async/broker-a-s.properties & sh ./bin/mqadmin updateTopic -c DefaultCluster 192.168.17.99:10911 -t testbroker sh ./bin/mqadmin updateTopic -c DefaultCluster 192.168.17.116:10911 -t testbroker
