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
2、广播消费(BROADCASTING) 1、CONSUME_FROM_LAST_OFFSET:默认策略, 2、CONSUME_FROM_FIRST_OFFSE
已经过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
默认端口是8080,默认的用户密码是:admin/admin123,大家拿到jar包之后请修改配置文件里的密码,BOOT-INF/classes/users.properties; 直接使用java -jar rocketmq-dashboard-1.0.0.jar运行,可以使用nohup放到后台...
rocketTemplate使用 加配置 rocketmq: # nameServer 地址 name-server: 127.0.0.1:9876 # 访问通道类型 LOCAL、CLOUD access-channel: LOCAL producer: # 发送超时时长 默认3000 send-message-timeout: 3000 ...
默认 描述 rocketmq.config.namesrvAddr 127.0.0.1:9876 代理群集的名称服务器地址 rocketmq.config.webTelemetryPath /指标 公开指标的路径 server.port 5557 收听Web界面和遥测的地址 rocketmq.config....
本机启动rocketmq后,直接使用java -jar启动该控制台程序,对rocketMq进行监控,单机版或者集群版都可以,启动后默认访问地址为localhost:8081,需要修改端口等,可以直接修改配置或传参,有什么问题也可以直接找我...
RocketMq支持任意延迟的延时消息方案 主要特性 支持任意延迟的延时消息,精确到秒,最长延迟时间为1年。 使用方法 配置broker.conf segmentScale=60 ##每个时间桶的时间范围,单位分钟,默认60,可选值0-60之间,...
错误原因:是因为内存不够,导致启动失败,原因:RocketMQ的配置默认是生产环境的配置,设置的jvm的内存 大 小值比较大,对于学习而言没有必要设置这么大,测试环境的内存往往都不是很大,所以需要调整默认值 解决...
分布式配置中心 端口:8848 访问地址 http://127.0.0.1:8848/nacos/ rocketmq console 控制台 端口:8180 http://localhost:8180 rocketmq No route info of this topic 原因 Broker禁止自动创建Topic,且用
springBoot的application.properties默认配置 Spring Boot示例代码 [Spring Boot中使用分布式应用限流实践] [Spring Boot中使用MongoDB增删改查] [Spring Boot中使用RocketMQ] [Spring Boot中使用Redis] [Spring...
- **服务限流降级**:默认支持 WebServlet、WebFlux, OpenFeign、RestTemplate、Spring Cloud Gateway, Zuul, Dubbo 和 RocketMQ 限流降级功能的接入,可以在运行时通过控制台实时修改限流降级规则,还支持查看限流...
包含了常用的MySQL、Redis、RocketMQ、Kafka、Elasticsearch、PostgreSQL、ZooKeeper、Nacos、配置参数详细说明。 这份文档是工作中整理的,现在分享出来,希望给用到的同行提供个参考。 后续如果有其它开发中间件的...
分布式配置管理:支持分布式系统中的外部化配置,配置更改时自动刷新。 消息驱动:基于 Spring Cloud Stream 为微服务应用构建消息驱动能力。 分布式事务:使用 @GlobalTransactional 注解, 高效并且对业务零侵入地...
使用Feign,只需要创建一个接口并注解,它具有可插拔的注解特性,可使用Feign 注解和JAX-RS注解,Feign支持可插拔的编码器和解码器,Feign默认集成了Ribbon,并和Eureka结合,默认实现了负载均衡的效果。 Feign ...
流控制和服务降级:默认情况下,支持HTTP服务的流控制。 您还可以使用注释来自定义流控制和服务降级规则。 规则可以动态更改。 服务注册和发现:可以注册服务,并且客户可以使用Spring托管的bean(自动集成功能区)...
采用两个版本第一个版本:springboot+mybatis+dubbo+rocketmq+mysql+redis等。第二个版 MySQL 是一款广受欢迎的开源关系型数据库管理系统(RDBMS),由瑞典MySQL AB公司开发,现隶属于美国甲骨文公司(Oracle)。自...
流控制和服务降级:默认情况下,支持HTTP服务的流控制。 您还可以使用注释来自定义流控制和服务降级规则。 规则可以动态更改。 服务注册和发现:可以注册服务,客户可以使用Spring托管的bean,自动集成功能区发现...