rocketmq 集群搭建 (2master + 2slave + 2namesrv)

技术:rocketmq4.2

运行环境:centos7.3

demo功能:提供说明rocketmq安装过程

下载,解压,拷贝忽略

name srv

修改配置 ./conf/namesrv.conf

kvConfigPath=/data/namesrv/kvConfig.properties

 

修改日志配置 ./conf/logback_namesrv.xml





    
        /data/rocketmq/logs/rocketmqlogs/namesrv_default.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/namesrv_default.%i.log.gz
            1
            5
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    

    
        /data/rocketmq/logs/rocketmqlogs/namesrv.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/namesrv.%i.log.gz
            1
            5
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    
    
        
        0
    

    
        true
        
            %d{yyy-MM-dd HH\:mm\:ss,SSS} %p %t - %m%n
            UTF-8
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

 

启动2台

nohup ./bin/mqnamesrv -c ./conf/namesrv.conf > /dev/null 2>&1 &

broker master

注意执行: /bin/os.sh (对于os参数优化)

新建异步模式配置:async.properties

brokerName=rocketmq-broker-1
brokerId=0
brokerRole=ASYNC_MASTER ### 同步:brokerRole=SYNC_MASTER
namesrvAddr=127.0.0.1:9876;127.0.0.2:9876
flushDiskType=ASYNC_FLUSH
fileReservedTime=168
deleteWhen=04
autoCreateTopicEnable=false
storePathCommitLog=/data/rocketmq/commitlog
rejectTransactionMessage=true
storePathRootDir=/data/rocketmq
cleanFileForciblyEnable=true
autoCreateSubscriptionGroup=false
brokerClusterName=rocketmq-cluster-1
brokerIP1=192.168.1.101

日志配置(master, slave 可以配置一样)

./conf/logback_broker.xml







    
        /data/rocketmq/logs/rocketmqlogs/broker_default.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/broker_default.%i.log.gz
            1
            10
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    

    
        /data/rocketmq/logs/rocketmqlogs/broker.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/broker.%i.log.gz
            1
            20
        
        
            128MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    
    
        
    

    
        /data/rocketmq/logs/rocketmqlogs/protection.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/protection.%i.log.gz
            1
            10
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} - %m%n
            UTF-8
        
    
    
        
    

    
        /data/rocketmq/logs/rocketmqlogs/watermark.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/watermark.%i.log.gz
            1
            10
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} - %m%n
            UTF-8
        
    
    
        
    

    
        /data/rocketmq/logs/rocketmqlogs/store.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/store.%i.log.gz
            1
            10
        
        
            128MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    
    
        
    

    
        /data/rocketmq/logs/rocketmqlogs/remoting.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/remoting.%i.log.gz
            1
            10
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    
    
        
    

    
        /data/rocketmq/logs/rocketmqlogs/storeerror.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/storeerror.%i.log.gz
            1
            10
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    
    
        
    


    
        /data/rocketmq/logs/rocketmqlogs/transaction.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/transaction.%i.log.gz
            1
            10
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    
    
        
    

    
        /data/rocketmq/logs/rocketmqlogs/lock.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/lock.%i.log.gz
            1
            5
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    
    
        
    

    
        /data/rocketmq/logs/rocketmqlogs/filter.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/filter.%i.log.gz
            1
            10
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    
    
        
    

    
        /data/rocketmq/logs/rocketmqlogs/stats.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/stats.%i.log.gz
            1
            5
        
        
            100MB
        
        
            %d{yyy-MM-dd HH:mm:ss,GMT+8} %p - %m%n
            UTF-8
        
    

    
        /data/rocketmq/logs/rocketmqlogs/commercial.log
        true
        
            /data/rocketmq/logs/rocketmqlogs/otherdays/commercial.%i.log.gz
            1
            10
        
        
            500MB
        
    

    
        true
        
            %d{yyy-MM-dd HH\:mm\:ss,GMT+8} %p %t - %m%n
            UTF-8
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

    
        
        
    

编写启动脚本

nohup sh ./bin/mqbroker -c ./async.properties > /dev/null 2>&1 &

 

启动2台

broker slave

新建异步配置文件

brokerName=broker-1 ## 一组 master 和 slave 的名字一样
brokerId=1
brokerRole=SLAVE
namesrvAddr=127.0.0.1:9876;127.0.0.2:9876
flushDiskType=ASYNC_FLUSH  ## 磁盘还是需要异步
fileReservedTime=168
deleteWhen=04
autoCreateTopicEnable=false
storePathCommitLog=/data/rocketmq/commitlog
rejectTransactionMessage=true
storePathRootDir=/data/rocketmq
cleanFileForciblyEnable=true
autoCreateSubscriptionGroup=false
brokerClusterName=rocketmq-cluster-1
brokerIP1=192.168.1.102

启动脚本

nohup sh ./bin/mqbroker -c ./async.properties > /dev/null 2>&1 & 

启动2台

欢迎添加微信,互相学习↑↑↑ -_-

发表评论

全部评论:0条

白老虎

programming is not only to solve problems, ways to think