业务背景

最近公司在做物联网相关项目调试过程发现好玩的bug
首先一个数据采集场景plc采集数据链路
kepServerkepserver IOT gateway) -> emqx查看日志)-> iot服务 -> 业务处理发送Kafka -> flink消费 -> websocket推送告警...
【整个链路还是比较长的】

整个过程是这样的,

现象

调试真实点位

率先发现改变设备运行状态plc点位值,设备运行状态或者告警产生比较慢【延迟比较多】

分析

查看现有日志初步分析发现消息生产到推送到Kafka有10s延迟

初步分析

最终定位问题IOT接受消息延迟,IOT框架内Listener监听消息延迟 orz初步定位,实际上是错的

后续,又将IOT监听MQTT消息初打日志,发送Kafka消息耗时时间打印

对比多个关键节点时间,发现两个延迟点

  1. kepServer数据发生变化的时间和EMQX接收到kepServer推送的消息的时间对比:发现有个5-8s的延迟【kepServer->EMQX
  2. Kafka发送消息到成功回调有个固定2s左右的延迟【Kafka

发现问题解决问题更难,多打日志,好定位问题,养成习惯

最终解决

链路排查

  1. kepServer

  2. kafka

    原本这个时间参数刚好设置就是2000ms,与上述刚好固定两秒延迟相符,偶尔有无延迟现象说明该消息刚发送就到了2s的频次直接就发生了无延迟

所有都改完之后,基本延迟在1s左右,由于链路本身就比较长,这个时间还是可以接受的。yes

原文地址:https://blog.csdn.net/qq_43417581/article/details/134791169

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任

如若转载,请注明出处:http://www.7code.cn/show_42858.html

如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱suwngjj01@126.com进行投诉反馈,一经查实,立即删除

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注