RocketMQ:broker配置说明

  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.mzph.cn/pingmian/12436.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C++面试问题精选 0513

1、有一个类包含static成员变量,并且这个类的构造函数中包含一个死循环,可以删除 main 函数吗? 在C++中,如果你有一个类包含static成员变量,并且这个类的构造函数中包含一个死循环(即无限循环),那么这通常不是一个好的设计选择,因为这会导致任何尝试创建该类实例的操…

Dato for Mac v5.2.11激活版:掌握时间,掌控生活

在忙碌的生活中,您是否常常觉得时间不够用?Dato for Mac,您的时间管理专家,助您轻松掌控每一天。清晰的日历视图、个性化的提醒功能,让您的日程安排井井有条。无论是工作还是生活,Dato for Mac都能成为您的…

linux命令行启动一个php进程, 如何监控 ,崩溃报警通知?

在Linux环境中,监控PHP进程并在其崩溃时发送通知可以通过多种方式实现,包括使用shell脚本结合监控工具和通知服务。下面我将提供一个简单的方案,使用systemd服务来管理PHP进程,并通过邮件发送崩溃通知。 第1步:创建一…

IT行业的人才培养与教育

你眼中的IT行业现状与未来趋势 随着技术的不断进步,IT行业已成为推动全球经济和社会发展的关键力量。从云计算、大数据、人工智能到物联网、5G通信和区块链,这些技术正在重塑我们的生活和工作方式。你眼中IT行业的现状及未来发展趋势是怎么样的&#xf…

AI图像生成-调整

一、两张图画风不相似 2、在两张图的共同输出口新添加一个空白正面提示词板块和条件合并板块 二、预处理插件(提取人物姿态) 1、新建节点-》ControlNet预处理器-》面部与姿态-》Openpose姿态预处理器 2、添加上传图片板块与预览图片板块 3、提取姿态 右…

vue下载文件,获取header头文件名乱码,下载文件名有下划线的解决

后台以数据流将文件返回,将文件名放在header头里,是中文名,有乱码,如图 访问网络使用的是axios,在 // 响应拦截器 service.interceptors.response.use((res) > {........ if (res.config.responseType blob) {//文…

【Linux取经路】进程通信之匿名管道

文章目录 一、进程间通信介绍1.1 进程间通信是什么?1.2 进程间通信的目的1.3 进程通信该如何实现 二、管道2.1 匿名管道2.1.1 站在文件描述符角度深入理解管道2.1.2 接口使用2.1.3 PIPE_BUFFER 和 Pipe capacity2.1.4 管道中的四种情况2.1.5 管道特征总结 2.2 匿名管…

只用了三天就入门了Vue3?

"真的我学Vue3,只是为了完成JAVA课设" 环境配置 使用Vue3要去先下载Node.js。 就像用Python离不开pip包管理器一样。 Node.js — Run JavaScript Everywhere (nodejs.org) 下完Node.js去学习怎么使用npm包管理器,放心你只需要学一些基础的…

【MARIE】嵌入式系统设计半期报告:MARIE模拟器的使用

1.模拟器介绍 1.1 体系结构 MARIE (Machine Architecture that is Really Intuitive and Easy) 是一种机器架构和汇编语言。发布者还为机器提供了一组用 Java 编写的模拟器程序。MARIE.js 是 MARIE 的 JavaScript 版本实现。它旨在尽可能忠实于原始 Ja…

Spring-Cloud-OpenFeign源码解析-03-FeignClientFactoryBean

在Spring-Cloud-OpenFeign源码解析-02-OpenFeign自动装配分析到OpenFeign 接口代理对象的创建是通过构建成一个 FeignClientFactoryBean 对象,并最后注入到容器中的,那么这个FeignClientFactoryBean是如何实现代理对象创建的呢? FactoryBean…

基于EKF扩展卡尔曼滤波的一阶环形倒立摆控制系统simulink建模与仿真

目录 1.课题概述 2.系统仿真结果 3.核心程序与模型 4.系统原理简介 5.完整工程文件 1.课题概述 基于EKF扩展卡尔曼滤波的一阶环形倒立摆控制系统simulink建模与仿真。基于扩展卡尔曼滤波(Extended Kalman Filter, EKF)的一阶环形倒立摆控制系统&…

docker学习和常用命令

参考视频:05.Docker基础-常见命令_哔哩哔哩_bilibili 镜像仓库datahub docker命令官方文档:docker exec | Docker Docs systemtrl docker 启动docker systemtrl start docker停止docker systemtrl stop docker重启docker systemtrl restart docker设…

【并发程序设计】4. exec函数族

4.exec函数族 exec函数族是一组用于在进程中启动另一个程序来替换当前进程的函数。 exec函数族主要用于在当前进程内部执行一个新的程序,而不会创建新的进程。 子进程调用exec函数,族父进程不受影响。进程当前内容被指定的程序替换,但进程…

【YOLOV5 入门】——Gradio搭建Web GUI

引入:上节搭建的UI可视化界面只能以运行程序弹出窗口的形式运行,不能在网页Web中使用,本次代码将会非常少! 一、Gradio简介与安装 Gradio 是一个用于构建机器学习模型演示界面和Web应用的开源库。提供了简单易用的界面&#xff0…

云端的艺术革命:云渲染如何重塑动画与视觉特效产业

在 2019 年,乔恩费儒(Jon Favreau)决定重拍迪士尼的经典电影《狮子王》。他的创新构想是以真实动物为模型,在非洲草原上拍摄,由真实动物“出演”的辛巴和其他角色,随后通过配音赋予它们生命。 为了实现这一…

janus源码分析(1)--代码结构整理

基础说明 janus官网 https://janus.conf.meetecho.com/index.html janus源码地址 https://github.com/meetecho/janus-gateway 编译及部署参考 https://pro-hnb.blog.csdn.net/article/details/137730389?spm1001.2014.3001.5502 https://pro-hnb.blog.csdn.net/article/deta…

flutter常用的指令(签名、adb、shell、keytool、scrcpy)

flutter常用的指令(签名、adb、shell、keytool、scrcpy) run 指定main_dev.dart debug flutter run -t lib/main_dev.dart --debug指定main_dev.dart release flutter run -t lib/main_dev.dart --release插件用到非空安全情况 flutter run -t lib/main_dev.dart --releas…

Linux mtoolstest命令教程:如何测试和显示mtools配置(附实例详解和注意事项)

Linux mtoolstest命令介绍 mtoolstest是一个用于测试mtools配置文件的命令。只需键入mtoolstest即可调用它,无需任何参数。mtoolstest会读取mtools配置文件,并将累积配置打印到标准输出。输出可以作为配置文件本身使用。 Linux mtoolstest命令适用的Li…

【Python探索之旅】列表

目录 特点 入门 访问元素 新增元素 修改元素 插入元素 删除元素 完结撒花 前言 在Python中,列表(List)是最常用的数据结构之一,类似于其他语言,如Java,与其不同啊Python中不需要声明数据类型。它提供了一种灵活且高效的方式…

Linux-线程

目录 1. 线程概念 2. 线程vs进程 3. 线程的优缺点 4. 线程创建 4.1 pthread_create 4.2 pthread_self 5. 线程终止 5.1 return 5.2 pthread_exit 5.3 pthread_cancel 6. 线程等待 7. 线程分离 1. 线程概念 线程:轻量级进程,在进程内部执行&a…