(19)国家知识产权局
(12)发明 专利申请
(10)申请公布号
(43)申请公布日
(21)申请 号 202211094870.0
(22)申请日 2022.09.08
(71)申请人 深圳华锐分布式技 术股份有限公司
地址 518000 广东省深圳市福田区梅林街
道梅都社区中康路136号深圳新一代
产业园5栋2301
(72)发明人 张希 张卫 赵楠 李杰 肖东升
(74)专利代理 机构 深圳市精英创新知识产权代
理有限公司 4 4740
专利代理师 迟珊珊
(51)Int.Cl.
G06F 9/54(2006.01)
G06F 9/50(2006.01)
G06F 16/27(2019.01)
(54)发明名称
分布式系统时延度量方法、 装置、 设备及介
质
(57)摘要
本发明涉及大数据领域, 提供一种分布式系
统时延度量方法、 装置、 设备及介质, 能够在分布
式系统中, 利用每个应用程序内部预先构建的作
为独立进程运行的采样引擎及预先构建的以独
立程序的形式运行的时延度量组件进行时延度
量, 解决了无法在应用程序内部处理时延的问
题, 提高了时延度量的全面性, 并且, 独立运行的
采样引擎及时延度量组件在进行时延度量时不
会占用系统资源, 避免在进行时延度量时影响系
统的正常运行。
权利要求书3页 说明书16页 附图2页
CN 115168080 A
2022.10.11
CN 115168080 A
1.一种分布式系统时延度量方法, 其特 征在于, 所述分布式系统时延度量方法包括:
确定目标分布式系统中每 个应用程序上的采集 点;
调用每个应用程序内部预先构建的作为独立进程运行的采样引擎, 利用每个采样引擎
采集对应 应用程序上采集 点的时间戳, 并根据采集的时间戳 生成时间戳消息;
调用预先构建的以独立 程序的形式运行的时延度量组件;
将所述时间戳消息发送至所述时延度量组件;
获取所述时延度量组件中配置的待度量的至少一个时延 指标;
根据所述至少一个时延指标, 利用所述时延度量组件对所述时间戳消息进行处理, 得
到每个时延指标对应的时延数值;
利用所述 时延度量组件对每个时延指标对应的时延数值进行统计计算, 得到时延度量
结果, 并输出 所述时延度量结果。
2.如权利要求1所述的分布式系统时延度量方法, 其特征在于, 所述利用每个采样引擎
采集对应 应用程序上采集 点的时间戳, 并根据采集的时间戳 生成时间戳消息包括:
对于每个应用程序上的预设环节, 利用该应用程序对应的采样引擎遍历采集所述预设
环节所对应的每 个采集点的时间戳, 并获取每 个采集点的采集 点标识;
在采集每 个采集点中的首个采集 点时, 在消息 头中增加数据标识;
在采集每个采集点中除所述首个采集点外的其他采集点 时, 利用所述数据标识标记所
述其他采集点;
对每个采集点的采集点标识、 所述数据标识及每个采集点的时间戳进行打包, 生成该
应用程序对应的消息;
整合每个应用程序对应的消息, 得到所述时间戳消息 。
3.如权利要求2所述的分布式系统时延度量方法, 其特征在于, 所述根据 所述至少一个
时延指标, 利用所述时延度量组件对所述时间戳消息进行处理, 得到每个时延指标对应的
时延数值包括:
对于每个时延指标, 获取 所述时延 指标对应的数据标识;
从所述时间戳消息中获取 具有所述数据标识的采集 点作为目标采集 点;
确定每个目标采集 点的采集 点标识;
根据每个目标采集点的采集点标识确定所述时延指标对应的开始采集点及结束采集
点;
检测所述开始采集点对应的应用程序与所述结束采集点对应的应用程序是否部署于
同一服务器, 得到检测结果;
根据所述检测结果计算所述时延 指标对应的时延数值。
4.如权利要求3所述的分布式系统时延度量方法, 其特征在于, 所述根据 所述检测结果
计算每个时延指标对应的时延数值包括:
当所述检测结果显示所述开始采集点对应的应用程序与所述结束采集点对应的应用
程序部署于同一服务器时, 获取所述开始采集点的时间戳作为第一时间戳, 及获取所述结
束采集点的时间戳作为第二时间戳, 计算所述第二时间戳与所述第一时间戳的差, 得到所
述时延指标对应的时延数值; 或者
当所述检测结果显示所述开始采集点对应的应用程序与所述结束采集点对应的应用权 利 要 求 书 1/3 页
2
CN 115168080 A
2程序没有部署于同一服务器时, 获取所述开始采集点对应的应用程序与所述结束采集点对
应的应用程序的相对时间差, 获取所述开始采集点的时间戳作为第三时间戳, 获取所述结
束采集点的时间戳作为第四时间戳, 计算所述第四时间戳与所述第三时间戳的差作为第五
时间戳, 计算所述第五时间戳与所述相对时间差的差, 得到所述时延 指标对应的时延数值。
5.如权利要求2所述的分布式系统时延度量方法, 其特征在于, 所述输出所述 时延度量
结果包括以下一种或者多种方式的组合:
在所述时延度量组件的配置界面上实时显示所述时延度量结果;
将所述时延度量结果写入指定文件以供 数据重演;
响应于请求方向所述 时延度量组件的内嵌服务器发送的访问请求, 将所述 时延度量结
果转换为JSON字符串, 并将所述JSON字符串发送至所述请求方;
以所述数据标识为行, 以所述采集点标识及所述时间戳为列, 将所述时延度量结果存
储至时序数据库。
6.如权利要求1所述的分布式系统时延度量方法, 其特 征在于, 所述方法还 包括:
获取预先定义的轨迹, 其中, 所述轨迹包括多个采集点, 每个采集点具有相同的追踪标
识;
利用所述追踪标识对所述多个采集点进行追踪, 并记录数据在所述多个采集点间的扭
转情况;
当所述多个采集点中有采集点未被追踪到时, 将所述轨迹确定为异常轨迹, 并将未被
追踪到的采集 点确定为异常点;
存储所述异常轨 迹及所述异常点, 并发出异常告警提 示。
7.如权利要求5所述的分布式系统时延度量方法, 其特 征在于, 所述方法还 包括:
从所述时序数据库中获取 数据进行历史时延分析。
8.一种分布式系统时延度量装置, 其特 征在于, 所述分布式系统时延度量装置包括:
确定单元, 用于确定目标分布式系统中每 个应用程序上的采集 点;
调用单元, 用于调用每个应用程序内部预先构建的作为独立进程运行的采样引擎, 利
用每个采样引擎采集对应应用程序上采集点的时间戳, 并根据采集的时间戳生成时间戳消
息;
所述调用单 元, 还用于调用预 先构建的以独立 程序的形式运行的时延度量组件;
发送单元, 用于将所述时间戳消息发送至所述时延度量组件;
获取单元, 用于获取 所述时延度量组件中配置的待度量的至少一个时延 指标;
处理单元, 用于根据所述至少一个时延指标, 利用所述时延度量组件对所述时间戳消
息进行处 理, 得到每 个时延指标对应的时延数值;
计算单元, 用于利用所述时延度量组件对每个时延指标对应的时延数值进行统计计
算, 得到时延度量结果, 并输出 所述时延度量结果。
9.一种计算机设备, 其特 征在于, 所述计算机设备包括:
存储器, 存储至少一个指令; 及
处理器, 执行所述存储器 中存储的指令以实现如权利要求1至7中任意一项所述的分布
式系统时延度量方法。
10.一种计算机可读存储介质, 其特征在于: 所述计算机可读存储介质中存储有至少一权 利 要 求 书 2/3 页
3
CN 115168080 A
3
专利 分布式系统时延度量方法、装置、设备及介质
文档预览
中文文档
22 页
50 下载
1000 浏览
0 评论
0 收藏
3.0分
温馨提示:本文档共22页,可预览 3 页,如浏览全部内容或当前文档出现乱码,可开通会员下载原始文档
本文档由 SC 于 2024-02-18 22:33:03上传分享