| |
Preparing the environment: CentOS_6.5_x64
IP: 192.168.0.249 dbTest249 Master1
IP: 192.168.0.251 webTest251 Master2
Download software alibaba-rocketmq
https://github.com/alibaba/RocketMQ/releases
First, install 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 /
Second, the master-slave configuration
1, respectively, at 249,251 on the Edit Profile
# Hostname
# Vim conf / 2m-noslave / broker-a.properties
1 ##################### Master1 server configuration file #####################
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 server configuration file #####################
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, edit JAVA memory block
# Vim bin / runbroker.sh
If the server memory is not enough, you can modify runserver.sh script (mqnamesrv file is called by the Name Server script runserver.sh main function com.alibaba.rocketmq.namesrv.NamesrvStartup start Name Server) in JAVA_OPT_1 parameters
[Plain] view plaincopy derived to view the code sheet on my piece of code CODE
1 JAVA_OPT_1 = "- server -Xms512m -Xmx1g -XX: PermSize = 128m -XX: MaxPermSize = 320m"
3. Create a data directory
# Mkdir -p / data / rocketmq / store / commitlog
# Mkdir / data / logs
# Cd conf /
# Sed -i 's # $ {user.home} # / data # g' * .xml // all xml files in the conf directory $ {user.home} replace / data, enter rocketmq / conf directory execute the command
4, start 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, view the boot log
# Tail -f /var/log/ns.log
# Tail -f /var/log/mq.log
6, view the boot port
# Netstat -tunpl
# Jps
# Kill -9 22596
# Kill -9 22564
# Kill -9 9967
# Netstat -tunpl
# Netstat -tunpl | grep java
7. Close RocketMQ
# Sh mqshutdown
1 Useage: mqshutdown broker | namesrv
# Sh mqshutdown broker
# Sh mqshutdown namesrv
8, start again
# Nohup sh mqnamesrv> /var/log/ns.log &
# Nohup sh mqbroker -c ../conf/2m-noslave/broker-a.properties> /var/log/mq.log 2> & 1 &
9, verification status
# Jps |
|
|
|