时延统计方法、装置、系统及存储介质

摘要

本申请实施例公开了一种时延统计方法、装置、系统及存储介质，其中方法包括：获取输入至所述分布式系统的目标数据的数据标识；采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点；根据所述数据标识、采集点标识和时间戳生成时间戳信息；读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则；基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。该时延统计方法可以实现分布式系统的时延以及吞吐量的自动采集、测量和统计。

权利要求

1.一种时延统计方法，应用于分布式系统，其特征在于，所述方法包括：获取输入至所述分布式系统的目标数据的数据标识；

采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点；

根据所述数据标识、采集点标识和时间戳生成时间戳信息；

读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则；

基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。

2.根据权利要求1所述的时延统计方法，其特征在于，所述获取输入至所述分布式系统的目标数据的数据标识之前，包括：根据预设筛选规则筛选出输入至所述分布式系统的样本数据；

将所述样本数据设为目标数据，并在所述目标数据的消息头中添加数据标识。

3.根据权利要求2所述的时延统计方法，其特征在于，所述根据预设筛选规则筛选出输入至所述分布式系统的样本数据；

根据预设计数器对输入至所述分布式系统的数据进行计数；

判断所述计数对应的计数数量是否满足预设条件；

若所述计数数量满足所述预设条件，则确定所述计数数量对应的数据为输入所述分布式系统的样本数据。

4.根据权利要求1所述的时延统计方法，其特征在于，所述基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延，包括：获取所述时延指标统计规则中的时延指标计算公式；

根据所述时延指标计算公式计算所述时间戳信息对应的时延指标。

5.根据权利要求1所述的时延统计方法，其特征在于，所述根据所述数据标识、采集点标识和时间戳生成时间戳信息，包括：根据所述数据标识和采集点标识将所述时间戳对应保存在预设数据表中以生成所述时间戳信息表。

6.根据权利要求1所述的时延统计方法，其特征在于，所述基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延之后，还包括：根据预设输出规则输出统计所述分布式系统的时延对应的统计结果。

7.根据权利要求6所述的时延统计方法，其特征在于，所述根据预设输出规则输出统计所述分布式系统的时延对应的统计结果，包括：接收Http访问请求，根据所述Http访问请求将所述统计结果以Json字符串形式进行返回。

8.一种时延统计装置，其特征在于，包括：

标识获取单元，用于获取输入至所述分布式系统的目标数据的数据标识；

信息采集单元，用于采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点；

信息生成单元，用于根据所述数据标识、采集点标识和时间戳生成时间戳信息；

文件读取单元，用于读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则；

时延统计单元，用于基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。

9.一种分布式系统，其特征在于，包括计算机设备，所述计算机设备包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现如权利要求1至7中任意一项所述方法的步骤。

10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质存储有计算机程序，所述计算机程序被处理器执行时使所述处理器执行如权利要求1至7任意一项所述方法的步骤。

说明书

时延统计方法、装置、系统及存储介质

技术领域

[0001] 本申请涉及分布式系统技术领域，尤其涉及一种时延统计方法、装置、系统及存储介质。

背景技术

[0002] 目前，分布式系统因可以解决中后台IT系统业务承载量问题而发展迅速，分布式系统指部署在多台主机(节点，即服务器)上的软件程序协同工作实现特定功能的软件系统。时延是分布式系统的重要性能指标之一。目前，分布式系统没有通用的精确地时延测量和统计方法，通常采用网络抓包、日志分析等方式测量时延。网络抓包方式只能测量网络传输的时延，不能测量程序内部处理时延；同时，网络抓包和日志分析等方式需占用分布式服务的本地系统资源(CPU、内存、硬盘等)，处理能力有限，在高吞吐压力下无法做到每笔消息的时延的实时测量和统计。因此，有必要提供一种时延统计方法以解决上述问题。

发明内容

[0003] 本申请提供了一种时延统计方法、装置、系统及存储介质，以便准确及时地统计分布式系统的时延。

[0004] 本申请提供了一种时延统计方法，其包括：

[0005] 获取输入至所述分布式系统的目标数据的数据标识；

[0006] 采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点；

[0007] 根据所述数据标识、采集点标识和时间戳生成时间戳信息；

[0008] 读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则；

[0009] 基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。

[0010] 本申请提供了一种时延统计装置，其包括：

[0011] 标识获取单元，用于获取输入至所述分布式系统的目标数据的数据标识；

[0012] 信息采集单元，用于采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点；

[0013] 信息生成单元，用于根据所述数据标识、采集点标识和时间戳生成时间戳信息；

[0014] 文件读取单元，用于读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则；

[0015] 时延统计单元，用于基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。

[0016] 本申请还提供了一种分布式系统，其包括多台计算机设备，所述计算机设备包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现本申请提供的任意一项所述的时延统计方法的步骤。

[0017] 本申请还提供了一种计算机存储介质，其中所述计算机存储介质存储有计算机程序，所述计算机程序被处理器执行时使所述处理器执行本申请提供的任意实施例所述的时延统计方法的步骤。

[0018] 本申请实施例提供了时延统计方法、装置、系统及存储介质，通过获取输入至所述分布式系统的目标数据的数据标识；采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点；根据所述数据标识、采集点标识和时间戳生成时间戳信息；读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则；基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。该时延统计方法可以实现分布式系统的时延以及吞吐量的自动采集、测量和统计。

附图说明

[0019] 为了更清楚地说明本申请实施例技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图是本申请的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。

[0020] 图1是本申请实施例提供的一种分布式系统的结构示意框图；

[0021] 图2是本申请一实施例提供的一种时延统计方法的示意流程图；

[0022] 图3是图2中时延统计方法的子步骤示意流程图；

[0023] 图4是本申请实施例提供的一种时延统计方法的应用场景示意图；

[0024] 图5是本申请另一实施例提供的一种时延统计方法的示意流程图；

[0025] 图6是图5中时延统计方法的子步骤示意流程图；

[0026] 图7是本申请一实施例提供的一种时延统计装置的示意性框图；

[0027] 图8是本申请一实施例提供的一种计算机设备的示意性框图。

具体实施方式

[0028] 下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本申请一部分实施例，而不是全部的实施例。基于本申请中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本申请保护的范围。

[0029] 应当理解，当在本说明书和所附权利要求书中使用时，术语“包括”和“包含”指示所描述特征、整体、步骤、操作、元素和/或组件的存在，但并不排除一个或多个其它特征、整体、步骤、操作、元素、组件和/或其集合的存在或添加。

[0030] 还应当理解，在此本申请说明书中所使用的术语仅仅是出于描述特定实施例的目的而并不意在限制本申请。如在本申请说明书和所附权利要求书中所使用的那样，除非上下文清楚地指明其它情况，否则单数形式的“一”、“一个”及“该”意在包括复数形式。

[0031] 还应当进一步理解，在本申请说明书和所附权利要求书中使用的术语“和/或”是指相关联列出的项中的一个或多个的任何组合以及所有可能组合，并且包括这些组合。

[0032] 本申请实施例提供了一种时延统计方法、装置、分布式系统和存储介质。

[0033] 为了便于理解，先对本申请实施例的时延统计方法所适用的分布式系统的组成进行介绍。如图1所示，该分布式系统包括多台服务器，也称为主机。其中，服务器可以是独立的服务器，也可以是多个服务器组成的服务器集群。该分布式系统包括部署在多台主机上的应用程序(软件程序)协同工作实现特定功能的软件系统。

[0034] 具体地，在分布式系统中实现该时延统计方法包括两类软件实体共同完成，两类软件实体包括时延采集模块和时延测量组件，其中该时延采集模块部署在每个主机的应用程序中，该时延测量组件部署在其中一个主机中，或者是单独的服务器中。其中时延测量组件可根据采集点做负载分割，根据采集点的数据部署多个时延测量组件，采集点把控时延采集模块，多个时延测量组件分别用于接收不同的采集点发送过来的数据，该数据包括时间戳信息，通过该方式提高时延的采集速度。

[0035] 请参阅图2，图2是本申请一实施例提供的一种时延统计方法的示意流程图。该时延统计方法应用于上述的分布式系统，如图1所示，该时延统计方法包括步骤S101～S105。

[0036] S101、获取输入至所述分布式系统的目标数据的数据标识。

[0037] 具体地，所述时延采集模块获取输入至所述分布式系统的目标数据的数据标识。目标数据是指从外部输入到所述分布式系统的数据，该数据需要经过所述分布式系统的主机中的应用程序进行加工处理，在各个应用程序之间流转，并有可能产生对外输出。其中每个目标数据均包括一个数据标识，比如用D1、D2...Dn进行标识，用于识别该目标数据，当然也可以用其他数据标识进行标识，在此不做限定。

[0038] S102、采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点。

[0039] 具体地，所述时延采集模块采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识。其中所述预设采集点为预先在所述应用程序设置多个时间采集点，并对该时间采集点进行标识，比如应用程序1包括100个时间采集点，其对应的采集点标识分别为T1、T2...T100。当然也可以其他方式进行标识，在此不做限定。

[0040] S103、根据所述数据标识、采集点标识和时间戳生成时间戳信息。

[0041] 具体地，所述时延采集模块根据所述数据标识、采集点标识和时间戳生成时间戳信息，具体是将所述数据标识、采集点标识和时间戳一同打包为一个时间戳信息，并将该时间戳信息发送至该时延测量组件。所述时间戳信息比如为：D1 T1 9:30:00.123456。其中，D1为数据标识，T1为采集点标识，9:30:00.123456为时间戳。

[0042] 在一实施例中，所述将该时间戳信息发送至该时延测量组件之后，还包括：所述时延测量组件接收到所述时间戳信息后根据所述数据标识和采集点标识将所述时间戳信息中的时间戳对应保存在预设数据表中以生成所述时间戳信息表。

[0043] 具体地，所述时延测量组件根据所述数据标识和采集点标识将所述时间戳按照数据标识和采集点标识对应保存在预设数据表中以生成时间戳信息表，该时间戳信息表具体如表1所示，更便于数据读取。

[0044] 表1为时间戳信息表

[0045]   T1 T2 T3 T4D1 9:30:00.123456 9:30:00.123478 9:30:00.126000 9:30:00.126456
D2 9:30:00.234567 9:30:00.234678 9:30:00.236000 9:30:00.236678
D3 …… …… …… ……
D4 …… …… …… ……

[0046] S104、读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则。

[0047] 具体地，所述时延测量组件读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则。其中所述时延指标统计规则为预先配置在服务器中，可预先配置在所述时延测量组件位于的服务器中。所述时延指标统计规则根据时间戳信息对所述分布式系统的统计规则。

[0048] 譬如，所述时延测量组件持续地根据时间戳信息按照预设统计规则，比如将时间戳信息中的结束点时间戳和开始点时间戳做减法运算以得到该数据的时延指标数值。当然也可以采用其他预设规则计算出不同数据的各项时延指标数值。此外，所述时延测量组件可按指定周期统计该周期内各项时延指标值，包括平均值、最小值、最大值、50％、90％、95％、99％等百分位值，同时也统计该指定周期内各时延采集点上的吞吐率。

[0049] S105、基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。

[0050] 具体地，所述时延测量组件基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。该时延指标统计规则包括多个时延指标计算公式，比如，结束点时间戳和开始点时间戳做减法运算的时延指标，当然也可以包括平均值、最小值、最大值、50％、90％、95％、99％等百分位值。

[0051] 基于此，步骤S105包括S1051和S105b。如图3所示，S105a、获取所述时延指标统计规则中的时延指标计算公式；S105b、根据所述时延指标计算公式计算所述时间戳信息对应的时延指标。由此可以计算各种时延指标数据。

[0052] 在一实施例中，所述时间戳信息表包括时延指标位，在所述根据所述时延指标计算公式计算所述时间戳信息对应的时延指标之后，还包括：将所述时延指标索引至所述时间戳信息表中的时延指标位以将所述时延指标保存在所述时间戳信息表。以便后续查看该时延指标，或者使用该时延指标做画图展示。

[0053] 具体地，将所述时延指标保存在所述时间戳信息表，表示为信息指标表，如表2所示。

[0054] 表2为信息指标表

[0055]

[0056] 请参阅图4，图4是本申请实施例提供的一种时延统计方法的应用场景示意图。图4是分布式系统其中一个主机的场景示意图，所述主机中包括应用程序，所述时延采集模板部署在应用程序中，所述时延测量组件部署服务器中单独运行，在外部将目标数据输入至分布式系统的应用程序时，时延采集模板获取输入至所述分布式系统的目标数据的数据标识，比如数据标识D1或D2；目标数据采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，采集点标识比如为：T1和T2，对应的时间戳比如为：9:30:00.123456和9:30:00.123478；时延采集模板根据所述数据标识、采集点标识和时间戳将所述数据标识、采集点标识和时间戳以生成时间戳信息，并将所述采集点确定将所述时间戳信息发送至多个时延采集组件或一个时延采集组件，由此提高时延处理速度；时延采集模块读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则，并基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延，计算出各种时延指标以便后续输出查看。

[0057] 在本实施例中，该时延统计方法通过获取输入至所述分布式系统的目标数据的数据标识；采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点；根据所述数据标识、采集点标识和时间戳生成时间戳信息；读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则；基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。该时延统计方法可以实现分布式系统的时延以及吞吐量的自动采集、测量和统计。

[0058] 请参阅图5，图5是本申请一实施例提供的一种时延统计方法的示意流程图。该时延统计方法应用于上述的分布式系统，如图5所示，该时延统计方法包括步骤S201～S208。

[0059] S201、根据预设筛选规则筛选出输入至所述分布式系统的样本数据。

[0060] 其中，步骤S201包括数据筛选的步骤，如图6所示，该步骤具体包括以下内容：S201a、根据预设计数器对输入至所述分布式系统的数据进行计数；S201b、判断所述计数对应的计数数量是否满足预设条件；S201c、若所述计数数量满足所述预设条件，则确定所述计数数量对应的数据为输入所述分布式系统的样本数据。

[0061] 具体地，预先在应用程序中设置一个计数器，通过该计算器对输入到所述分布式系统的数据进行计算标记。判断所述计数对应的计数数量是否满足预设条件。比如，对计算数量对100进行模运算，n为计数数量，n％100＝0即为满足该预设条件。再比如，计算数量是奇数或偶数时等均可为满足所述预设条件。若所述计数数量满足所述预设条件，则确定所述计数数量对应的数据为输入所述分布式系统的样本数据。通过数据筛选的步骤可以有选择地对部分数据进行时延统计和测量，避免采集过多的数据而造成资源浪费。

[0062] 当然，在其他实施例中，也可以其他方法对数据进行筛选，比如指定对某些数据进行采集。

[0063] S202、将所述样本数据设为目标数据，并在所述目标数据的消息头中添加数据标识。

[0064] 具体地，将确定的样本数据作为目标数据，同时在所述目标数据的消息头中添加数据标识，以便在步骤S103获取输入至所述分布式系统的目标数据的数据标识。

[0065] S203、获取输入至所述分布式系统的目标数据的数据标识。

[0066] 具体地，所述目标数据是指从外部输入到所述分布式系统的数据，该数据需要经过所述分布式系统的主机中的应用程序进行加工处理，在各个应用程序之间流转，并有可能产生对外输出，其中每个目标数据均包括一个数据标识。

[0067] S204、采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点。

[0068] 具体地，所述时延采集模块采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识。其中所述预设采集点为预先在所述应用程序设置多个时间采集点，并对该时间采集点进行标识。

[0069] S205、根据所述数据标识、采集点标识和时间戳生成时间戳信息。

[0070] 具体地，所述时延采集模块根据所述数据标识、采集点标识和时间戳生成时间戳信息，具体是将所述数据标识、采集点标识和时间戳一同打包为一个时间戳信息，并将该时间戳信息发送至该时延测量组件。

[0071] S206、读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则。

[0072] 具体地，所述时延测量组件读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则。其中所述时延指标统计规则为预先配置在服务器中，可预先配置在所述时延测量组件位于的服务器中。所述时延指标统计规则根据时间戳信息对所述分布式系统的统计规则。

[0073] S207、基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。

[0074] 具体地，所述时延测量组件基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。该时延指标统计规则包括多个时延指标计算公式，比如，结束点时间戳和开始点时间戳做减法运算的时延指标，当然也可以包括平均值、最小值、最大值、50％、90％、95％、99％等百分位值。

[0075] S208、根据预设输出规则输出统计所述分布式系统的时延对应的统计结果。

[0076] 具体地，所述预设输出规则是指将所述统计结果按照预设输出形式进行输出，该预设输出形式包括三种形式输出，分别为：1、将统计结果滚动输出到命令行控制台；2、将统计结果输出到文件，该文件中追加记录每个统计周期的各项时延指标的统计值，也可以记录每笔数据的各项时延指标值；3、时延测量组件内嵌Http服务器，可接收来自浏览器或其他程序的Http访问请求，根据该访问请求把当前的统计结果以Json字符串的形式返回访问者。

[0077] 图7是本申请实施例提供的一种时延统计装置的示意性框图。如图7所示，对应于以上时延统计方法，本申请还提供一种时延统计装置。该时延统计装置包括用于执行上述时延统计方法的单元，该装置可以被配置于服务器中。

[0078] 其中，如图7所示，时延统计装置400包括：数据筛选单元401、标识添加单元402、标识获取单元403、信息采集单元404、信息生成单元405、文件读取单元406、时延统计单元407和结果输出单元408。

[0079] 数据筛选单元401，用于根据预设筛选规则筛选出输入至所述分布式系统的样本数据。

[0080] 标识添加单元402，用于将所述样本数据设为目标数据，并在所述目标数据的消息头中添加数据标识。

[0081] 标识获取单元403，用于获取输入至所述分布式系统的目标数据的数据标识。

[0082] 信息采集单元404，用于采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点。

[0083] 信息生成单元405，用于根据所述数据标识、采集点标识和时间戳生成时间戳信息。

[0084] 文件读取单元406，用于读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则。

[0085] 时延统计单元407，用于基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。

[0086] 结果输出单元408，用于根据预设输出规则输出统计所述分布式系统的时延对应的统计结果。

[0087] 所属领域的技术人员可以清楚地了解到，为了描述的方便和简洁，上述描述的时延统计装置和单元的具体工作过程，可以参考前述方法实施例中的对应过程，在此不再赘述。

[0088] 上述装置可以实现为一种计算机程序的形式，计算机程序可以在如图8所示的计算机设备上运行。

[0089] 请参阅图8，图8是本申请实施例提供的一种计算机设备的示意性框图。该计算机设备700可以是服务器。

[0090] 参照图8，该计算机设备700包括通过系统总线710连接的处理器720、存储器和网络接口750，其中，存储器可以包括非易失性存储介质730和内存储器740。

[0091] 该非易失性存储介质730可存储操作系统731和计算机程序732。该计算机程序732被执行时，可使得处理器720执行任意一种时延统计方法。

[0092] 该处理器720用于提供计算和控制能力，支撑整个计算机设备700的运行。

[0093] 该内存储器740为非易失性存储介质730中的计算机程序732的运行提供环境，该计算机程序732被处理器720执行时，可使得处理器720执行任意一种时延统计方法。

[0094] 该网络接口750用于进行网络通信，如发送分配的任务等。本领域技术人员可以理解，图8中示出的结构，仅仅是与本申请方案相关的部分结构的框图，并不构成对本申请方案所应用于其上的计算机设备700的限定，具体的计算机设备700可以包括比图中所示更多或更少的部件，或者组合某些部件，或者具有不同的部件布置。其中，所述处理器720用于运行存储在存储器中的程序代码，以实现如下步骤：

[0095] 获取输入至所述分布式系统的目标数据的数据标识；采集所述目标数据被应用程序处理时经过所述应用程序的预设采集点对应的时间戳和采集点标识，所述应用程序分布在所述分布式系统的不同节点；根据所述数据标识、采集点标识和时间戳生成时间戳信息；读取时延指标配置文件，所述时延指标配置文件中包括时延指标统计规则；基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延。

[0096] 在一实施例中，所述处理器720用于运行存储在存储器中的程序代码实现所述获取输入至所述分布式系统的目标数据的数据标识之前，还实现如下步骤：

[0097] 根据预设筛选规则筛选出输入至所述分布式系统的样本数据；将所述样本数据设为目标数据，并在所述目标数据的消息头中添加数据标识。

[0098] 在一实施例中，所述处理器720用于运行存储在存储器中的程序代码实现所述根据预设筛选规则筛选出输入至所述分布式系统的样本数据，具体实现如下步骤：

[0099] 根据预设计数器对输入至所述分布式系统的数据进行计数；判断所述计数对应的计数数量是否满足预设条件；若所述计数数量满足所述预设条件，则确定所述计数数量对应的数据为输入所述分布式系统的样本数据。

[0100] 在一实施例中，所述处理器720用于运行存储在存储器中的程序代码实现所述基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延时，具体实现如下步骤：

[0101] 获取所述时延指标统计规则中的时延指标计算公式；根据所述时延指标计算公式计算所述时间戳信息对应的时延指标。

[0102] 在一实施例中，所述处理器720用于运行存储在存储器中的程序代码实现所述根据所述数据标识、采集点标识和时间戳生成时间戳信息时，具体实现如下步骤：

[0103] 根据所述数据标识和采集点标识将所述时间戳对应保存在预设数据表中以生成所述时间戳信息表。

[0104] 在一实施例中，所述处理器720用于运行存储在存储器中的程序代码实现所述基于所述时延指标统计规则，根据所述时间戳信息统计所述分布式系统的时延之后，还实现如下步骤：

[0105] 根据预设输出规则输出统计所述分布式系统的时延对应的统计结果。

[0106] 在一实施例中，所述处理器720用于运行存储在存储器中的程序代码实现所述根据预设输出规则输出统计所述分布式系统的时延对应的统计结果时，具体实现如下步骤：

[0107] 接收Http访问请求，根据所述Http访问请求将所述统计结果以Json字符串形式进行返回。

[0108] 应当理解，在本申请实施例中，处理器720可以是中央处理单元(Central Processing Unit，CPU)，该处理器720还可以是其他通用处理器、数字信号处理器(Digital Signal Processor，DSP)、专用集成电路(Application Specific Integrated Circuit，ASIC)、现成可编程门阵列(Field-Programmable Gate Array，FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等。其中，通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。

[0109] 本领域技术人员可以理解，图8中示出的计算机设备700结构并不构成对计算机设备700的限定，可以包括比图示更多或更少的部件，或者组合某些部件，或者不同的部件布置。

[0110] 本领域普通技术人员可以理解的是实现上述实施例方法中的全部或部分流程，是可以通过计算机程序来指令相关的硬件来完成，计算机程序可存储于一存储介质中，该存储介质为计算机可读存储介质。如本发明实施例中，该计算机程序可存储于计算机系统的存储介质中，并被该计算机系统中的至少一个处理器执行，以实现包括如上述各方法的实施例的流程步骤。

[0111] 该计算机可读存储介质可以是磁碟、光盘、U盘、移动硬盘、只读存储器(ROM，Read-Only Memory)、磁碟或者光盘等各种可以存储程序代码的介质。

[0112] 本领域普通技术人员可以意识到，结合本文中所公开的实施例描述的各示例的单元及算法步骤，能够以电子硬件、计算机软件或者二者的结合来实现，为了清楚地说明硬件和软件的可互换性，在上述说明中已经按照功能一般性地描述了各示例的组成及步骤。这些功能究竟以硬件还是软件方式来执行，取决于技术方案的特定应用和设计约束条件。专业技术人员可以对每个特定的应用来使用不同方法来实现所描述的功能，但是这种实现不应认为超出本申请的范围。

[0113] 在本申请所提供的几个实施例中，应该理解到，所揭露的时延统计装置和方法，可以通过其它的方式实现。例如，以上所描述的时延统计装置实施例仅仅是示意性的。例如，各个单元的划分，仅仅为一种逻辑功能划分，实际实现时可以有另外的划分方式。例如多个单元或组件可以结合或者可以集成到另一个系统，或一些特征可以忽略，或不执行。

[0114] 本申请实施例方法中的步骤可以根据实际需要进行顺序调整、合并和删减。

[0115] 本申请实施例装置中的单元可以根据实际需要进行合并、划分和删减。

[0116] 另外，在本申请各个实施例中的各功能单元可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以是两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现，也可以采用软件功能单元的形式实现。

[0117] 该集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本申请的技术方案本质上或者说对现有技术做出贡献的部分，或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个人计算机，终端，或者网络设备等)执行本申请各个实施例所述方法的全部或部分步骤。

[0118] 以上所述，仅为本申请的具体实施方式，但本申请的保护范围并不局限于此，任何熟悉本技术领域的技术人员在本申请揭露的技术范围内，可轻易想到各种等效的修改或替换，这些修改或替换都应涵盖在本申请的保护范围之内。因此，本申请的保护范围应以权利要求的保护范围为准。