一种采集系统与网元设备的心跳检测方法及其装置与流程

1.本技术涉及通信技术领域，尤其涉及一种采集系统与网元设备的心跳检测方法及其装置。


背景技术：

2.相关技术中，为保证网元设备侧话单采集正常，会部署监控脚本，若对端网元目录下话单量有积压或采集主机与对端网元连接异常，则会触发监控告警；在网元连接数达到最大值导致网元无法连接时，会触发网元无法连接及对应采集目录话单积压告警，网元设备侧维护人员收到告警后，会进行网元设备上计费主备模块切换操作，暂时解决网元无法连接及话单积压问题。
3.现有采集系统与网元设备间连接模式存在不足，分发程序与网元保持长连接，采集处理程序与网元设备保持短连接，网元设备侧有连接数限制，且设备侧传输控制协议(tcp，transmission control protocol)连接存在非正常释放情况，导致连接数记录值持续处于上升状态，最终导致采集程序无法与网元设备建立连接。


技术实现要素：

4.本公开提供一种采集系统与网元设备的心跳检测方法及其装置，以至少解决相关技术中网元设备侧有连接数限制，且设备侧tcp连接存在非正常释放情况，导致连接数记录值持续处于上升状态，最终导致采集程序无法与网元设备建立连接的问题。
5.本技术第一方面实施例提出了一种采集系统与网元设备的心跳检测方法，由采集系统执行，包括：在采集系统对网元设备的数据采集过程中，针对任一网元设备，以预设的固定心跳间隔向网元设备发送心跳包，其中，采集系统所包含的分发程序和采集程序两者与网元设备的连接方式均设置为长连接模式；基于采集系统所采集的网元设备的数据，获取网元设备对应的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔探测时刻；从心跳间隔探测时刻开始，根据采集系统的长连接数据、采集系统的系统负载以及网元设备对应的平均心跳间隔数据，动态配置心跳间隔；基于动态配置的心跳间隔向网元设备发送心跳包。
6.根据本技术的一个实施例，从心跳间隔探测时刻开始，根据采集系统的长连接数据、采集系统的系统负载以及网元设备对应的平均心跳间隔数据，动态配置心跳间隔，包括：根据采集系统在心跳间隔探测时刻的长连接数据、采集系统在心跳间隔探测时刻的系统负载以及在心跳间隔探测时刻网元设备对应的平均心跳间隔数据，确定待发送的第一心跳包对应的第一心跳间隔调整值，其中，第一心跳包为在确定心跳间隔探测时刻之后向网元设备发送的第一个心跳包；将固定心跳间隔作为第一心跳包对应的心跳间隔基准值；将心跳间隔基准值与第一心跳间隔调整值的和值作为第一心跳包对应的心跳间隔。
7.根据本技术的一个实施例，将心跳间隔基准值与第一心跳间隔调整值的和值作为第一心跳包对应的心跳间隔之后，还包括：针对采集系统向网元设备任一次发送的心跳包，
若在采集系统向网元设备发送心跳包之后接收到网元设备返回的心跳包响应，则将采集系统该次向网元设备发送的心跳包作为第一目标心跳包，并将第一目标心跳包的心跳间隔作为当前待发送的心跳包对应的心跳间隔基准值；根据当前时刻采集系统的长连接数据、当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值；将当前待发送的心跳包对应的心跳间隔基准值与当前待发送的心跳包对应的心跳间隔调整值的和值作为当前待发送的心跳包对应的心跳间隔。
8.根据本技术的一个实施例，根据当前时刻采集系统的长连接数据、当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值，包括：根据当前时刻采集系统的长连接数据，获取当前时刻与采集系统建立长连接的网元设备的第一数量值；获取采集系统对应的长连接端口均长连接有网元设备的情况下对应的网元设备的第二数量值；将第一数量值与第二数量值的比值作为采集系统当前时刻的长连接建设率；基于长连接建设率，结合当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值。
9.根据本技术的一个实施例，采集系统与网元设备的心跳检测方法，还包括：针对采集系统向网元设备任一次发送的心跳包，若在采集系统向网元设备发送心跳包之后未接收到网元设备返回的心跳包响应，则将采集系统该次向网元设备发送的心跳包作为第二目标心跳包；基于第二目标心跳包对应的心跳间隔重新向网元设备发送心跳包，并同时向与网元设备的长连接的途径节点发送重连提醒。
10.根据本技术的一个实施例，采集系统与网元设备的心跳检测方法，还包括：还包括：在基于第二目标心跳包对应的心跳间隔重新向网元设备发送心跳包的连续次数达到预设次数之后，确定网元设备处于断连状态，则向网元设备发送长连接建立请求；接收网元设备返回的长连接建立成功响应，并基于预设的固定心跳间隔向网元设备发送心跳包。
11.根据本技术的一个实施例，接收网元设备返回的长连接建立成功响应，并基于预设的固定心跳间隔向网元设备发送心跳包之后，还包括：重新获取网元设备的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔再探测时刻；根据采集系统在心跳间隔再探测时刻的长连接数据、采集系统在心跳间隔再探测时刻的系统负载以及在心跳间隔再探测时刻网元设备对应的平均心跳间隔数据，结合第一心跳间隔调整值，确定待发送的第二心跳包对应的第二心跳间隔调整值，其中，第二心跳包为在确定心跳间隔再探测时刻之后向网元设备发送的第一个心跳包；将固定心跳间隔作为第二心跳包对应的心跳间隔基准值；将心跳间隔基准值与第二心跳间隔调整值的和值作为第二心跳包对应的心跳间隔；基于第二心跳包对应的心跳间隔向网元设备发送心跳包。
12.根据本技术的一个实施例，根据采集系统在心跳间隔再探测时刻的长连接数据、采集系统在心跳间隔再探测时刻的系统负载以及在心跳间隔再探测时刻网元设备对应的平均心跳间隔数据，结合第一心跳间隔调整值，确定待发送的第二心跳包对应的第二心跳间隔调整值，包括：根据心跳间隔再探测时刻采集系统的长连接数据、心跳间隔探测时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定待发送的第二心跳包对应的第二心跳间隔调整原始值；若第二心跳间隔调整原始值大于等于第一心跳间隔调整值，则将第二心跳间隔调整原始值的一半作为第二心跳间隔调整值；若第二心跳间隔调整原始值小于第一心跳间隔调整值，则将第二心跳间隔调整原始值作为第二心跳间隔调整值。
13.根据本技术的一个实施例，采集系统与网元设备的心跳检测方法，还包括：将采集系统的文件传输协议(file transfer protocol，ftp)空闲超时时间设置为小于网络设备的ftp空闲超时时间。
14.根据本技术的一个实施例，采集系统与网元设备的心跳检测方法，还包括：在采集系统对网元设备的进行数据采集时，接收网元设备发送的压缩数据；对压缩数据进行解压缩，获取网元设备的话单数据。
15.根据本技术的一个实施例，基于采集系统所采集的网元设备的数据，获取网元设备对应的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔探测时刻，包括：基于采集系统所采集的网元设备的数据，获取网元设备对应的话单产出数据、话单查询数据和话单账户余额；根据话单产出数据确定话单产出稀疏时段；根据话单查询数据确定话单查询稀疏时段；若话单账户余额大于预定的余额阈值，且话单同时处于话单产出稀疏时段和话单查询稀疏时段，则确定当前时刻为心跳间隔探测时刻。
16.本技术第二方面实施例提出了采集系统与网元设备的心跳检测装置，包括：第一发送模块，用于在采集系统对网元设备的数据采集过程中，针对任一网元设备，以预设的固定心跳间隔向网元设备发送心跳包，其中，采集系统所包含的分发程序和采集程序两者与网元设备的连接方式均设置为长连接模式；时刻获取模块，用于基于采集系统所采集的网元设备的数据，获取网元设备对应的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔探测时刻；动态配置模块，用于从心跳间隔探测时刻开始，根据采集系统的长连接数据、采集系统的系统负载以及网元设备对应的平均心跳间隔数据，动态配置心跳间隔；第二发送模块，用于基于动态配置的心跳间隔向网元设备发送心跳包。
17.根据本技术的一个实施例，动态配置模块，还用于：根据采集系统在心跳间隔探测时刻的长连接数据、采集系统在心跳间隔探测时刻的系统负载以及在心跳间隔探测时刻网元设备对应的平均心跳间隔数据，确定待发送的第一心跳包对应的第一心跳间隔调整值，其中，第一心跳包为在确定心跳间隔探测时刻之后向网元设备发送的第一个心跳包；将固定心跳间隔作为第一心跳包对应的心跳间隔基准值；将心跳间隔基准值与第一心跳间隔调整值的和值作为第一心跳包对应的心跳间隔。
18.根据本技术的一个实施例，动态配置模块，还用于：针对采集系统向网元设备任一次发送的心跳包，若在采集系统向网元设备发送心跳包之后接收到网元设备返回的心跳包响应，则将采集系统该次向网元设备发送的心跳包作为第一目标心跳包，并将第一目标心跳包的心跳间隔作为当前待发送的心跳包对应的心跳间隔基准值；根据当前时刻采集系统的长连接数据、当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值；将当前待发送的心跳包对应的心跳间隔基准值与当前待发送的心跳包对应的心跳间隔调整值的和值作为当前待发送的心跳包对应的心跳间隔。
19.根据本技术的一个实施例，动态配置模块，还用于：根据当前时刻采集系统的长连接数据，获取当前时刻与采集系统建立长连接的网元设备的第一数量值；获取采集系统对应的长连接端口均长连接有网元设备的情况下对应的网元设备的第二数量值；将第一数量值与第二数量值的比值作为采集系统当前时刻的长连接建设率；基于长连接建设率，结合当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的
心跳包对应的心跳间隔调整值。
20.根据本技术的一个实施例，动态配置模块，还用于：针对采集系统向网元设备任一次发送的心跳包，若在采集系统向网元设备发送心跳包之后未接收到网元设备返回的心跳包响应，则将采集系统该次向网元设备发送的心跳包作为第二目标心跳包；基于第二目标心跳包对应的心跳间隔重新向网元设备发送心跳包，并同时向与网元设备的长连接的途径节点发送重连提醒。
21.根据本技术的一个实施例，采集系统与网元设备的心跳检测装置还包括：断连确定模块，用于在基于第二目标心跳包对应的心跳间隔重新向网元设备发送心跳包的连续次数达到预设次数之后，确定网元设备处于断连状态，则向网元设备发送长连接建立请求；长连接重建立模块，用于接收网元设备返回的长连接建立成功响应，并基于预设的固定心跳间隔向网元设备发送心跳包。
22.根据本技术的一个实施例，动态配置模块，还用于：重新获取网元设备的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔再探测时刻；根据采集系统在心跳间隔再探测时刻的长连接数据、采集系统在心跳间隔再探测时刻的系统负载以及在心跳间隔再探测时刻网元设备对应的平均心跳间隔数据，结合第一心跳间隔调整值，确定待发送的第二心跳包对应的第二心跳间隔调整值，其中，第二心跳包为在确定心跳间隔再探测时刻之后向网元设备发送的第一个心跳包；将固定心跳间隔作为第二心跳包对应的心跳间隔基准值；将心跳间隔基准值与第二心跳间隔调整值的和值作为第二心跳包对应的心跳间隔；第二发送模块，还用于：基于第二心跳包对应的心跳间隔向网元设备发送心跳包。
23.根据本技术的一个实施例，动态配置模块，还用于：根据心跳间隔再探测时刻采集系统的长连接数据、心跳间隔探测时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定待发送的第二心跳包对应的第二心跳间隔调整原始值；若第二心跳间隔调整原始值大于等于第一心跳间隔调整值，则将第二心跳间隔调整原始值的一半作为第二心跳间隔调整值；若第二心跳间隔调整原始值小于第一心跳间隔调整值，则将第二心跳间隔调整原始值作为第二心跳间隔调整值。
24.根据本技术的一个实施例，采集系统与网元设备的心跳检测装置还包括：配置模块，用于将采集系统的ftp空闲超时时间设置为小于网络设备的ftp空闲超时时间。
25.根据本技术的一个实施例，采集系统与网元设备的心跳检测装置还包括：数据接收模块，用于在采集系统对网元设备的进行数据采集时，接收网元设备发送的压缩数据；解压缩模块，用于对压缩数据进行解压缩，获取网元设备的话单数据。
26.根据本技术的一个实施例，时刻获取模块，还用于：基于采集系统所采集的网元设备的数据，获取网元设备对应的话单产出数据、话单查询数据和话单账户余额；根据话单产出数据确定话单产出稀疏时段；根据话单查询数据确定话单查询稀疏时段；若话单账户余额大于预定的余额阈值，且话单同时处于话单产出稀疏时段和话单查询稀疏时段，则确定当前时刻为心跳间隔探测时刻。
27.本技术第三方面实施例提出了一种采集系统，包括：至少一个处理器；以及与所述至少一个处理器通信连接的存储器；其中，所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以实现如本技术第一方面实施例所述的采集系统与网元设备的心跳检测方法。
28.本技术第四方面实施例提出了一种存储有计算机指令的非瞬时计算机可读存储介质，其中，所述计算机指令用于实现如本技术第一方面实施例所述的采集系统与网元设备的心跳检测方法。
29.本技术第五方面实施例提出了一种计算机程序产品，包括计算机程序，所述计算机程序在被处理器执行时实现如本技术第一方面实施例所述的采集系统与网元设备的心跳检测方法。
30.本公开的实施例提供的技术方案至少带来以下有益效果：本技术通过将分发程序和采集程序连接方式都设置为长连接模式，并使用心跳包进行维持，可以避免短连接的频繁建立和断开，从而降低同时与网元设备建立连接的数量。这将有助于解决网元设备侧的连接数限制问题；由于网元设备侧tcp连接存在非正常释放情况，连接数记录值一直上升，导致采集程序无法与网元设备建立连接。通过发送心跳包并根据拥塞状态和系统负载动态配置心跳间隔，可以及时检测连接状态，并在需要时调整心跳间隔以维持连接稳定性，通过动态配置心跳间隔，可以根据实时的网络状况和设备负载情况灵活地调整心跳包的发送频率。这样可以避免过于频繁的心跳包发送，减少带宽和服务器资源的消耗，提高资源利用效率；基于采集系统获取的网元设备数据，可以实时监测网元设备的拥塞状态。这将有助于及时发现网络拥塞情况，并根据拥塞状态确定相应的心跳间隔探测时刻，从而更精确地调整心跳间隔。
31.应当理解的是，以上的一般描述和后文的细节描述仅是示例性和解释性的，并不能限制本公开。
附图说明
32.本技术上述的和/或附加的方面和优点从下面结合附图对实施例的描述中将变得明显和容易理解，其中：
33.图1是本技术示出的一种采集系统与网元设备的心跳检测方法的示例性实施方式的示意图。
34.图2是本技术示出的一种采集系统与网元设备的心跳包发送示意图。
35.图3是本技术示出的一种将采集系统所包含的分发程序和采集程序两者与网元设备的连接方式均设置为长连接模式配置信息截图。
36.图4是本技术示出的一种动态配置心跳间隔的方法的示意图。
37.图5是本技术示出的一种采集系统与网元设备的ftp部署关系图。
38.图6是本技术示出的一种采集系统与网元设备的心跳检测装置的示意图。
39.图7是本技术一个实施例示出的一种采集系统的示意图。
具体实施方式
40.下面详细描述本技术的实施例，所述实施例的示例在附图中示出，其中自始至终相同或类似的标号表示相同或类似的元件或具有相同或类似功能的元件。下面通过参考附图描述的实施例是示例性的，旨在用于解释本技术，而不能理解为对本技术的限制。
41.需要说明的是，本公开中所有获取信息、权限，提供服务的动作都是在遵照所在地国家相应的数据保护法规政策的前提下，并获得由相应装置所有者给予授权的情况下进行
的，均符合相关法律法规的规定，且不违背公序良俗。
42.图1是本技术示出的一种采集系统与网元设备的心跳检测方法的示例性实施方式的示意图，如图1所示，该采集系统与网元设备的心跳检测方法，包括以下步骤：
43.s101，在采集系统对网元设备的数据采集过程中，针对任一网元设备，以预设的固定心跳间隔向网元设备发送心跳包，其中，采集系统所包含的分发程序和采集程序两者与网元设备的连接方式均设置为长连接模式。
44.采集系统与网元设备建立面向连接的传输层协议(transmission control protocol，tcp)连接需要三步握手，持续执行该过程耗时较多，如果采集程序每次取文件都采用短连接模式，在文件量较大且业务网元频繁出现连接数异常时，会降低文件采集处理效率，最终导致文件积压，且使用短连接频繁的通信会造成socket错误，而且频繁的socket创建也是对资源的浪费。长连接直接调用socket(套接字)接口进行数据通信，多用于操作频繁，点对点的通讯。本技术中，将采集系统所包含的分发程序和采集程序两者与网元设备的连接方式均设置为长连接模式，由原有短连接优化为支持源端连接池功能，实现长连接，减少频繁连接次数，也即，采集程序在上次与网元设备建立连接且文件采集操作完成后，不断开tcp连接，下次采集程序处理时直接传输文件数据包，避免连接中断，并提高采集效率。
45.采集进程采用长连接模式时，在网元话单量小，采集进程未接收到分发进程发送的socket包(包含采集网元、目录、话单量等信息)时，考虑到防火墙会强行终止采集进程的长连接会话，造成长连接被异常释放，但用于文件传输的协议(file transfer protocol，ftp)服务端软件记录的连接数并未因为程序断开连接而减小，因此，ftp服务端软件连接数值始终保持增大状态，当服务端连接数达到最大后，后续采集进程tcp无法连接，最终在采集系统出现大量主机与网元设备间连接失败告警，只能等待网元设备进行主备模块倒换操作，释放连接数后再次尝试连接。
46.本方案在长连接模式的基础上，进一步在采集程序内置心跳包检测程序(keep alive模式)，以及心跳包周期确定策略，在网元设备无话单文件生成时，根据心跳包周期确定策略确定的心跳包周期来使得采集系统向网元发送心跳包，若网元侧有心跳包响应，则说明tcp连接仍处于正常状态。
47.keep alive一般包含以下三个参数：1)tcp_keepalive_time：该参数用于检测对端状态。当tcp连接长时间都没有数据通信时，会发送心跳包，检测对端是否仍处于连接状态。2)tcp_keepalive_intvl：该参数控制心跳包时间间隔，控制每隔多久发送一次心跳包。3)tcp_keepalive_probes：该参数代表重试次数，假如第一次心跳包对端没有回复，并不能确认连接已经断开，多次连接都没有回复，才代表对端已断开连接。
48.图2是本技术示出的一种采集系统与网元设备的心跳包发送示意图，如图2所示，采集系统向网元设备发送心跳包，并接收网元设备返回的心跳包响应。其中，心跳包可以是一个特定的数据包，通常包含一些固定的标识符或信息，以便网元设备能够正确地识别和响应。
49.图3是本技术示出的一种将采集系统所包含的分发程序和采集程序两者与网元设备的连接方式均设置为长连接模式配置信息截图，如图3所示，由原始短连接方式修改为长连接模式。对连接模式相关参数配置具体的值，将protocol对应的布尔类型值设置为f(false)，即代表不使用短连接(shortlink)，采用长连接模式。
50.本技术中，在采集系统开始对网元设备进行数据采集时，针对任一网元设备，首先以预设的固定心跳间隔向网元设备发送心跳包。
51.s102，基于采集系统所采集的网元设备的数据，获取网元设备对应的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔探测时刻。
52.在采集系统采集到网元设备足够的数据之后，对采集到的网元设备数据进行分析和处理，以识别出反映拥塞状态的相关指标或特征。在识别到网元设备处于不拥塞状态时，为了避免频繁的心跳包发送，为了减少带宽和服务器资源的消耗，提高资源利用效率，不再以固定心跳间隔向网元设备发送心跳包，而是尝试以动态的心跳间隔向网元设备发送心跳包，将确定开始以动态的心跳间隔向网元设备发送心跳包的时刻作为心跳间隔探测时刻。
53.s103，从心跳间隔探测时刻开始，根据采集系统的长连接数据、采集系统的系统负载以及网元设备对应的平均心跳间隔数据，动态配置心跳间隔。
54.在确定心跳间隔探测时刻之后，根据采集系统的长连接数据、采集系统的系统负载以及网元设备对应的平均心跳间隔数据，动态配置心跳间隔。
55.作为一种可实现的方式，本技术所述的采集系统的系统负载为采集系统的cpu使用率，则在确定心跳间隔探测时刻之后，获取在心跳间隔探测时刻与采集系统建立长连接的网元设备的实时数值作为第一数量值，获取在采集系统对应的长连接端口均长连接有网元设备的情况下对应的网元设备的总数量作为第二数量值，将第一数量值与第二数量值的比值作为采集系统当前时刻的长连接建设率；则基于长连接建设率，结合在心跳间隔探测时刻采集系统的cpu使用率以及网元设备对应的平均心跳间隔，确定在确定心跳间隔探测时刻之后待发送的第一个心跳包对应的心跳间隔调整值的公式如下：
56.z＝0.1*t*(1-x)*(1-y)
57.上式中，z代表心跳间隔调整值，t代表网元设备对应的平均心跳间隔，x代表采集系统当前时刻的长连接建设率，y代表采集系统的cpu使用率。
58.例如，当前长连接的建设率为30％，平均心跳间隔为2.5秒，cpu使用率为50％，则将心跳间隔调整值确定为2.5*0.7*0.5*0.1＝0.0875。
59.不难理解的，心跳间隔调整值指的是心跳间隔调整的大小，由于在确定心跳间隔探测时刻之后待发送的第一个心跳包的前一个心跳包的发送间隔为固定心跳间隔，则将固定心跳间隔与第一个心跳包对应的心跳间隔调整值的和值作为第一个心跳包对应的心跳间隔。
60.以此类推，每当确定待发送的下一个心跳包对应的心跳间隔调整值时，根据当前时刻采集系统的长连接数据、采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定待发送的下一个心跳包对应的心跳间隔调整值，再获取本次发送的心跳包对应的心跳间隔，将本次发送的心跳包对应的心跳间隔与下一个心跳包对应的心跳间隔调整值的和值作为下一个心跳包对应的心跳间隔。
61.s104，基于动态配置的心跳间隔向网元设备发送心跳包。
62.在本技术中，在确定了心跳包时间间隔后，借助keep alive特性，在心跳包检测程序中对心跳包时间间隔进行设置，例如，确定的心跳包时间间隔为60s，则在心跳包检测程序中将心跳包时间间隔设置为60s，向网元设备发送心跳包，来保证服务端持续处于连接状态。
63.本技术实施例提出了一种采集系统与网元设备的心跳检测方法，通过将分发程序和采集程序连接方式都设置为长连接模式，并使用心跳包进行维持，可以避免短连接的频繁建立和断开，实现采集系统与网元设备间连接不间断，文件正常被采集，网元设备目录不存在积压，实现采集程序不间断运行场景。通过发送心跳包并根据拥塞状态和系统负载动态配置心跳间隔，可以及时检测连接状态，并在需要时调整心跳间隔以维持连接稳定性，通过动态配置心跳间隔，可以根据实时的网络状况和设备负载情况灵活地调整心跳包的发送频率。这样可以避免过于频繁的心跳包发送，减少带宽和服务器资源的消耗，提高资源利用效率；基于采集系统获取的网元设备数据，可以实时监测网元设备的拥塞状态。这将有助于及时发现网络拥塞情况，并根据拥塞状态确定相应的心跳间隔探测时刻，从而更精确地调整心跳间隔。
64.作为一种可实现的实施方式，基于采集系统所采集的网元设备的数据，获取网元设备对应的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔探测时刻时，可以基于采集系统所采集的网元设备的数据，获取网元设备对应的话单产出数据(比如说话单生成的数量、时间戳等信息)、话单查询数据(比如说话单查询的次数、时间戳等信息)和话单账户余额。
65.将话单产出稀疏时段定义为话单产出数量相对较少的时间段，可能表示话单生成活动相对较少或者网元设备负载较低的时段。将话单查询稀疏时段定义为单查询活动相对较少或者网元设备负载较低的时段。根据话单产出数据确定话单产出稀疏时段；根据话单查询数据确定话单查询稀疏时段；若话单账户余额大于预定的余额阈值，且话单同时处于话单产出稀疏时段和话单查询稀疏时段，则确定当前时刻为心跳间隔探测时刻。
66.图4是本技术示出的一种动态配置心跳间隔的方法的示意图，如图4所示，该动态配置心跳间隔的方法，包括以下步骤：
67.s401，根据采集系统在心跳间隔探测时刻的长连接数据、采集系统在心跳间隔探测时刻的系统负载以及在心跳间隔探测时刻网元设备对应的平均心跳间隔数据，确定待发送的第一心跳包对应的第一心跳间隔调整值，其中，第一心跳包为在确定心跳间隔探测时刻之后向网元设备发送的第一个心跳包。
68.本技术中，将在确定心跳间隔探测时刻之后向网元设备发送的第一个心跳包作为第一心跳包，将第一心跳包对应的心跳间隔调整值作为第一心跳间隔调整值。
69.在确定心跳间隔探测时刻之后，获取在心跳间隔探测时刻与采集系统建立长连接的网元设备的实时数值作为第一数量值，获取在采集系统对应的长连接端口均长连接有网元设备的情况下对应的网元设备的总数量作为第二数量值，将第一数量值与第二数量值的比值作为采集系统当前时刻的长连接建设率；则基于长连接建设率，结合在心跳间隔探测时刻采集系统的cpu使用率以及网元设备对应的平均心跳间隔，确定待发送的第一心跳包对应的第一心跳间隔调整值的公式如下：
70.z＝0.1*t*(1-x)*(1-y)
71.上式中，z代表心跳间隔调整值，t代表网元设备对应的平均心跳间隔，x代表采集系统当前时刻的长连接建设率，y代表采集系统的cpu使用率。
72.s402，将固定心跳间隔作为第一心跳包对应的心跳间隔基准值。
73.不难理解的，第一心跳间隔调整值指的是第一心跳包对应的心跳间隔调整的大
小，由于在确定心跳间隔探测时刻之后待发送的第一个心跳包的前一个心跳包的发送间隔为固定心跳间隔，本技术中，将固定心跳间隔作为第一心跳包对应的心跳间隔基准值。
74.s403，将心跳间隔基准值与第一心跳间隔调整值的和值作为第一心跳包对应的心跳间隔。
75.将心跳间隔基准值与第一心跳间隔调整值的和值作为第一心跳包对应的心跳间隔，并基于第一心跳包对应的心跳间隔向网元设备发送第一心跳包。
76.s404，针对采集系统向网元设备任一次发送的心跳包，若在采集系统向网元设备发送心跳包之后接收到网元设备返回的心跳包响应，则将采集系统该次向网元设备发送的心跳包作为第一目标心跳包，并将第一目标心跳包的心跳间隔作为当前待发送的心跳包对应的心跳间隔基准值。
77.s405，根据当前时刻采集系统的长连接数据、当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值。
78.与上述确定心跳间隔的方式相同，每当确定待发送的下一个心跳包对应的心跳间隔调整值时，根据当前时刻采集系统的长连接数据，获取当前时刻与采集系统建立长连接的网元设备的第一数量值；获取采集系统对应的长连接端口均长连接有网元设备的情况下对应的网元设备的第二数量值；将第一数量值与第二数量值的比值作为采集系统当前时刻的长连接建设率；基于长连接建设率，结合当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值。
79.s406，将当前待发送的心跳包对应的心跳间隔基准值与当前待发送的心跳包对应的心跳间隔调整值的和值作为当前待发送的心跳包对应的心跳间隔。
80.每次确定当前待发送的心跳包对应的心跳间隔调整值之后，将当前待发送的心跳包对应的心跳间隔基准值与当前待发送的心跳包对应的心跳间隔调整值的和值作为当前待发送的心跳包对应的心跳间隔。
81.示例性的，若固定心跳间隔为60s，确定心跳间隔探测时刻之后的第一个心跳包对应的心跳间隔调整值为2s，则可计算获得心跳间隔探测时刻之后发送的第一个心跳包对应的心跳间隔为60+2＝62s。
82.若采集系统接收到心跳间隔探测时刻之后的第一个心跳包对应的心跳包响应，若确定心跳间隔探测时刻之后的第二个心跳包对应的心跳间隔调整值为3s，则可计算获得心跳间隔探测时刻之后发送的第二个心跳包对应的心跳间隔为62+3＝65s。
83.以此类推，可计算获得每个心跳包对应的心跳间隔。
84.本技术实施例通过发送心跳包并根据拥塞状态和系统负载动态配置心跳间隔，可以及时检测连接状态，并在需要时调整心跳间隔以维持连接稳定性，通过动态配置心跳间隔，可以根据实时的网络状况和设备负载情况灵活地调整心跳包的发送频率。这样可以避免过于频繁的心跳包发送，减少带宽和服务器资源的消耗，提高资源利用效率。
85.进一步的，针对采集系统向网元设备任一次发送的心跳包，若在采集系统向网元设备发送心跳包之后未接收到网元设备返回的心跳包响应，则意味着该网元设备可能出现断连，为了进行进一步确定，将采集系统该次向网元设备发送的心跳包作为第二目标心跳包；基于第二目标心跳包对应的心跳间隔重新向网元设备发送心跳包，并同时向与网元设备的长连接的途径节点发送重连提醒，以提醒长连接有可能被误杀，并提示相关节点做好
重连长连接的准备。
86.进一步的，在基于第二目标心跳包对应的心跳间隔重新向网元设备发送心跳包的连续次数达到预设次数之后，确定网元设备处于断连状态，则向网元设备发送长连接建立请求；在网元设备允许建立长连接之后，接收网元设备返回的长连接建立成功响应，此时长连接建立成功，采集系统会恢复对话单文件的正常处理，并基于预设的固定心跳间隔向网元设备发送心跳包。
87.进一步的，在长连接建立成功并基于预设的固定心跳间隔向网元设备发送心跳包之后，需要重新获取网元设备的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔再探测时刻。将在确定心跳间隔再探测时刻之后向网元设备发送的第一个心跳包作为第二心跳包，将第二心跳包对应的心跳间隔调整值作为第二心跳间隔调整值。本技术中，根据心跳间隔再探测时刻采集系统的长连接数据、心跳间隔探测时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定待发送的第二心跳包对应的第二心跳间隔调整原始值；若第二心跳间隔调整原始值大于等于第一心跳间隔调整值，则将第二心跳间隔调整原始值的一半作为第二心跳间隔调整值；若第二心跳间隔调整原始值小于第一心跳间隔调整值，则将第二心跳间隔调整原始值作为第二心跳间隔调整值。将固定心跳间隔作为第二心跳包对应的心跳间隔基准值；将心跳间隔基准值与第二心跳间隔调整值的和值作为第二心跳包对应的心跳间隔；基于第二心跳包对应的心跳间隔向网元设备发送心跳包。
88.接下来，与上述确定心跳间隔的方式相同，在基于第二心跳包对应的心跳间隔向网元设备发送心跳包之后，每当确定待发送的下一个心跳包对应的心跳间隔调整值时，根据当前时刻采集系统的长连接数据，获取当前时刻与采集系统建立长连接的网元设备的第一数量值；获取采集系统对应的长连接端口均长连接有网元设备的情况下对应的网元设备的第二数量值；将第一数量值与第二数量值的比值作为采集系统当前时刻的长连接建设率；基于长连接建设率，结合当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值，以此实现心跳间隔的动态配置。
89.进一步的，ftp空闲超时时间代表在网元设备上ftp服务器软件的空闲超时设置，即网元设备侧在无文件生成时，ftp的最长连接时间。图5是本技术示出的一种采集系统与网元设备的ftp部署关系图，采集系统ftp客户端超时时间设置须参考网元设备侧ftp服务器软件的空闲超时设置。本技术中，将采集系统的ftp空闲超时时间设置为小于网络设备的ftp空闲超时时间，这样在客户端发送quit命令时，服务端会返回221成功代码(goodbye)。
90.考虑网元设备侧能够自由调控ftp服务器，并将ftp服务器软件的超时时间设置调大，采集系统以此为来设置客户端软件超时时间，且将采集系统的ftp空闲超时时间小于网络设备的ftp空闲超时时间，确保两者间ftp连接正常。以关口局语音业务为例，关口局网元每隔5分钟生成一个话单文件，网元设备侧以此为依据，对ftp时间间隔进行优化，将网元设备作为服务器端的ftp时间间隔设置大于5分钟，采集系统作为客户端的ftp时间间隔需依据网元侧动态调整(小于网络设备设置的时间值)，保证网络连接状态正常，话单生成后立即被取走。
91.进一步的，由于移动网内业务复杂，且用户数量庞大，当处于用户密集使用网络阶段，网元设备上会激增较大量的话单。若不进行数据处理，采集系统直接进行数据采集，实
现大量数据快速传输是有很大难度的，且网元设备大多采用嵌入式系统与采集系统对接，要提升保存、传输话单数据的能力，就需要进行话单压缩处理。
92.本技术中，在采集系统对网元设备的进行数据采集时，接收网元设备发送的压缩数据；对压缩数据进行解压缩，获取网元设备的话单数据。
93.可选的，压缩数据可采用游程编码(run length encoding，rle)进行二进制话单文件压缩，减少重复字符的物理尺寸，话单文件内容被编码成两个字节，第一个字节表示字符数量，第二个字节表示本身字符值。若话单文件内容为000111，用正数表示1，用负数表示表示0，游程长度表示连续的相同字符，则000111压缩为(-3，+3)，当话单量非常大时，能很好地提高压缩率，且可以保证压缩解压缩速度，并且占用资源很少，实现文件的快速传输。
94.图6是本技术示出的一种采集系统与网元设备的心跳检测装置的示意图，如图6所示，该采集系统与网元设备的心跳检测装置600，包括第一发送模块601、时刻获取模块602、动态配置模块603和第二发送模块604，其中：
95.第一发送模块601，用于在采集系统对网元设备的数据采集过程中，针对任一网元设备，以预设的固定心跳间隔向网元设备发送心跳包，其中，采集系统所包含的分发程序和采集程序两者与网元设备的连接方式均设置为长连接模式。
96.时刻获取模块602，用于基于采集系统所采集的网元设备的数据，获取网元设备对应的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔探测时刻。
97.动态配置模块603，用于从心跳间隔探测时刻开始，根据采集系统的长连接数据、采集系统的系统负载以及网元设备对应的平均心跳间隔数据，动态配置心跳间隔。
98.第二发送模块604，用于基于动态配置的心跳间隔向网元设备发送心跳包。
99.本装置通过将分发程序和采集程序连接方式都设置为长连接模式，并使用心跳包进行维持，可以避免短连接的频繁建立和断开，从而降低同时与网元设备建立连接的数量。这将有助于解决网元设备侧的连接数限制问题；由于网元设备侧tcp连接存在非正常释放情况，连接数记录值一直上升，导致采集程序无法与网元设备建立连接。通过发送心跳包并根据拥塞状态和系统负载动态配置心跳间隔，可以及时检测连接状态，并在需要时调整心跳间隔以维持连接稳定性，通过动态配置心跳间隔，可以根据实时的网络状况和设备负载情况灵活地调整心跳包的发送频率。这样可以避免过于频繁的心跳包发送，减少带宽和服务器资源的消耗，提高资源利用效率；基于采集系统获取的网元设备数据，可以实时监测网元设备的拥塞状态。这将有助于及时发现网络拥塞情况，并根据拥塞状态确定相应的心跳间隔探测时刻，从而更精确地调整心跳间隔。
100.进一步的，动态配置模块603，还用于：根据采集系统在心跳间隔探测时刻的长连接数据、采集系统在心跳间隔探测时刻的系统负载以及在心跳间隔探测时刻网元设备对应的平均心跳间隔数据，确定待发送的第一心跳包对应的第一心跳间隔调整值，其中，第一心跳包为在确定心跳间隔探测时刻之后向网元设备发送的第一个心跳包；将固定心跳间隔作为第一心跳包对应的心跳间隔基准值；将心跳间隔基准值与第一心跳间隔调整值的和值作为第一心跳包对应的心跳间隔。
101.进一步的，动态配置模块603，还用于：针对采集系统向网元设备任一次发送的心跳包，若在采集系统向网元设备发送心跳包之后接收到网元设备返回的心跳包响应，则将采集系统该次向网元设备发送的心跳包作为第一目标心跳包，并将第一目标心跳包的心跳
间隔作为当前待发送的心跳包对应的心跳间隔基准值；根据当前时刻采集系统的长连接数据、当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值；将当前待发送的心跳包对应的心跳间隔基准值与当前待发送的心跳包对应的心跳间隔调整值的和值作为当前待发送的心跳包对应的心跳间隔。
102.进一步的，动态配置模块603，还用于：根据当前时刻采集系统的长连接数据，获取当前时刻与采集系统建立长连接的网元设备的第一数量值；获取采集系统对应的长连接端口均长连接有网元设备的情况下对应的网元设备的第二数量值；将第一数量值与第二数量值的比值作为采集系统当前时刻的长连接建设率；基于长连接建设率，结合当前时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值。
103.进一步的，动态配置模块603，还用于：针对采集系统向网元设备任一次发送的心跳包，若在采集系统向网元设备发送心跳包之后未接收到网元设备返回的心跳包响应，则将采集系统该次向网元设备发送的心跳包作为第二目标心跳包；基于第二目标心跳包对应的心跳间隔重新向网元设备发送心跳包，并同时向与网元设备的长连接的途径节点发送重连提醒。
104.进一步的，采集系统与网元设备的心跳检测装置600还包括：断连确定模块605，用于在基于第二目标心跳包对应的心跳间隔重新向网元设备发送心跳包的连续次数达到预设次数之后，确定网元设备处于断连状态，则向网元设备发送长连接建立请求；长连接重建立模块606，用于接收网元设备返回的长连接建立成功响应，并基于预设的固定心跳间隔向网元设备发送心跳包。
105.进一步的，动态配置模块603，还用于：重新获取网元设备的拥塞状态，并根据拥塞状态确定该网元设备对应的心跳间隔再探测时刻；根据采集系统在心跳间隔再探测时刻的长连接数据、采集系统在心跳间隔再探测时刻的系统负载以及在心跳间隔再探测时刻网元设备对应的平均心跳间隔数据，结合第一心跳间隔调整值，确定待发送的第二心跳包对应的第二心跳间隔调整值，其中，第二心跳包为在确定心跳间隔再探测时刻之后向网元设备发送的第一个心跳包；将固定心跳间隔作为第二心跳包对应的心跳间隔基准值；将心跳间隔基准值与第二心跳间隔调整值的和值作为第二心跳包对应的心跳间隔；第二发送模块604，还用于：基于第二心跳包对应的心跳间隔向网元设备发送心跳包。
106.进一步的，动态配置模块603，还用于：根据心跳间隔再探测时刻采集系统的长连接数据、心跳间隔探测时刻采集系统的系统负载以及网元设备对应的平均心跳间隔数据，确定待发送的第二心跳包对应的第二心跳间隔调整原始值；若第二心跳间隔调整原始值大于等于第一心跳间隔调整值，则将第二心跳间隔调整原始值的一半作为第二心跳间隔调整值；若第二心跳间隔调整原始值小于第一心跳间隔调整值，则将第二心跳间隔调整原始值作为第二心跳间隔调整值。
107.进一步的，采集系统与网元设备的心跳检测装置600还包括：配置模块607，用于将采集系统的ftp空闲超时时间设置为小于网络设备的ftp空闲超时时间。
108.进一步的，采集系统与网元设备的心跳检测装置600还包括：数据接收模块608，用于在采集系统对网元设备的进行数据采集时，接收网元设备发送的压缩数据；解压缩模块609，用于对压缩数据进行解压缩，获取网元设备的话单数据。
109.进一步的，时刻获取模块602，还用于：基于采集系统所采集的网元设备的数据，获取网元设备对应的话单产出数据、话单查询数据和话单账户余额；根据话单产出数据确定话单产出稀疏时段；根据话单查询数据确定话单查询稀疏时段；若话单账户余额大于预定的余额阈值，且话单同时处于话单产出稀疏时段和话单查询稀疏时段，则确定当前时刻为心跳间隔探测时刻。
110.为了实现上述实施例，本技术实施例还提出一种采集系统700，如图7所示，该采集系统700包括：处理器701和处理器通信连接的存储器702，存储器702存储有可被至少一个处理器执行的指令，指令被至少一个处理器701执行，以实现如上述实施例所示的采集系统与网元设备的心跳检测方法。
111.为了实现上述实施例，本技术实施例还提出一种存储有计算机指令的非瞬时计算机可读存储介质，其中，计算机指令用于使计算机实现如上述实施例所示的采集系统与网元设备的心跳检测方法。
112.为了实现上述实施例，本技术实施例还提出一种计算机程序产品，包括计算机程序，计算机程序在被处理器执行时实现如上述实施例所示的采集系统与网元设备的心跳检测方法。
113.在本技术的描述中，需要理解的是，术语“中心”、“纵向”、“横向”、“长度”、“宽度”、“厚度”、“上”、“下”、“前”、“后”、“左”、“右”、“竖直”、“水平”、“顶”、“底”“内”、“外”、“顺时针”、“逆时针”、“轴向”、“径向”、“周向”等指示的方位或位置关系为基于附图所示的方位或位置关系，仅是为了便于描述本技术和简化描述，而不是指示或暗示所指的装置或元件必须具有特定的方位、以特定的方位构造和操作，因此不能理解为对本技术的限制。
114.此外，术语“第一”、“第二”仅用于描述目的，而不能理解为指示或暗示相对重要性或者隐含指明所指示的技术特征的数量。由此，限定有“第一”、“第二”的特征可以明示或者隐含地包括一个或者更多个该特征。在本技术的描述中，“多个”的含义是两个或两个以上，除非另有明确具体的限定。
115.在本说明书的描述中，参考术语“一个实施例”、“一些实施例”、“示例”、“具体示例”、或“一些示例”等的描述意指结合该实施例或示例描述的具体特征、结构、材料或者特点包含于本技术的至少一个实施例或示例中。在本说明书中，对上述术语的示意性表述不必须针对的是相同的实施例或示例。而且，描述的具体特征、结构、材料或者特点可以在任一个或多个实施例或示例中以合适的方式结合。此外，在不相互矛盾的情况下，本领域的技术人员可以将本说明书中描述的不同实施例或示例以及不同实施例或示例的特征进行结合和组合。
116.尽管上面已经示出和描述了本技术的实施例，可以理解的是，上述实施例是示例性的，不能理解为对本技术的限制，本领域的普通技术人员在本技术的范围内可以对上述实施例进行变化、修改、替换和变型。

技术特征：
1.一种采集系统与网元设备的心跳检测方法，由采集系统执行，其特征在于，包括：在采集系统对网元设备的数据采集过程中，针对任一所述网元设备，以预设的固定心跳间隔向所述网元设备发送心跳包，其中，所述采集系统所包含的分发程序和采集程序两者与所述网元设备的连接方式均设置为长连接模式；基于所述采集系统所采集的网元设备的数据，获取所述网元设备对应的拥塞状态，并根据所述拥塞状态确定该网元设备对应的心跳间隔探测时刻；从所述心跳间隔探测时刻开始，根据所述采集系统的长连接数据、所述采集系统的系统负载以及所述网元设备对应的平均心跳间隔数据，动态配置心跳间隔；基于动态配置的所述心跳间隔向所述网元设备发送心跳包。2.根据权利要求1所述的方法，其特征在于，所述从所述心跳间隔探测时刻开始，根据所述采集系统的长连接数据、所述采集系统的系统负载以及所述网元设备对应的平均心跳间隔数据，动态配置心跳间隔，包括：根据所述采集系统在所述心跳间隔探测时刻的长连接数据、所述采集系统在所述心跳间隔探测时刻的系统负载以及在所述心跳间隔探测时刻所述网元设备对应的平均心跳间隔数据，确定待发送的第一心跳包对应的第一心跳间隔调整值，其中，所述第一心跳包为在确定心跳间隔探测时刻之后向所述网元设备发送的第一个心跳包；将所述固定心跳间隔作为所述第一心跳包对应的心跳间隔基准值；将所述心跳间隔基准值与所述第一心跳间隔调整值的和值作为所述第一心跳包对应的心跳间隔。3.根据权利要求2所述的方法，其特征在于，所述将所述心跳间隔基准值与所述第一心跳间隔调整值的和值作为所述第一心跳包对应的心跳间隔之后，还包括：针对所述采集系统向所述网元设备任一次发送的心跳包，若在所述采集系统向所述网元设备发送心跳包之后接收到所述网元设备返回的心跳包响应，则将所述采集系统该次向所述网元设备发送的心跳包作为第一目标心跳包，并将所述第一目标心跳包的心跳间隔作为当前待发送的心跳包对应的心跳间隔基准值；根据当前时刻所述采集系统的长连接数据、当前时刻所述采集系统的系统负载以及所述网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值；将当前待发送的心跳包对应的心跳间隔基准值与所述当前待发送的心跳包对应的心跳间隔调整值的和值作为当前待发送的心跳包对应的心跳间隔。4.根据权利要求3所述的方法，其特征在于，所述根据当前时刻所述采集系统的长连接数据、当前时刻所述采集系统的系统负载以及所述网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值，包括：根据当前时刻所述采集系统的长连接数据，获取当前时刻与所述采集系统建立长连接的网元设备的第一数量值；获取所述采集系统对应的长连接端口均长连接有网元设备的情况下对应的网元设备的第二数量值；将所述第一数量值与所述第二数量值的比值作为所述采集系统当前时刻的长连接建设率；基于所述长连接建设率，结合当前时刻所述采集系统的系统负载以及所述网元设备对
应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值。5.根据权利要求4所述的方法，其特征在于，所述方法，还包括：针对所述采集系统向所述网元设备任一次发送的心跳包，若在所述采集系统向所述网元设备发送心跳包之后未接收到所述网元设备返回的心跳包响应，则将所述采集系统该次向所述网元设备发送的心跳包作为第二目标心跳包；基于所述第二目标心跳包对应的心跳间隔重新向所述网元设备发送心跳包，并同时向与所述网元设备的长连接的途径节点发送重连提醒。6.根据权利要求5所述的方法，其特征在于，所述方法，还包括：在基于所述第二目标心跳包对应的心跳间隔重新向所述网元设备发送心跳包的连续次数达到预设次数之后，确定所述网元设备处于断连状态，则向所述网元设备发送长连接建立请求；接收所述网元设备返回的长连接建立成功响应，并基于预设的所述固定心跳间隔向所述网元设备发送心跳包。7.根据权利要求6所述的方法，其特征在于，所述接收所述网元设备返回的长连接建立成功响应，并基于预设的所述固定心跳间隔向所述网元设备发送心跳包之后，还包括：重新获取所述网元设备的拥塞状态，并根据所述拥塞状态确定该网元设备对应的心跳间隔再探测时刻；根据所述采集系统在所述心跳间隔再探测时刻的长连接数据、所述采集系统在所述心跳间隔再探测时刻的系统负载以及在所述心跳间隔再探测时刻所述网元设备对应的平均心跳间隔数据，结合所述第一心跳间隔调整值，确定待发送的第二心跳包对应的第二心跳间隔调整值，其中，所述第二心跳包为在确定心跳间隔再探测时刻之后向所述网元设备发送的第一个心跳包；将所述固定心跳间隔作为所述第二心跳包对应的心跳间隔基准值；将所述心跳间隔基准值与所述第二心跳间隔调整值的和值作为第二心跳包对应的心跳间隔；基于所述第二心跳包对应的心跳间隔向所述网元设备发送心跳包。8.根据权利要求7所述的方法，其特征在于，所述根据所述采集系统在所述心跳间隔再探测时刻的长连接数据、所述采集系统在所述心跳间隔再探测时刻的系统负载以及在所述心跳间隔再探测时刻所述网元设备对应的平均心跳间隔数据，结合所述第一心跳间隔调整值，确定待发送的第二心跳包对应的第二心跳间隔调整值，包括：根据所述心跳间隔再探测时刻所述采集系统的长连接数据、所述心跳间隔探测时刻所述采集系统的系统负载以及所述网元设备对应的平均心跳间隔数据，确定待发送的第二心跳包对应的第二心跳间隔调整原始值；若所述第二心跳间隔调整原始值大于等于所述第一心跳间隔调整值，则将所述第二心跳间隔调整原始值的一半作为所述第二心跳间隔调整值；若所述第二心跳间隔调整原始值小于所述第一心跳间隔调整值，则将所述第二心跳间隔调整原始值作为所述第二心跳间隔调整值。9.根据权利要求1-8中任一项所述的方法，其特征在于，所述方法还包括：将所述采集系统的文件传输协议ftp空闲超时时间设置为小于所述网络设备的ftp空
闲超时时间。10.根据权利要求1-8中任一项所述的方法，其特征在于，所述方法还包括：在所述采集系统对所述网元设备的进行数据采集时，接收所述网元设备发送的压缩数据；对所述压缩数据进行解压缩，获取所述网元设备的话单数据。11.根据权利要求1所述的方法，其特征在于，所述基于所述采集系统所采集的网元设备的数据，获取所述网元设备对应的拥塞状态，并根据所述拥塞状态确定该网元设备对应的心跳间隔探测时刻，包括：基于所述采集系统所采集的网元设备的数据，获取所述网元设备对应的话单产出数据、话单查询数据和话单账户余额；根据所述话单产出数据确定话单产出稀疏时段；根据所述话单查询数据确定话单查询稀疏时段；若所述话单账户余额大于预定的余额阈值，且所述话单同时处于所述话单产出稀疏时段和所述话单查询稀疏时段，则确定当前时刻为所述心跳间隔探测时刻。12.一种采集系统与网元设备的心跳检测装置，其特征在于，包括：第一发送模块，用于在采集系统对网元设备的数据采集过程中，针对任一所述网元设备，以预设的固定心跳间隔向所述网元设备发送心跳包，其中，所述采集系统所包含的分发程序和采集程序两者与所述网元设备的连接方式均设置为长连接模式；时刻获取模块，用于基于所述采集系统所采集的网元设备的数据，获取所述网元设备对应的拥塞状态，并根据所述拥塞状态确定该网元设备对应的心跳间隔探测时刻；动态配置模块，用于从所述心跳间隔探测时刻开始，根据所述采集系统的长连接数据、所述采集系统的系统负载以及所述网元设备对应的平均心跳间隔数据，动态配置心跳间隔；第二发送模块，用于基于动态配置的所述心跳间隔向所述网元设备发送心跳包。13.根据权利要求12所述的装置，其特征在于，所述动态配置模块，还用于：根据所述采集系统在所述心跳间隔探测时刻的长连接数据、所述采集系统在所述心跳间隔探测时刻的系统负载以及在所述心跳间隔探测时刻所述网元设备对应的平均心跳间隔数据，确定待发送的第一心跳包对应的第一心跳间隔调整值，其中，所述第一心跳包为在确定心跳间隔探测时刻之后向所述网元设备发送的第一个心跳包；将所述固定心跳间隔作为所述第一心跳包对应的心跳间隔基准值；将所述心跳间隔基准值与所述第一心跳间隔调整值的和值作为所述第一心跳包对应的心跳间隔。14.根据权利要求13所述的装置，其特征在于，所述动态配置模块，还用于：针对所述采集系统向所述网元设备任一次发送的心跳包，若在所述采集系统向所述网元设备发送心跳包之后接收到所述网元设备返回的心跳包响应，则将所述采集系统该次向所述网元设备发送的心跳包作为第一目标心跳包，并将所述第一目标心跳包的心跳间隔作为当前待发送的心跳包对应的心跳间隔基准值；根据当前时刻所述采集系统的长连接数据、当前时刻所述采集系统的系统负载以及所述网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值；
将当前待发送的心跳包对应的心跳间隔基准值与所述当前待发送的心跳包对应的心跳间隔调整值的和值作为当前待发送的心跳包对应的心跳间隔。15.根据权利要求14所述的装置，其特征在于，所述动态配置模块，还用于：根据当前时刻所述采集系统的长连接数据，获取当前时刻与所述采集系统建立长连接的网元设备的第一数量值；获取所述采集系统对应的长连接端口均长连接有网元设备的情况下对应的网元设备的第二数量值；将所述第一数量值与所述第二数量值的比值作为所述采集系统当前时刻的长连接建设率；基于所述长连接建设率，结合当前时刻所述采集系统的系统负载以及所述网元设备对应的平均心跳间隔数据，确定当前待发送的心跳包对应的心跳间隔调整值。16.根据权利要求15所述的装置，其特征在于，所述动态配置模块，还用于：针对所述采集系统向所述网元设备任一次发送的心跳包，若在所述采集系统向所述网元设备发送心跳包之后未接收到所述网元设备返回的心跳包响应，则将所述采集系统该次向所述网元设备发送的心跳包作为第二目标心跳包；基于所述第二目标心跳包对应的心跳间隔重新向所述网元设备发送心跳包，并同时向与所述网元设备的长连接的途径节点发送重连提醒。17.根据权利要求16所述的装置，其特征在于，所述装置还包括：断连确定模块，用于在基于所述第二目标心跳包对应的心跳间隔重新向所述网元设备发送心跳包的连续次数达到预设次数之后，确定所述网元设备处于断连状态，则向所述网元设备发送长连接建立请求；长连接重建立模块，用于接收所述网元设备返回的长连接建立成功响应，并基于预设的所述固定心跳间隔向所述网元设备发送心跳包。18.根据权利要求17所述的装置，其特征在于，所述动态配置模块，还用于：重新获取所述网元设备的拥塞状态，并根据所述拥塞状态确定该网元设备对应的心跳间隔再探测时刻；根据所述采集系统在所述心跳间隔再探测时刻的长连接数据、所述采集系统在所述心跳间隔再探测时刻的系统负载以及在所述心跳间隔再探测时刻所述网元设备对应的平均心跳间隔数据，结合所述第一心跳间隔调整值，确定待发送的第二心跳包对应的第二心跳间隔调整值，其中，所述第二心跳包为在确定心跳间隔再探测时刻之后向所述网元设备发送的第一个心跳包；将所述固定心跳间隔作为所述第二心跳包对应的心跳间隔基准值；将所述心跳间隔基准值与所述第二心跳间隔调整值的和值作为第二心跳包对应的心跳间隔；所述第二发送模块，还用于：基于所述第二心跳包对应的心跳间隔向所述网元设备发送心跳包。19.根据权利要求18所述的装置，其特征在于，所述动态配置模块，还用于：根据所述心跳间隔再探测时刻所述采集系统的长连接数据、所述心跳间隔探测时刻所述采集系统的系统负载以及所述网元设备对应的平均心跳间隔数据，确定待发送的第二心跳包对应的第二心跳间隔调整原始值；若所述第二心跳间隔调整原始值大于等于所述第一心跳间隔调整值，则将所述第二心跳间隔调整原始值的一半作为所述第二心跳间隔调整值；
若所述第二心跳间隔调整原始值小于所述第一心跳间隔调整值，则将所述第二心跳间隔调整原始值作为所述第二心跳间隔调整值。20.根据权利要求12-19任一项所述的装置，其特征在于，所述装置还包括：配置模块，用于将所述采集系统的ftp空闲超时时间设置为小于所述网络设备的ftp空闲超时时间。21.根据权利要求12-19任一项所述的装置，其特征在于，所述装置还包括：数据接收模块，用于在所述采集系统对所述网元设备的进行数据采集时，接收所述网元设备发送的压缩数据；解压缩模块，用于对所述压缩数据进行解压缩，获取所述网元设备的话单数据。22.根据权利要求12所述的装置，其特征在于，所述时刻获取模块，还用于：基于所述采集系统所采集的网元设备的数据，获取所述网元设备对应的话单产出数据、话单查询数据和话单账户余额；根据所述话单产出数据确定话单产出稀疏时段；根据所述话单查询数据确定话单查询稀疏时段；若所述话单账户余额大于预定的余额阈值，且所述话单同时处于所述话单产出稀疏时段和所述话单查询稀疏时段，则确定当前时刻为所述心跳间隔探测时刻。23.一种采集系统，包括：至少一个处理器；以及与所述至少一个处理器通信连接的存储器；其中，所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以使所述至少一个处理器能够执行权利要求1-11中任一项所述的方法。24.一种存储有计算机指令的非瞬时计算机可读存储介质，其中，所述计算机指令用于使所述计算机执行根据权利要求1-11中任一项所述的方法。25.一种计算机程序产品，包括计算机程序，所述计算机程序在被处理器执行时实现根据权利要求1-11中任一项所述的方法。

技术总结
本申请提出了一种采集系统与网元设备的心跳检测方法及其装置，涉及通信技术领域，在采集系统对网元设备的数据采集过程中，针对任一网元设备，以固定心跳间隔向网元设备发送心跳包，采集系统与网元设备的连接方式设置为长连接模式；所采集的网元设备的数据，获取网元设备对应的拥塞状态，根据拥塞状态确定该网元设备对应的心跳间隔探测时刻；从心跳间隔探测时刻开始，根据采集系统的长连接数据、采集系统的系统负载以及网元设备对应的平均心跳间隔数据，动态配置心跳间隔；基于动态配置的心跳间隔向网元设备发送心跳包。本申请可以避免短连接的频繁建立和断开，通过动态配置心跳间隔，避免过于频繁的心跳包发送，减少带宽和服务器资源的消耗。务器资源的消耗。务器资源的消耗。


技术研发人员：黄磊 郭晓玲
受保护的技术使用者：中国移动通信集团河南有限公司
技术研发日：2023.07.17
技术公布日：2023/10/20