日志数据推送方法、装置、设备及存储介质与流程

本申请涉及网络通信领域，尤其涉及一种日志数据推送方法、装置、设备及存储介质。

背景技术：

1、在监控企业应用的日志数据时，相关的日志数据推送方法通常采用定时轮询和复杂协议采集全量日志数据，再将所有日志数据无差别广播至所有客户端，不仅数据获取延迟高，还会有大量无关数据占用带宽，导致日志数据推送效率低下。

技术实现思路

1、本申请的主要目的在于提供一种日志数据推送方法、装置、设备及存储介质，旨在解决在监控企业应用的日志数据时，存在数据获取延迟高，无关数据占用带宽大，导致日志数据推送效率低下的技术问题。

2、为实现上述目的，本申请提供一种日志数据推送方法，所述日志数据推送方法包括：

3、对目标日志文件注册文件事件监听器，获得变化日志数据；

4、基于预设推送协议建立服务器和客户端之间的长连接，获得所述客户端的订阅规则；

5、根据所述订阅规则对所述变化日志数据进行筛选，获得目标日志数据；

6、将所述目标日志数据推送至目标客户端。

7、可选地，所述对目标日志文件注册文件事件监听器，获得变化日志数据，包括：

8、通过文件监听机制对目标日志文件所在的日志文件目录进行监听注册，获得文件事件；

9、若所述文件事件类型为写入事件，则确定所述目标日志文件的日志数据存在增量更新，基于所述增量更新触发日志读取事件；

10、响应于所述日志读取事件，对增量日志数据进行读取，获得变化日志数据。

11、可选地，所述对增量日志数据进行读取，获得变化日志数据，包括：

12、获取所述目标日志文件的文件游标，所述文件游标包括读取位置标识；

13、根据所述读取位置标识从所述目标日志文件中读取增量日志数据；

14、对所述增量日志数据进行标准化处理，获得变化日志数据。

15、可选地，所述基于预设推送协议建立服务器和客户端之间的长连接，获得所述客户端的订阅规则，包括：

16、响应于客户端的连接请求，基于预设推送协议建立服务器和所述客户端之间的长连接；

17、根据所述长连接生成所述客户端的会话标识；

18、基于所述长连接获取所述客户端的订阅请求；

19、对所述会话标识和所述订阅请求进行关联映射，获得所述客户端的订阅规则。

20、可选地，所述响应于客户端的连接请求，响应于客户端的连接请求，基于预设推送协议建立服务器和所述客户端之间的长连接之后，还包括：

21、基于预设时间周期检测所述服务器和所述客户端之间的长连接状态；

22、若检测到所述长连接状态为连接中断，则清理所述服务器和所述客户端之间的会话资源，并启动所述客户端的自动重连机制。

23、可选地，所述根据所述订阅规则对所述变化日志数据进行筛选，获得目标日志数据，包括：

24、根据所述客户端的订阅规则对所述变化日志数据进行条件校验；

25、若校验通过，则将所述变化日志数据作为目标日志数据。

26、可选地，所述将所述目标日志数据推送至目标客户端之后，还包括：

27、若服务器的推送服务性能占用达到预设性能阈值，则增加服务节点；

28、将所述客户端的连接请求通过负载均衡器分发至所述服务节点，所述服务节点数量根据推送服务需求动态调整。

29、此外，为实现上述目的，本申请还提出一种日志数据推送装置，所述日志数据推送装置包括：

30、日志监听模块，用于对目标日志文件注册文件事件监听器，获得变化日志数据；

31、连接建立模块，用于基于预设推送协议建立服务器和客户端之间的长连接，获得所述客户端的订阅规则；

32、数据筛选模块，用于根据所述订阅规则对所述变化日志数据进行筛选，获得目标日志数据；

33、日志推送模块，用于将所述目标日志数据推送至目标客户端。

34、此外，为实现上述目的，本申请还提出一种日志数据推送设备，所述日志数据推送设备包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的日志数据推送程序，所述日志数据推送程序配置为实现如上文所述的日志数据推送方法。

35、此外，为实现上述目的，本申请还提出一种存储介质，所述存储介质上存储有日志数据推送程序，所述日志数据推送程序被处理器执行时实现如上文所述的日志数据推送方法。

36、本申请提出的一个或多个技术方案，至少具有以下技术效果：

37、在本申请中，公开了对目标日志文件注册文件事件监听器，获得变化日志数据，基于预设推送协议建立服务器和客户端之间的长连接，获得客户端的订阅规则，根据订阅规则对所述变化日志数据进行筛选，获得目标日志数据，将目标日志数据推送至目标客户端；由于本申请通过监听注册实时获取变化日志数据，同时建立服务器与客户端之间的长连接获取客户端的订阅规则，再结合订阅规则筛选并推送日志数据，从而在源头削减待处理量，避免带宽浪费，显著降低日志推送的链路延迟，提高日志数据推送效率。

1.一种日志数据推送方法，其特征在于，所述日志数据推送方法包括：

2.如权利要求1所述的日志数据推送方法，其特征在于，所述对目标日志文件注册文件事件监听器，获得变化日志数据，包括：

3.如权利要求2所述的日志数据推送方法，其特征在于，所述对增量日志数据进行读取，获得变化日志数据，包括：

4.如权利要求1至3中任一项所述的日志数据推送方法，其特征在于，所述基于预设推送协议建立服务器和客户端之间的长连接，获得所述客户端的订阅规则，包括：

5.如权利要求4所述的日志数据推送方法，其特征在于，所述响应于客户端的连接请求，响应于客户端的连接请求，基于预设推送协议建立服务器和所述客户端之间的长连接之后，还包括：

6.如权利要求1至3中任一项所述的日志数据推送方法，其特征在于，所述根据所述订阅规则对所述变化日志数据进行筛选，获得目标日志数据，包括：

7.如权利要求1至3中任一项所述的日志数据推送方法，其特征在于，所述将所述目标日志数据推送至目标客户端之后，还包括：

8.一种日志数据推送装置，其特征在于，所述日志数据推送装置包括：

9.一种日志数据推送设备，其特征在于，所述设备包括：存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序，所述计算机程序配置为实现如权利要求1至7中任一项所述的日志数据推送方法的步骤。

10.一种存储介质，其特征在于，所述存储介质为计算机可读存储介质，所述存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如权利要求1至7中任一项所述的日志数据推送方法的步骤。