rocketmq 군집 구축

이전 장 에 서 는 rocketmq 의 메시지 전송 과 수신 을 설명 하 였 으 며, 이 글 은 rocketmq 를 어떻게 설치 하 는 지 설명 하 였 다.
단기 건설
1. 패키지 설치 준비
apache - rocketmq. tar. gz 를 / opt 디 렉 터 리 에 업로드 합 니 다.http://download.csdn.net/download/xxzblog/10124706
기계
2. 설치

cd /opt
tar -xzf apache-rocketmq.tar.gz
mv apache-rocketmq rocketmq
mkdir /opt/rocketmq/logs
cd /opt/rocketmq/bin && dos2unix *

3. 환경 설정

cp /opt/rocketmq/conf/broker.conf /opt/rocketmq/conf/broker.properties
echo "brokerIP1=192.168.1.101" > /opt/rocketmq/conf/broker.properties

vi /opt/rocketmq/mqnamesrv-start.sh
export ROCKETMQ_HOME=/opt/rocketmq
nohup sh /opt/rocketmq/bin/mqnamesrv > /opt/rocketmq/logs/mqnamesrv.log 2>&1 &
:x
chmod u+x /opt/rocketmq/mqnamesrv-start.sh

vi /opt/rocketmq/mqbroker-start.sh
export ROCKETMQ_HOME=/opt/rocketmq
nohup sh /opt/rocketmq/bin/mqbroker -n 192.168.1.101:9876 -c /opt/rocketmq/conf/broker.properties > /opt/rocketmq/logs/mqbroker.log 2>&1 &
:x
chmod u+x /opt/rocketmq/mqbroker-start.sh

무 리 를 지어 짓다.
1, 2 는 단기 와 같다.
본 고 는 2m - noslave, 기계 ip: 192.168.1.101, 192.168.1.102 를 배치 합 니 다.
3. 환경 설정
/opt/rocketmq/conf/2m-noslave/broker-a.properties

#        
brokerClusterName=DefaultCluster
#broker  ,                 
brokerName=broker-a
#0    Master,>0    Slave
brokerId=0
#nameServer  ,    
namesrvAddr=192.168.1.101:9876;192.168.1.102:9876

#  
brokerIP1=192.168.1.101

#      ,           topic,        
defaultTopicQueueNums=4
#     Broker     Topic,      ,    
autoCreateTopicEnable=true
#     Broker        ,      ,    
autoCreateSubscriptionGroup=true
#Broker          
listenPort=10911
#       ,     4 
deleteWhen=04
#      ,   48   
fileReservedTime=48
#commitLog         1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue       30W ,        
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#          
diskMaxUsedSpaceRatio=88

#          
#    
storePathRootDir=/opt/rocketmq/store
#commitLog     
storePathCommitLog=/opt/rocketmq/store/commitlog
#            
storePathConsumeQueue=/opt/rocketmq/store/consumequeue
#        
storePathIndex=/opt/rocketmq/store/index
#checkpoint       
storeCheckpoint=/opt/rocketmq/store/checkpoint
#abort       
abortFile=/opt/rocketmq/store/abort


#         
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker    
#- ASYNC_MASTER     Master
#- SYNC_MASTER     Master
#- SLAVE
brokerRole=ASYNC_MASTER
#    
#- ASYNC_FLUSH     
#- SYNC_FLUSH     
flushDiskType=ASYNC_FLUSH

#checkTransactionMessageEnable=false
#        
#sendMessageThreadPoolNums=128
#        
#pullMessageThreadPoolNums=128

/opt/rocketmq/conf/2m-noslave/broker-b.properties

#        
brokerClusterName=DefaultCluster
#broker  ,                 
brokerName=broker-b
#0    Master,>0    Slave
brokerId=0
#nameServer  ,    
namesrvAddr=192.168.1.101:9876;192.168.1.102:9876

#  
brokerIP1=192.168.1.102

#      ,           topic,        
defaultTopicQueueNums=4
#     Broker     Topic,      ,    
autoCreateTopicEnable=true
#     Broker        ,      ,    
autoCreateSubscriptionGroup=true
#Broker          
listenPort=10911
#       ,     4 
deleteWhen=04
#      ,  48  
fileReservedTime=48
#commitLog         1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue       30W ,        
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#          
diskMaxUsedSpaceRatio=88

#          
#    
storePathRootDir=/opt/rocketmq/store
#commitLog     
storePathCommitLog=/opt/rocketmq/store/commitlog
#            
storePathConsumeQueue=/opt/rocketmq/store/consumequeue
#        
storePathIndex=/opt/rocketmq/store/index
#checkpoint       
storeCheckpoint=/opt/rocketmq/store/checkpoint
#abort       
abortFile=/opt/rocketmq/store/abort


#         
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker    
#- ASYNC_MASTER     Master
#- SYNC_MASTER     Master
#- SLAVE
brokerRole=ASYNC_MASTER
#    
#- ASYNC_FLUSH     
#- SYNC_FLUSH     
flushDiskType=ASYNC_FLUSH

#checkTransactionMessageEnable=false
#        
#sendMessageThreadPoolNums=128
#        
#pullMessageThreadPoolNums=128

nameserver 스 크 립 트 시작 [기계 두 대]

cd /opt/rocketmq/bin
nohup sh mqnamesrv &

BrokerServer 시작
192.168.1.101

nohup sh /opt/rocketmq/bin/mqbroker -c /opt/rocketmq/conf/2m-noslave/broker-a.properties > /opt/rocketmq/logs/mqbroker.log  2>&1 &

192.168.1.102

nohup sh /opt/rocketmq/bin/mqbroker -c /opt/rocketmq/conf/2m-noslave/broker-b.properties > /opt/rocketmq/logs/mqbroker.log  2>&1 &

비고: os 에 대한 최적화 / opt / rocketmq / bin / os. sh 를 실행 할 수 있 습 니 다.
rocketmq - console 구축
1. 패키지 설치 준비
rocketmq - console - ng - 1.0.0. jar 를 / opt / rocketmq - console 로 업로드 합 니 다.http://download.csdn.net/download/xxzblog/10124810
2. 스 크 립 트 시작

vi /opt/rocketmq-console/start.sh
nohup java -jar rocketmq-console-ng-1.0.0.jar --server.port=12581 --rocketmq.config.namesrvAddr=192.168.1.101:9876,192.168.1.102:9876 >/opt/rocketmq-console/run.log 2>&1 &
:x
chmod u+x /opt/rocketmq-console/start.sh

3. 스 크 립 트 실행

/opt/rocketmq-console/start.sh

4. 성공 여부 검증

     :http://127.0.0.1:12581

전체 rocketmq 구축 이 끝 났 습 니 다.