rocketMQ搭建方法
注：不能用root启动
配置文件如下：
[[email protected] 2m-2s-sync]$ pwd
/opt/mq/alibaba-rocketmq/conf/2m-2s-sync
[[email protected] 2m-2s-sync]$ vim broker-a.properties
brokerClusterName=prodrcmq
brokerName=broker-a
brokerId=0
namesrvAddr=192.168.60.10:9876;192.168.60.14:9876;192.168.60.11:9876;192.168.60.13:9876
defaultTopicQueueNums=8
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
ListenPort=10911
deleteWhen=04
fileReservedTime=120
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=300000
diskMaxUsedSpaceRatio=88
storePathRootDir=/opt/mq/alibaba-rocketmq/store
storePathCommitLog=/opt/mq/alibaba-rocketmq/store/commitlog
storePathComsumeQueue=/opt/mq/alibaba-rocketmq/store/consumequeue
storePathIndex=/opt/mq/alibaba-rocketmq/store/index
storeCheckPoint=/opt/mq/alibaba-rocketmq/store/checkpoint
abortFile=/opt/mq/alibaba-rocketmq/store/abort
maxMessageSize=65536
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=SYNC_FLUSH
启动文件
|
[[email protected] init.d]$ cat mq #!/bin/bash
# chkconfig: 2345 10 90 # description: mq ....
#str=$"\n" #sstr=$(echo -e $str) #echo $sstr
BASE=/opt/mq/alibaba-rocketmq/bin PROFILE=broker-a.properties PROURL=/opt/mq/alibaba-rocketmq/conf/2m-2s-sync LL=$(ps -ef | grep java | grep -v grep | awk '{print $2}' | xargs kill -9) case "$1" in
'start')
cd /home/admin/ su - admin -c "nohup bash $BASE/mqnamesrv &" str=$"\n" sstr=$(echo -e $str) echo $sstr cd /opt/mq/ su - admin -c "nohup bash $BASE/mqbroker -c $PROURL/$PROFILE > /dev/null 2>&1 &" str=$"\n" sstr=$(echo -e $str) echo $sstr ;;
'stop')
su - admin -c "bash $BASE/mqshutdown broker" su - admin -c "bash $BASE/mqshutdown namesrv"
;;
'restart')
su - admin -c "bash $BASE/mqshutdown broker" su - admin -c "bash $BASE/mqshutdown namesrv" sleep 3 $KILL sleep 1
cd /home/admin/ su - admin -c "nohup bash $BASE/mqnamesrv &" str=$"\n" sstr=$(echo -e $str) echo $sstr cd /opt/mq/ su - admin -c "nohup bash $BASE/mqbroker -c $PROURL/$PROFILE > /dev/null 2>&1 &" str=$"\n" sstr=$(echo -e $str) echo $sstr sleep 1
;;
*)
echo "use start | stop"
;; esac |
[[email protected] 2m-2s-sync]$ pwd
/opt/mq/alibaba-rocketmq/conf/2m-2s-sync
[[email protected] 2m-2s-sync]$
[[email protected] 2m-2s-sync]$
[[email protected] 2m-2s-sync]$ ll
total 16
-rw-r--r-- 1 admin admin 794 Sep 19 13:43 broker-a.properties
-rw-r--r-- 1 admin admin 141 Mar 28 2015 broker-a-s.properties
-rw-r--r-- 1 admin admin 147 Mar 28 2015 broker-b.properties
-rw-r--r-- 1 admin admin 141 Mar 28 2015 broker-b-s.properties
rocketmq01---->192.168.60.10-------->a
rocketmq02---->192.168.60.14-------->a-s
rocketmq03---->192.168.60.11-------->b
rocketmq04---->192.168.60.13-------->b-s
注：启动脚本要改
启动脚本
#!/bin/bash
# chkconfig: 2345 10 90
# description: mq ....
#str=$"\n"
#sstr=$(echo -e $str)
#echo $sstr
BASE=/opt/mq/alibaba-rocketmq/bin
case "$1" in
'start')
cd /home/admin/
su - admin -c "nohup bash $BASE/mqnamesrv &"
str=$"\n"
sstr=$(echo -e $str)
echo $sstr
cd /opt/mq/
su - admin -c "nohup bash $BASE/mqbroker -c /opt/mq/alibaba-rocketmq/conf/2m-2s-sync/broker-a.properties > /dev/null 2>&1 &"
str=$"\n"
sstr=$(echo -e $str)
echo $sstr
;;
'stop')
su - admin -c "bash $BASE/mqshutdown broker"
su - admin -c "bash $BASE/mqshutdown namesrv"
;;
*)
echo "use start | stop"
;;
esac
cd /etc/init.d
sudo ln –s /opt/mq/mq.sh mq
chkconfig –add mq
chkconfig –level 2345 mq on
sudo /etc/init.d/mq start/stop
rocketmq-console配置
控制台包放到tomcat中，依赖tomcat启动。
[[email protected] webapps]$ pwd
/opt/apache-tomcat-8.0.23/webapps
[[email protected] webapps]$ ll
total 21408
drwxr-xr-x 6 admin admin 4096 Sep 20 15:38 mq-console
-rw-r--r-- 1 root root 21915397 Sep 20 13:55 mq-console.war
重新启动tomcat
[[email protected] ~]$ sudo /etc/init.d/tomcat restart
找到配置文件config.properties或application.properties进行修改
$ vim /opt/apache-tomcat-8.0.23/webapps/mq-console/WEB-INF/classes/config.properties
（ip1：port;ip2:port）
重新启动tomcat
sudo /etc/init.d/tomcat restart
浏览器中访问
http://192.168.60.12:8080/mq-console/cluster/list.do