温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

如何排查RocketMQ一次消费性能问题

发布时间:2021-11-18 09:43:42 阅读:254 作者:小新 栏目:大数据
开发者测试专用服务器限时活动,0元免费领,库存有限,领完即止! 点击查看>>

这篇文章将为大家详细讲解有关如何排查RocketMQ一次消费性能问题,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。

一、需求描述

在容器推广中,为了测试容器的性能,需要消息SDK与ECS上在发送和消费的性能对比;在对比消费性能时,发现容器中的消费性能居然是ECS的2倍。容器并发消费的20个线程TPS在3万左右,ECS中20个消费线程TPS在1.5万左右。 

问题:配置均采用8C16G,容器中的性能几乎是ECS的两倍,这不科学,事出反常必有妖。

二、问题分析1.tcpdump网络情况

tcpdump显示在消费的机器存在频繁的域名解析过程;10.x.x.185向DNS服务器100.x.x.136.domain和10.x.x.138.domain请求解析。而10.x.x.185这台机器又是消息发送者的机器IP,测试的发送和消费分别部署在两台机器上。

问题:消费时为何会有消息发送方的IP呢?而且该IP还不断进行域名解析。

如何排查RocketMQ一次消费性能问题

2.查看消费线程堆栈

如何排查RocketMQ一次消费性能问题

3.消费代码定位

在消费时有通过MessageExt.bornHost.getBornHostNameString获取消费这信息;问题由此引起。

public class MessageExt extends Message {    private static final long serialVersionUID = 5720810158625748049L;    private int queueId;    private int storeSize;    private long queueOffset;    private int sysFlag;    private long bornTimestamp;    private SocketAddress bornHost;    private long storeTimestamp;    private SocketAddress storeHost;    private String msgId;    private long commitLogOffset;    private int bodyCRC;    private int reconsumeTimes;    private long preparedTransactionOffset;}

调用GetBornHostNameString获取HostName时会根据IP反查DNS服务器;

InetSocketAddress inetSocketAddress = (InetSocketAddress)this.bornHost;return inetSocketAddress.getAddress().getHostName();

三、后记

将getBornHostNameString注释或者直接返回IP,ECS的消费性能基本稳定在3万左右。

备注:感谢公司测试同学魏华和容器专家陶汉辉对性能一遍又一遍的测试和排查。

关于“如何排查RocketMQ一次消费性能问题”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。

亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

原文链接:https://my.oschina.net/u/4226611/blog/4352880

AI

开发者交流群×