zoukankan      html  css  js  c++  java
  • rocketmq双主模式

    1、官网

    https://rocketmq.apache.org/

    官方安装文档

    https://rocketmq.apache.org/docs/quick-start/

    2、rocketmq多主配置文件参考(conf/2m-noslave/broker-a.properties)

    10.0.0.2服务器
    [root@a ~]# cat /usr/local/rocketmq/conf/2m-noslave/broker-a.properties
    brokerClusterName=rocketmq-cluster
    brokerName=broker-a
    brokerId=0
    namesrvAddr=10.0.0.2:9876;10.0.0.3:9876
    brokerIP1=10.0.0.2
    defaultTopicQueueNums=4
    autoCreateTopicEnable=true
    autoCreateSubscriptionGroup=true
    listenPort=10168
    deleteWhen=04
    fileReservedTime=48
    mapedFileSizeCommitLog=1073741824
    mapedFileSizeConsumeQueue=500000
    diskMaxUsedSpaceRatio=88
    storePathRootDir=/data/rocketmq/store
    storePathCommitLog=/data/rocketmq/store/commitlog
    storePathConsumeQueue=/data/rocketmq/store/consumequeue
    storePathIndex=/data/rocketmq/store/index
    storeCheckpoint=/data/rocketmq/store/checkpoint
    abortFile=/data/rocketmq/store/abort
    maxMessageSize=65536
    brokerRole=ASYNC_MASTER
    flushDiskType=ASYNC_FLUSH
    
    #发消息线程池数量
    #sendMessageThreadPoolNums=128
    #拉消息线程池数量
    #pullMessageThreadPoolNums=128
    

      

    服务启动与关闭

    function start_rocketMQ(){ 
        echo "start mqnamesrv......"  
        nohup sh /usr/local/rocketmq/bin/mqnamesrv &
        nohup sh /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &
    
        sleep 2
        [ $? -ne 0 ]&& action "start mqnamesrv  Success..."  /bin/true||action "start mqnamesrv False..." /bin/false
    
    }
    
    function stop_rocketMQ(){
         echo "stop rocketMQ..."
         sh /usr/local/rocketmq/bin/mqshutdown broker
         sleep 2
         sh /usr/local/rocketmq/bin/mqshutdown namesrv
    
    }
    

      

    10.0.0.3服务器
    [root@b ~]# cat /usr/local/rocketmq/conf/2m-noslave/broker-b.properties 
    brokerClusterName=rocketmq-cluster
    brokerName=broker-b
    brokerId=0
    namesrvAddr=10.0.0.2:9876;10.0.0.3:9876
    brokerIP1=10.0.0.3
    defaultTopicQueueNums=4
    autoCreateTopicEnable=true
    autoCreateSubscriptionGroup=false
    listenPort=10168
    deleteWhen=04
    fileReservedTime=48
    mapedFileSizeCommitLog=1073741824
    mapedFileSizeConsumeQueue=500000
    diskMaxUsedSpaceRatio=88
    storePathRootDir=/data/rocketmq/store
    storePathCommitLog=/data/rocketmq/store/commitlog
    storePathConsumeQueue=/data/rocketmq/store/consumequeue
    storePathIndex=/data/rocketmq/store/index
    storeCheckpoint=/data/rocketmq/store/checkpoint
    abortFile=/data/rocketmq/store/abort
    maxMessageSize=65536
    brokerRole=ASYNC_MASTER
    flushDiskType=ASYNC_FLUSH
    
    #发消息线程池数量
    #sendMessageThreadPoolNums=128
    #拉消息线程池数量
    #pullMessageThreadPoolNums=128
    

      

    启动与关闭

    function start_rocketMQ(){ 
        echo "start mqnamesrv......"  
        nohup sh /usr/local/rocketmq/bin/mqnamesrv &
        nohup sh /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-b.properties >/dev/null 2>&1 &
    
        sleep 2
        [ $? -ne 0 ]&& action "start mqnamesrv  Success..."  /bin/true||action "start mqnamesrv False..." /bin/false
    
    }
    
    function stop_rocketMQ(){
         echo "stop rocketMQ..."
         sh /usr/local/rocketmq/bin/mqshutdown broker
         sleep 2
         sh /usr/local/rocketmq/bin/mqshutdown namesrv
    
    }
    

      



  • 相关阅读:
    python基础学习4(内置函数)
    python基础学习5(包与模块)
    放弃用你的InnerHTML来输出HTML吧,jQuery Tmpl不详细讲解
    Entity Framework 4.1 CodeFirst实例
    .net企业库数据处理模块使用DAAB来开发应用
    行转列和列转行
    读懂这100这句话,你会懂得很多
    iis 6 下有关gzip 的有关配置
    jquery 设置 Select CheckBox Radio
    SQL函数说明大全
  • 原文地址:https://www.cnblogs.com/zhangb8042/p/10487907.html
Copyright © 2011-2022 走看看