zoukankan      html  css  js  c++  java
  • 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 文件夹, 这点需要特别注意。

      以上仅作记录

  • 相关阅读:
    让Controller支持对平铺参数执行@Valid数据校验
    @Validated和@Valid的区别?校验级联属性(内部类)
    Apache和Spring提供的StopWatch执行时间监视器
    Spring方法级别数据校验:@Validated + MethodValidationPostProcessor
    疑问
    第20章 链接详解(笔记)
    nm命令介绍
    使用Euclid算法求最大公约数
    Linux Man手册的使用示例
    VMware12 + Ubuntu16.04 虚拟磁盘扩容
  • 原文地址:https://www.cnblogs.com/xiaoshudian/p/13560986.html
Copyright © 2011-2022 走看看