本文主要是介绍RocketMQ之Broker，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
Broker启动后默认监听10911和10912和10909三个端口
下面是broker的相关配置：
autoCreateSubscriptionGroup true
brokerName broker-a
listenPort 10911
haListenPort 10912
clientManagerThreadPoolQueueCapacity 1000000
flushCommitLogThoroughInterval 10000
flushCommitLogLeastPages 4
clientCallbackExecutorThreads 8
notifyConsumerIdsChangedEnable true
expectConsumerNumUseFilter 32
cleanResourceInterval 10000
channelNotActiveInterval 60000
diskMaxUsedSpaceRatio 75
debugLockEnable false
messageDelayLevel 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
clusterTopicEnable true
messageIndexEnable true
serverPooledByteBufAllocatorEnable true
shortPollingTimeMills 1000
commercialEnable true
redeleteHangedFileInterval 120000
flushConsumerOffsetInterval 5000
flushCommitLogTimed false
maxMessageSize 4194304
brokerId 0
syncFlushTimeout 5000
flushConsumeQueueThoroughInterval 60000
clientChannelMaxIdleTimeSeconds 120
flushDelayOffsetInterval 10000
serverSocketRcvBufSize 131072
flushDiskType ASYNC_FLUSH
maxTransferBytesOnMessageInMemory 262144
clientManageThreadPoolNums 32
serverChannelMaxIdleTimeSeconds 120
serverCallbackExecutorThreads 0
enablePropertyFilter false
transientStorePoolSize 5
enableConsumeQueueExt false
maxTransferBytesOnMessageInDisk 65536
pullMessageThreadPoolNums 32
clientCloseSocketIfTimeout false
fetchNamesrvAddrByAddressServer false
sendThreadPoolQueueCapacity 10000
diskFallRecorded true
transientStorePoolEnable false
offsetCheckInSlave false
disableConsumeIfConsumerReadSlowly false
commitCommitLogThoroughInterval 200
consumerManagerThreadPoolQueueCapacity 1000000
flushIntervalConsumeQueue 1000
clientOnewaySemaphoreValue 65535
warmMapedFileEnable false
slaveReadEnable false
transferMsgByHeap true
consumerFallbehindThreshold 17179869184
serverAsyncSemaphoreValue 64
startAcceptSendRequestTimeStamp 0
flushConsumerOffsetHistoryInterval 60000
brokerIP2 192.168.59.96
filterDataCleanTimeSpan 86400000
maxTransferCountOnMessageInDisk 8
brokerIP1 192.168.59.96
deleteCommitLogFilesInterval 100
adminBrokerThreadPoolNums 16
storePathCommitLog C:UsersAdministratorstorecommitlog
filterServerNums 0
deleteConsumeQueueFilesInterval 100
checkCRCOnRecover true
serverOnewaySemaphoreValue 256
filterSupportRetry false
defaultQueryMaxNum 32
clientSocketRcvBufSize 131072
clientWorkerThreads 4
maxDelayTime 40
connectTimeoutMillis 3000
commercialTimerCount 1
clientPooledByteBufAllocatorEnable false
serverSocketSndBufSize 131072
regionId DefaultRegion
duplicationEnable false
cleanFileForciblyEnable true
fastFailIfNoBufferInStorePool false
rejectTransactionMessage false
serverSelectorThreads 3
consumerManageThreadPoolNums 32
haSendHeartbeatInterval 5000
mapedFileSizeConsumeQueue 6000000
commitCommitLogLeastPages 4
longPollingEnable true
flushConsumeQueueLeastPages 2
storePathRootDir C:UsersAdministratorstore
# 默认队列个数
defaultTopicQueueNums = 8
highSpeedMode false
commercialBaseCount 1
maxErrorRateOfBloomFilter 20
accessMessageInMemoryMaxRatio 40
autoCreateTopicEnable true
commitIntervalCommitLog 200
brokerTopicEnable true
namesrvAddr 127.0.0.1:9876
clientAsyncSemaphoreValue 65535
maxMsgsNumBatch 64
fileReservedTime 48
deleteWhen 04
waitTimeMillsInSendQueue 200
commercialTransCount 1
osPageCacheBusyTimeOutMills 1000
maxIndexNum 20000000
registerBrokerTimeoutMills 6000
messageIndexSafe false
putMsgIndexHightWater 600000
serverWorkerThreads 8
clientSocketSndBufSize 131072
traceOn true
maxHashSlotNum 5000000
bitMapLengthConsumeQueueExt 112
brokerRole ASYNC_MASTER
rocketmqHome D:SoftwareDevJavaDevapache-rocketmq
useReentrantLockWhenPutMessage false
haHousekeepingInterval 20000
brokerPermission 6
maxTransferCountOnMessageInMemory 32
useEpollNativeSelector false
haSlaveFallbehindMax 268435456
haTransferBatchSize 32768
messageStorePlugIn
pullThreadPoolQueueCapacity 100000
# 集群中所有broker都要设置成一样，包括master和slave
brokerClusterName=DefaultCluster
enableCalcFilterBitMap false
destroyMapedFileIntervalForcibly 120000
mapedFileSizeCommitLog 1073741824
commercialBigCount 1
flushLeastPagesWhenWarmMapedFile 4096
sendMessageThreadPoolNums 1
flushIntervalCommitLog 500
mappedFileSizeConsumeQueueExt 50331648
这篇关于RocketMQ之Broker的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
