RocketMQ:broker配置说明

embedded/2024/9/17 19:06:20/ 标签: rocketmq
  1. RocketMQ broker配置项的简要说明:
  2. serverSelectorThreads: 服务器选择器线程数,用于处理网络请求。
  3. brokerRole: 指定Broker的角色,如`ASYNC_MASTER`表示异步主节点。
  4. serverSocketRcvBufSize: 服务器套接字接收缓冲区大小。
  5. osPageCacheBusyTimeOutMills: 操作系统页面缓存忙等待超时时间。
  6. shortPollingTimeMills: 短轮询超时时间。
  7. clientSocketRcvBufSize: 客户端套接字接收缓冲区大小。
  8. clusterTopicEnable: 是否启用集群主题。
  9. brokerTopicEnable: 是否启用Broker主题。
  10. autoCreateTopicEnable: 是否自动创建主题。
  11. maxErrorRateOfBloomFilter: 布隆过滤器的最大错误率。
  12. maxMsgsNumBatch: 批量发送消息的最大数量。
  13. cleanResourceInterval: 清理资源的时间间隔。
  14. commercialBaseCount: 商业基础计数。
  15. maxTransferCountOnMessageInMemory: 内存中消息的最大传输计数。
  16. brokerFastFailureEnable: 是否启用Broker快速失败。
  17. brokerClusterName: Broker集群名称。
  18. flushDiskType: 磁盘刷新类型。
  19. mappedFileSizeCommitLog: 提交日志映射文件大小。
  20. mappedFileSizeConsumeQueue: 消费队列映射文件大小。
  21. consumerFallbehindThreshold: 消费者落后阈值。
  22. autoCreateSubscriptionGroup: 是否自动创建订阅组。
  23. transientStorePoolEnable: 是否启用瞬时存储池。
  24. flushConsumerOffsetInterval: 刷新消费者偏移量的时间间隔。
  25. waitTimeMillsInHeartbeatQueue: 心跳队列中的等待时间。
  26. checkTransactionMessageEnable: 是否检查事务消息。
  27. diskMaxUsedSpaceRatio: 磁盘最大使用空间比例。
  28. cleanFileForciblyEnable: 是否强制清理文件。
  29. slaveReadEnable: 是否启用从节点读取。
  30. flushCommitLogLeastPages: 提交日志刷新时至少的页数。
  31. msgTraceTopicName: 消息跟踪主题名称。
  32. expectConsumerNumUseFilter: 预期使用过滤器的消费者数量。
  33. traceTopicEnable: 是否启用跟踪主题。
  34. useEpollNativeSelector: 是否使用Epoll原生选择器。
  35. enablePropertyFilter: 是否启用属性过滤器。
  36. messageDelayLevel: 消息延迟级别,包括不同的延迟时间。
  37. deleteCommitLogFilesInterval: 删除提交日志文件的时间间隔。
  38. brokerName: Broker名称。
  39. maxTransferBytesOnMessageInDisk: 磁盘上消息的最大传输字节数。
  40. listenPort: 监听端口。
  41. flushConsumeQueueLeastPages: 消费队列刷新时至少的页数。
  42. pullMessageThreadPoolNums: 拉取消息的线程池数量。
  43. useReentrantLockWhenPutMessage: 发送消息时是否使用可重入锁。
  44. flushIntervalConsumeQueue: 消费队列刷新间隔。
  45. sendThreadPoolQueueCapacity: 发送线程池队列容量。
  46. debugLockEnable: 是否启用调试锁。
  47. haHousekeepingInterval: 高可用维护间隔。
  48. diskFallRecorded: 是否记录磁盘故障。
  49. messageIndexEnable: 是否启用消息索引。
  50. clientAsyncSemaphoreValue: 客户端异步信号量值。
  51. clientCallbackExecutorThreads: 客户端回调执行器线程数。
  52. putMsgIndexHightWater: 发送消息索引高水位。
  53. sendMessageThreadPoolNums: 发送消息的线程池数量。
  54. clientManagerThreadPoolQueueCapacity: 客户端管理线程池队列容量。
  55. serverSocketSndBufSize: 服务器套接字发送缓冲区大小。
  56. maxDelayTime: 最大延迟时间。
  57. clientSocketSndBufSize: 客户端套接字发送缓冲区大小。
  58. namesrvAddr: 名称服务器地址。
  59. commercialEnable: 是否启用商业特性。
  60. maxHashSlotNum: 最大哈希槽位数量。
  61. heartbeatThreadPoolNums: 心跳线程池数量。
  62. transactionTimeOut: 事务超时时间。
  63. maxMessageSize: 最大消息大小。
  64. adminBrokerThreadPoolNums: 管理Broker线程池数量。
  65. defaultQueryMaxNum: 默认查询最大数量。
  66. forceRegister: 是否强制注册。
  67. maxTransferBytesOnMessageInMemory: 内存中消息的最大传输字节数。
  68. enableConsumeQueueExt: 是否启用消费队列扩展。
  69. longPollingEnable: 是否启用长轮询。
  70. serverWorkerThreads: 服务器工作线程数。
  71. messageIndexSafe: 是否安全的消息索引。
  72. deleteConsumeQueueFilesInterval: 删除消费队列文件的时间间隔。
  73. haSendHeartbeatInterval: 发送心跳的时间间隔。
  74. processReplyMessageThreadPoolNums: 处理回复消息的线程池数量。
  75. clientChannelMaxIdleTimeSeconds: 客户端通道最大空闲时间。
  76. filterSupportRetry: 是否支持过滤器重试。
  77. flushDelayOffsetInterval: 刷新延迟偏移量的时间间隔。
  78. duplicationEnable: 是否启用消息去重。
  79. replyThreadPoolQueueCapacity: 回复线程池队列容量。
  80. offsetCheckInSlave: 是否在从节点检查偏移量。
  81. clientCloseSocketIfTimeout: 超时时客户端是否关闭套接字。
  82. transientStorePoolSize: 瞬时存储池大小。
  83. waitTimeMillsInSendQueue: 发送队列中的等待时间。
  84. warmMapedFileEnable: 是否启用预热映射文件。
  85. endTransactionThreadPoolNums: 事务结束线程池数量。
  86. flushCommitLogTimed: 是否定时刷新提交日志。
  87. flushLeastPagesWhenWarmMapedFile: 预热映射文件时刷新的最少页数。
  88. clientWorkerThreads: 客户端工作线程数。
  89. storePathConsumeQueue: 消费队列存储路径。
  90. endTransactionPoolQueueCapacity: 事务结束池队列容量。
  91. registerNameServerPeriod: 注册名称服务器周期。
  92. registerBrokerTimeoutMills: 注册Broker超时时间。
  93. accessMessageInMemoryMaxRatio: 内存中访问消息的最大比例。
  94. highSpeedMode: 是否启用高速模式。
  95. transactionCheckMax: 事务检查最大次数。
  96. checkCRCOnRecover: 恢复时是否检查CRC。
  97. destroyMapedFileIntervalForcibly: 强制销毁映射文件的时间间隔。
  98. brokerIP2: 第二个Broker IP地址。
  99. brokerIP1: 第一个Broker IP地址。
  100. commitIntervalCommitLog: 提交日志的提交间隔。
  101. clientOnewaySemaphoreValue: 客户端单向信号量值。
  102. storeReplyMessageEnable: 是否启用存储回复消息。
  103. traceOn: 是否开启跟踪。
  104. clientManageThreadPoolNums: 客户端管理线程池数量。
  105. channelNotActiveInterval: 通道非活动间隔。
  106. mappedFileSizeConsumeQueueExt: 扩展消费队列映射文件大小。
  107. consumerManagerThreadPoolQueueCapacity: 消费者管理线程池队列容量。
  108. serverOnewaySemaphoreValue: 服务器单向信号量值。
  109. haListenPort: 高可用监听端口。
  110. enableCalcFilterBitMap: 是否启用计算过滤器位图。
  111. clientPooledByteBufAllocatorEnable: 是否启用客户端池化字节缓冲区分配器。
  112. aclEnable: 是否启用访问控制列表。
  113. storePathRootDir: 存储根目录路径。
  114. syncFlushTimeout: 同步刷新超时。
  115. rejectTransactionMessage: 是否拒绝
  116. commitCommitLogThoroughInterval: 提交日志彻底刷盘的时间间隔,单位为毫秒。这个参数设置Broker在多长时间内将消息的索引信息从内存刷新到磁盘。
  117. connectTimeoutMillis: 连接超时时间,单位为毫秒。这是客户端尝试连接Broker时的超时时间。
  118. queryThreadPoolQueueCapacity: 查询线程池队列的容量。这是Broker处理查询请求的线程池队列能容纳的最大请求数。
  119. regionId: 区域ID。这通常用于标识Broker或集群所在的地理位置或数据中心。
  120. consumerManageThreadPoolNums: 消费者管理线程池数量。这是Broker用于管理消费者信息的线程池大小。
  121. disableConsumeIfConsumerReadSlowly: 如果设置为true,当消费者读取消息变慢时,将禁用消费。
  122. flushConsumerOffsetHistoryInterval: 刷新消费者偏移量历史的时间间隔,单位为毫秒。
  123. fetchNamesrvAddrByAddressServer: 是否通过地址服务器获取NameServer地址。
  124. storePathCommitLog: 提交日志存储路径。这是Broker存储消息提交日志的文件系统路径。
  125. haTransferBatchSize: 高可用转移的批量大小。这是在主从切换时,从主Broker同步到从Broker的消息批量大小。
  126. compressedRegister: 是否压缩注册信息。
  127. commercialTransCount: 商业事务计数。
  128. transactionCheckInterval: 事务检查间隔,单位为毫秒。这是Broker检查消息事务状态的时间间隔。
  129. mappedFileSizeCommitLog: 提交日志映射文件的大小,单位为字节。
  130. startAcceptSendRequestTimeStamp: 开始接受发送请求的时间戳。
  131. serverPooledByteBufAllocatorEnable: 是否启用池化字节缓冲区分配器。
  132. serverAsyncSemaphoreValue: 服务器异步信号量值。
  133. heartbeatThreadPoolQueueCapacity: 心跳线程池队列容量。
  134. waitTimeMillsInTransactionQueue: 事务队列中的等待时间,单位为毫秒。
  135. deleteWhen: 删除策略,通常配合时间使用,如每天的“04”点。
  136. bitMapLengthConsumeQueueExt: 消费队列扩展位图的长度。
  137. fastFailIfNoBufferInStorePool: 如果存储池中没有缓冲区,则快速失败。
  138. defaultTopicQueueNums: 默认主题的队列数量。
  139. notifyConsumerIdsChangedEnable: 是否通知消费者ID变化。
  140. flushConsumeQueueThoroughInterval: 彻底刷新消费队列的时间间隔,单位为毫秒。
  141. fileReservedTime: 文件保留时间,单位为小时。
  142. brokerPermission: Broker权限。
  143. transferMsgByHeap: 是否通过堆内存传输消息。
  144. pullThreadPoolQueueCapacity: 拉取线程池队列的容量。
  145. brokerId: Broker的ID。
  146. maxTransferCountOnMessageInDisk: 磁盘上消息的最大传输计数。

http://www.ppmy.cn/embedded/41642.html

相关文章

2024 Google I/O Android 相关内容汇总

2024 Google I/O Android 相关内容汇总 本次 Google I/O 的核心虽然是 AI ,但是 Android 也是作为主要议题出现, Android 部分可以简单分为产品和开发相关内容,接下来主要介绍这两部分的相关更新。 重点开始开发相关,内容不少 产…

MySQL——变量的定义与使用

新建链接,自带world数据库,里面自带city表格。 DQL # MySQL变量的定义与使用 #1、不允许数字作为开头 #2、只能用_或$符号,不允许使用其他符号 #3、不允许使用关键字或保留字 set userName小可爱; select userName; #标识符只影响当前查询#…

播放视频wenjian

方法一&#xff1a; xml文件 activity_next.xml <?xml version"1.0" encoding"utf-8"?> <LinearLayout xmlns:android"http://schemas.android.com/apk/res/android"android:layout_width"match_parent"android:layout_h…

怎么截图公式识别?方法简单介绍

怎么截图公式识别&#xff1f;随着科技的不断发展&#xff0c;人们对于高效、便捷的工作方式的需求日益增加。在学术、教育以及科技研发等领域&#xff0c;数学公式是不可或缺的一部分。然而&#xff0c;手动输入公式往往费时费力&#xff0c;且容易出错。因此&#xff0c;截图…

c++20 shared_ptr、unique_ptr、weak_ptr、enable_shared_from_this

正如《Professional C,Fifth Edition》所说: 1.程序员忘记在合适时间释放内存delete导致内存泄露。 2.代码异常后面的代码delete没有执行到导致内存泄露。 3.释放内存的代码过于臃肿。 4.多个释放内存点delete代码过于重复。 5.多个地方要共享内存。 unique_ptr:唯一拥有…

万物生长大会 | 创邻科技再登杭州准独角兽榜单

近日&#xff0c;由民建中央、中国科协指导&#xff0c;民建浙江省委会、中国投资发展促进会联合办的第八届万物生长大会在杭州举办。 在这场创新创业领域一年一度的盛会上&#xff0c;杭州市创业投资协会联合微链共同发布《2024杭州独角兽&准独角兽企业榜单》。榜单显示&…

Flutter 解决App页面软键盘遮挡住输入框底部区域内容

问题现状 有时候我们需要在唤起键盘的时候&#xff0c;输入框不是刚好在键盘上面&#xff0c;比如输入框下面还有按钮。像这样&#xff08;最终UI效果截图示例&#xff09;&#xff1a; &#xff08;当然这个截图比较简单&#xff0c;因为他头部内容不多&#xff0c;键盘升起可…

Spring MVC(七) 异常处理

在实际的开发中&#xff0c;不管做什么操作&#xff0c;都不可避免会遇到各种可预知的、不可预知的异常需要处理。每个过程都单独处理异常&#xff0c;系统的代码耦合度高&#xff0c;工作量大且不好统一&#xff0c;维护的工作量也很大。如果能够做到统一的处理&#xff0c;将…

Redis教程(四):Redis中String类型的常用命令

String操作&#xff1a; 插入一个key为name&#xff0c;值为apple的数据 set name apple 插入的数据中如果有空格的数据&#xff0c;请用""双引号&#xff0c;否则会报错&#xff01; set name "hello world!" 如果key为name的数据不存在&#xff0c;…

Android Studio连接MySQL8.0

【序言】 移动平台这个课程要做一个app的课设&#xff0c;我打算后期增加功能改成毕设&#xff0c;就想要使用MySQL来作为数据库&#xff0c;相对于SQLlite来说&#xff0c;我更熟悉MySQL一点。 【遇到的问题】 一直无法连接上数据库&#xff0c;开始的时候查了很多资料&#…

Android Studio开发之路(十二)image、byte[]、mat、Bitmap几种格式互转合集

一、知识点 Camerax中的 imageCapture用例默认的image格式是JPEG, 而ImageAnalysis用例默认的image格式是YUV_420_888. 二、ImageAnalysis用例中ImageProxy转mat YUV转Mat 三、imageCapture中image专byte[] 如下边代码&#xff0c; //拍照&#xff0c;保存到内存 private…

CSRF 攻击实验:更改请求方式绕过验证

前言 CSRF&#xff08;Cross-Site Request Forgery&#xff09;&#xff0c;也称为XSRF&#xff0c;是一种安全漏洞&#xff0c;攻击者通过欺骗用户在受信任网站上执行非自愿的操作&#xff0c;以实现未经授权的请求。 CSRF攻击利用了网站对用户提交的请求缺乏充分验证和防范…

【全开源】JAVA语聊大厅语音聊天APP系统源码

语聊大厅语音聊天源码&#xff1a;打造专属的语音社交平台 核心功能 多人语音聊天&#xff1a;支持多人同时在线语音聊天&#xff0c;用户可以创建或加入不同的聊天室&#xff0c;与好友或陌生人进行实时互动。语音转文字&#xff1a;提供语音转文字功能&#xff0c;方便用户…

B某S 岗位采集 __zp_stoken__参数详细解析,秒了~

文章目录 分析必要参数抓包目标网址寻找必要参数 -- curl 尝试法copy curl复制代码直接运行根据网站headers和cookies逐一排查headers参数排除cookies参数排除 参数定位(hook)找堆栈ts 和 seednew ABC().z 结果&#xff1a; 目标网址&#xff1a; aHR0cHM6Ly93d3cuemhpcGluLmNv…

[数据结构]红黑树的原理及其实现

文章目录 红黑树的特性红黑树的时间复杂度推导&#xff1a;结论红黑树与AVL树比较 红黑树的插入红黑树的节点定义调整策略思考情况2&#xff1a;思考情况3&#xff1a; 代码实现myBTRee.htest.cpp 红黑树的特性 红黑树最常用的平衡二叉搜索树。跟AVL树不同的是&#xff0c;红黑…

Java并发编程:学习路线图

文章目录 一、操作系统内核原理1、进程管理详解2、内存管理详解3、IO输入输出系统详解4、进程间通信机制详解5、网络通信原理剖析 二、Java内存模型三、并发集合1、Map&#xff08;1&#xff09;ConcurrentHashMap&#xff08;2&#xff09;ConcurrentSkipListMap 2、List&…

数字化校园在落地前会遇到哪些阻碍?

信息化年代开展的一起也带动了数字化学校的开展速度。但想要数字化学校继续开展&#xff0c;就要打破现有的开展阻止&#xff0c;完成可继续的开展。接下来咱们来简略了解一下其遇到了哪些开展约束。 首要第一层阻止便是教师和学生关于高新科技的承受程度。教师的杰出的信息素质…

Prosys OPC UA Simulation Server工程文件备份方法

Prosys OPC UA Simulation Server是一款免费的OPC UA服务器仿真软件&#xff0c;具体的使用和下载参考官网&#xff1a; Prosys OPC - OPC UA Simulation Server Downloads 他的免费版本不提供工程文件的备份、导入导出功能&#xff0c;每次退出时保存。如果需要工程备份&a…

算法详解——回溯法

一、回溯法概述——问题背景 回溯法是一种解决约束满足问题的方法&#xff0c;特别适用于解决组合问题、搜索优化问题等。它通过逐步构建候选解决方案并且在这个解决方案不再可能满足约束或条件时进行剪枝和回溯。具体来说&#xff0c;回溯法可以应用于以下类型的问题&#xff…

产品推荐 | 基于 AMD Alveo V80 数据中心的FPGA加速器卡

1、产品概述 Alveo V80 卡采用强大的 AMD Versal™ XCV80 HBM 系列自适应 SoC&#xff0c;将高带宽存储器 (HBM2e) 和 800 Gb/s 高速网络封装到全高、 长外形尺寸的双插槽卡中&#xff0c;专为在本地服务器或云中部署而设计。 V80 加速器经过优化&#xff0c;可通过 AMD Vers…