rockmq 集群 windonw下安裝,啟動broker,Try to shutdown service thread:PullRequestHoldService started:false lastThread:null


  在window下部署rocketmq集群時(rocketmq 4.7.1,jdk 1.8),nameserver 啟動成功,broker啟動不成功,總是Try to shutdown service thread:PullRequestHoldService started:false lastThread:null,broker.properties配置表如下

   

    #所屬集群名字
    brokerClusterName=rocketmq-cluster
    #broker名字,名字可重復,為了管理,每個master起一個名字,他的slave同他,eg:Amaster叫broker-a,他的slave也叫broker-a
    brokerName=broker-a
    #0 表示 Master,>0 表示 Slave
    brokerId=0
    #nameServer地址,分號分割
    namesrvAddr=127.0.0.1:9876;127.0.0.1:9870
    #在發送消息時,自動創建服務器不存在的topic,默認創建的隊列數
    defaultTopicQueueNums=4
    #是否允許 Broker 自動創建Topic,建議線下開啟,線上關閉
    autoCreateTopicEnable=true
    #是否允許 Broker 自動創建訂閱組,建議線下開啟,線上關閉
    autoCreateSubscriptionGroup=true
    #Broker 對外服務的監聽端口,
    listenPort=10911
    #刪除文件時間點,默認凌晨 4點
    deleteWhen=04
    #文件保留時間,默認 48 小時
    fileReservedTime=120
    #commitLog每個文件的大小默認1G
    mapedFileSizeCommitLog=1048576
    #ConsumeQueue每個文件默認存30W條,根據業務情況調整
    mapedFileSizeConsumeQueue=3000
    #destroyMapedFileIntervalForcibly=120000
    #redeleteHangedFileInterval=120000
    #檢測物理文件磁盤空間
    diskMaxUsedSpaceRatio=88
    #存儲路徑 
    #storePathRootDir=D:\\Java\\rocketmq-all-4.7.1-bin-release\\store\\broker-a
    #commitLog 存儲路徑
    storePathCommitLog=D:\\Java\\rocketmq-all-4.7.1-bin-release\\store\\broker-a\\commitlog
    #消費隊列存儲路徑存儲路徑
    storePathConsumeQueue=D:\\Java\\rocketmq-all-4.7.1-bin-release\\store\\broker-a\\consumequeue
    #消息索引存儲路徑
    storePathIndex=D:\\Java\\rocketmq-all-4.7.1-bin-release\\store\\broker-a\\index
    #checkpoint 文件存儲路徑
    storeCheckpoint=D:\\Java\\rocketmq-all-4.7.1-bin-release\\store\\broker-a\\checkpoint
    #abort 文件存儲路徑
    abortFile=D:\\Java\\rocketmq-all-4.7.1-bin-release\\store\\broker-a\\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

  需要注意的是 存儲路徑 storeCheckpoint ,abortFile 不需要創建文件夾,會自動創建checkpoint 文件 和 abort 文件,但是需要創建 commitlog ,consumequeue,index 文件夾, 這點需要特別注意。

  以上僅作記錄


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM