RocketMQ 内存优化

摘要:
RocketMQ(RocketMQ的官方文档)的默认内存使用率非常高。您可以通过更改mqbroker和mqnamesrv的配置来调整内存。有两个启动脚本,runbroker.sh和runserver.sh。找到runserver.sh和runbroker.sh,编辑并重新启动brokerJAVA_OPT=“${JAVA_OPT}-serverXms256m-Xmx256m-Xmn125m-XX:MetaspaceSize=128m-XX:MaxMetaspaceSize=320m”mqbroker和mqnamesrv的内存也可以调整。这两种配置也很重要。默认值为500m至1g。具体的文件配置是mqbroker.xml和mqnamesrv.xml。文件中的配置信息可以根据您的情况进行修改:50M50M30M30M30M需要注意的是mqbroker.xml和mqnamesrv.xml的内存不应超过runbroker.sh和runserver.sh的内存,否则,它将由于内存不足而崩溃。

rocketmq官方文档

RocketMQ 的默认内存占用非常高,通过更改mqbroker和mqnamesrv的配置可以调整内存。

有两个启动脚本,runbroker.sh 和runserver.sh。

找到runserver.sh和runbroker.sh,编辑,然后重新启动broker

JAVA_OPT=”${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m” 

mqbroker和mqnamesrv的内存也可以调整,这两项配置也很重要,默认是500m到1g。具体文件配置是mqbroker.xml和mqnamesrv.xml。文件里面的配置信息根据自己的情况修改:

<options>
         <-Xms200m></-Xms200m>
         <-Xmx200m></-Xmx200m>
         <-XX:NewSize>50M</-XX:NewSize>
         <-XX:MaxNewSize>50M</-XX:MaxNewSize>
         <-XX:PermSize>30M</-XX:PermSize>
         <-XX:MaxPermSize>30M</-XX:MaxPermSize>
 </options>
要注意的事情是mqbroker.xml和mqnamesrv.xml的内存不要超过runbroker.sh 和runserver.sh的内存,
不然会因为内存不够导致崩溃。




免责声明:文章转载自《RocketMQ 内存优化》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇如何判断Android设备是手机还是平板?2-k8s笔记-Kubernetes安装配置指南下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

RocketMQ的消息发送及消费

RocketMQ消息支持的模式: 消息支持的模式分为三种:NormalProducer(普通同步),消息异步发送,OneWay。 消息同步发送: 普通消息的发送和接收在前面已经演示过了,在前面的案例中是基于同步消息发送模式。也就是说消息发送出去后,producer会等到broker回应后才能继续发送下一个消息. 消息异步发送: 异步发送是指发送方发出数据后...

Docker部署RocketMQ踩坑记录

搜索镜像 可以选择在官方网站 hub.docker.com 上搜索镜像; 或者在命令行界面中执行命令 docker search rocketmq 搜索镜像; 以下表格是排名靠前的镜像对比: 镜像名称 下载量Downloads 收藏数Stars 最后维护时间 说明文档 foxiswho/rocketmq 500K+ 54 7个月前 有文档...

RocketMQ的安装配置:配置jdk环境,配置RocketMQ环境,配置集群环境,配置rocketmq-console

RocketMQ的安装配置 演示虚拟机环境:Centos64-1 (D:linuxMorecentos6_64) root / itcast : 固定IP 192.168.52.128 一,配置JDK环境 1,解压jdk到指定的目录 tar -xvf jdk-8u171-linux-x64.tar.gz -C /usr/local cd /usr/loca...

【RocketMQ】RocketMQ事务消息 Demo

RocketMQ为4.3.0版本(我这种写法4.2.0不行) 如果你之前用的其他版本,需要去修改下系统的环境变量 maven工程用到的jar包 <dependencies> <!-- RocketMQ --> <dependency> <groupId>org.apache.rocketmq<...

RocketMq 测试

向长辈致敬: 蠍: 卢兄  像RocketMq 这个怎么测试? 卢兄: 中间件的测试,要结合中间件的特点来测试 蠍: 特点什么意思   卢兄: 比如,这个工具是作为发布消息和消费消息的,具有解耦的特点 卢兄: 那么你可以通过做交易,去看他是否能够正常发布消息,消费消息 卢兄: 最重要的还是要去测试他的性能 蠍: 性能怎么测试 卢兄: 让其消息队列积累大量的...

RocketMQ源码 — 八、 RocketMQ消息重试

RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。 producer发送消息重试 producer在发送消息的时候如果发送失败了,RocketMQ会自动重试。 private SendResult sendDefaultImpl( Message msg, final Communication...