autoCreateSubscriptionGroup true brokerName broker-a 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 listenPort 10911 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 brokerClusterName DefaultCluster enableCalcFilterBitMap false destroyMapedFileIntervalForcibly 120000 mapedFileSizeCommitLog 1073741824 commercialBigCount 1 flushLeastPagesWhenWarmMapedFile 4096 sendMessageThreadPoolNums 1 flushIntervalCommitLog 500 mappedFileSizeConsumeQueueExt 50331648
相关推荐
RocketMQ 配置文件:(下面是默认配置) brokerClusterName = DefaultCluster brokerName = broker-a brokerId = 0 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH
本文将详细介绍RocketMQ的运行参数配置,帮助读者更好地理解和优化RocketMQ的运行环境。 首先,我们要关注的是Broker配置参数,这是RocketMQ的核心组件,负责消息的存储和转发。其中,`listenPort`设置为10911,这...
RocketMQ Console是RocketMQ的管理控制台,它提供了一个图形化的界面,方便用户监控和管理RocketMQ集群的状态,进行消息的发布、消费以及相关配置操作。 `rocketmq-console-ng-2.0.0.jar` 是RocketMQ控制台的应用...
RocketMq的默认配置要求很高,例如内存至少需要4个G,对于开发调试环境来说太高了。因此,我们需要修改这些参数,以避免内存分配或者不够的问题。 首先,创建logs文件夹,存储mq日志: [root@dev ~]# cd /...
RocketMQ-Dashboard是一款专为Apache RocketMQ设计的可视化管理工具,它允许用户通过Web界面来监控、管理和操作RocketMQ集群,极大地简化了RocketMQ的日常运维工作。在本资源中,您将找到一个可以直接启动的jar包,...
综上所述,部署RocketMQ集群需要考虑的方面包括集群架构规划、环境准备、软件下载安装、文件路径配置、配置文件调整和测试验证。在部署过程中,需要根据实际需求对配置文件进行适当的修改,以确保RocketMQ集群能够...
2. 配置环境变量,如设置 `ROCKETMQ_HOME` 指向 RocketMQ 安装目录,以及 `NAMESRV_ADDR` 为 NameServer 的地址(默认为 `localhost:9876`)。 3. 在RocketMQ的主目录下,通过命令行启动NameServer(`\bin\mqnamesrv...
默认端口是8080,默认的用户密码是:admin/admin123,大家拿到jar包之后请修改配置文件里的密码,BOOT-INF/classes/users.properties; 直接使用java -jar rocketmq-dashboard-1.0.0.jar运行,可以使用nohup放到后台...
7. **广播消费**:所有消费者都会接收到每条消息,这与RocketMQ的发布/订阅机制不同,RocketMQ默认采用的是集群消费模式,即消息仅被一个消费者消费。 RocketMQ的消息持久化策略通常基于文件系统,但也可以配置为...
rocketTemplate使用 加配置 rocketmq: # nameServer 地址 name-server: 127.0.0.1:9876 # 访问通道类型 LOCAL、CLOUD access-channel: LOCAL producer: # 发送超时时长 默认3000 send-message-timeout: 3000 ...
这将启动Console的服务,你可以通过浏览器访问指定的端口(默认是8080)来查看和管理RocketMQ集群。 4. **核心概念** - **Topic**:消息的主题,是消息的分类,每个Topic可以被多个消费者组消费。 - **Queue**:...
本教程将详细讲解如何在Windows操作系统上进行RocketMQ的安装与配置,适合初学者快速入门。 一、 RocketMQ的组成部分 RocketMQ主要包含四个核心组件:NameServer、Broker、Producer和Consumer。NameServer是服务...
- HTTP静态服务器寻址(默认方式),客户端定期访问指定HTTP服务器,获取NameServer地址列表。 推荐使用HTTP静态服务器寻址方式,因其配置简单且支持NameServer集群热升级。 #### 3. 客户端配置与行为自定义 ...
在使用过程中,你可能还需要了解RocketMQ的相关配置,如Broker配置、NameServer配置、客户端配置等,这些都会影响到监控数据的准确性。同时,理解RocketMQ的内部原理,如消息存储结构、消息发送与消费机制,将有助于...
8. **系统配置**:对RocketMQ的一些全局配置进行修改,如命名空间、默认配置等。 RocketMQ Console的实现是基于war包,即"rocketmq-console.war",这是一个Web应用的归档文件,遵循Java Web应用的标准格式。这个war...
已经过mvn clean package -Dmaven.test.skip=true打包编译完成。 可以直接执行启动命令:java -jar rocketmq-console-ng-2.0.0.jar --...默认配置:server.port=8088、rocketmq.config.namesrvAddr=127.0.0.1:9876
可选参数如 `-r` 和 `-w` 分别用于设置 Topic 的可读和可写队列数,默认均为8。 **删除 Topic** 删除 Topic 使用 `deleteTopic` 命令,同样需要 `-n` (NameServer 地址)、`-c` (集群名称) 和 `-t` (Topic 名称) ...