CN115086339A - 一种数据监控系统、方法及可读存储介质 - Google Patents

Abstract

本申请公开了一种数据监控系统及方法，包括：服务网关，用于获得不少于一个大屏设备的上报数据，并将上报数据转发至收集服务集群；收集服务集群，包括不少于一个收集服务节点，用于分别获得服务网关转发的上报数据，并将上报数据存储至预设存储系统；预设存储系统，包括不少于一个预设存储节点，分别用于存储不同的大屏设备的上报数据；小屏数据接口，与服务网关相连，用于获得小屏设备的数据请求，基于数据请求通过服务网关获得通过收集服务集群存储至预设存储节点的与小屏设备对应的大屏设备的状态信息。

Description

一种数据监控系统、方法及可读存储介质

技术领域

本申请涉及数据监控领域，尤其涉及一种数据监控系统、方法及可读存储介质。

背景技术

在在线教学领域，通常是由学生通过平板电脑、电视等大屏设备观看学习内容，家长通过手机等小屏设备获取学习状态。

其中，大屏设备实时向服务端发送行为数据，小屏设备通过获得服务端的数据确定大屏设备的学习状态，这就需要大屏设备与小屏设备之间采用长连接的方式实现小屏设备对大屏设备的状态的获取。若较多的大屏设备与小屏设备建立连接，就会对服务端的服务造成极大的压力。

发明内容

有鉴于此，本申请提供一种数据监控系统、方法及可读存储介质，其具体方案如下：

一种数据监控系统，包括：

服务网关，用于获得不少于一个大屏设备的上报数据，并将所述上报数据转发至收集服务集群；

收集服务集群，包括不少于一个收集服务节点，用于分别获得所述服务网关转发的上报数据，并将所述上报数据存储至预设存储系统；

预设存储系统，包括不少于一个预设存储节点，用于分别存储大屏设备的上报数据；

小屏数据接口，与所述服务网关相连，用于获得小屏设备的数据请求，并基于所述数据请求通过所述服务网关获得通过所述收集服务集群存储至预设存储节点的与所述小屏设备对应的大屏设备的状态信息，其中，所述状态信息基于所述上报数据确定。

进一步的，所述收集服务集群还用于：

在获得大屏设备通过服务网关转发的上报数据后，基于所述上报数据确定所述大屏设备的状态信息。

进一步的，所述收集服务集群基于所述上报数据确定所述大屏设备的状态信息，包括：

所述收集服务集群获得所述服务网关转发的大屏设备的上报数据，确定所述大屏设备的状态为在线状态；若所述收集服务集群在预设时段内未获得所述服务网关转发的大屏设备的上报数据，确定所述大屏设备的状态为异常状态；

或，

所述收集服务集群获得所述服务网关转发的大屏设备的上报数据，对所述上报数据进行分析，基于对所述上报数据进行分析得到的分析结果确定所述大屏设备的状态为在线状态或异常状态。

进一步的，所述收集服务集群还用于：

所述收集服务集群中的每个收集服务节点分别与一个所述预设存储节点连接，若所述收集服务节点确定与其连接的预设存储节点在第一预设时长内未接收到第一大屏设备发送的上报数据，则确定所述第一大屏设备的状态为离线状态，其中，所述第一大屏设备为所述不少于一个大屏设备中的至少一个。

进一步的，所述若所述收集服务节点确定与其连接的预设存储节点在第一预设时长内未接收到第一大屏设备发送的上报数据，则确定所述第一大屏设备的状态为离线状态，包括：

若所述收集服务节点确定与其连接的预设存储节点在第二预设时长内未接收到第一大屏设备发送的上报数据，确定补偿时长，所述补偿时长用于延长第一大屏设备发送上报数据的预设时长，其中，所述第二预设时长小于所述第一预设时长；

若确定在所述补偿时长内未接收到所述第一大屏设备发送的上报数据，则确定所述第一大屏设备的状态为离线状态；

若确定在所述补偿时长内接收到所述第一大屏设备发送的上报数据，存储所述上报数据至所述预设存储节点。

进一步的，还包括：

小屏服务集群，包括不少于一个小屏服务节点，分别与所述小屏数据接口连接，用于获得所述小屏设备的数据请求，基于发送所述数据请求的小屏设备确定与所述数据请求对应的小屏服务节点，以便于所述小屏服务节点能够基于所述数据请求输出大屏数据请求至所述服务网关，从而获得与所述大屏数据请求对应的大屏设备的状态数据。

一种数据监控方法，包括：

获得不少于一个大屏设备的上报数据；

确定获得的所述上报数据对应的收集服务节点，通过对应的所述收集服务节点转发所述上报数据；

将所述上报数据存储至与所述收集服务节点对应的预设存储节点，以便于当获得小屏设备的数据请求时，能够通过对应的所述收集服务节点从所述预设存储节点获得与所述小屏设备对应的大屏设备的状态信息，其中，所述状态信息基于所述上报数据确定。

进一步的，还包括：

在获得大屏设备发送的上报数据后，基于所述上报数据确定所述大屏设备的状态信息，并将所述状态信息与所述上报数据对应存储。

进一步的，所述基于所述上报数据确定所述大屏设备的状态信息，包括：

在获得所述大屏设备发送的上报数据后，确定所述大屏设备的状态为在线状态；若在预设时段内未获得所述大屏设备的上报数据，确定所述大屏设备的状态为异常状态；

或，

在获得所述大屏设备发送的上报数据后，对所述上报数据进行分析，基于对所述上报数据进行分析得到的分析结果确定所述大屏设备的状态为在线状态或异常状态。

一种可读存储介质，用于至少存储一组指令集；

所述指令集用于被调用并至少执行如上任一项的数据监控的方法。

从上述技术方案可以看出，本申请公开的数据监控系统及方法，包括：服务网关，用于获得不少于一个大屏设备的上报数据，并将上报数据转发至收集服务集群；收集服务集群，包括不少于一个收集服务节点，用于分别获得服务网关转发的上报数据，并将上报数据存储至预设存储系统；预设存储系统，包括不少于一个预设存储节点，分别用于存储不同的大屏设备的上报数据；小屏数据接口，与服务网关相连，用于获得小屏设备的数据请求，基于数据请求通过服务网关获得通过收集服务集群存储至预设存储节点的与小屏设备对应的大屏设备的状态信息，其中，状态信息基于上报数据确定。本方案通过收集服务集群实现对获得的多个大屏设备的数据的分别存储，并在小屏设备需要获得相应的大屏设备的状态数据时，能够通过收集服务集群实现对存储有相应上报数据的预设存储节点的访问，避免了大屏设备与小屏设备的长连接，缓解了服务端的压力。

附图说明

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

图1为本申请实施例公开的一种数据监控系统的结构示意图；

图2为本申请实施例公开的一种大屏设备发送上报数据的示意图；

图3为本申请实施例公开的一种数据监控系统的结构示意图；

图4为本申请实施例公开的一种小屏设备发送大屏数据请求的示意图；

图5为本申请实施例公开的一种数据监控方法的流程图。

具体实施方式

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

本申请公开了一种数据监控系统，其结构示意图如图1所示，包括：

服务网关11，收集服务集群12，预设存储系统13及小屏数据接口14。

其中，服务网关用于获得不少于一个大屏设备的上报数据，并将上报数据转发至收集服务集群；

收集服务集群包括不少于一个收集服务节点，用于分别获得服务网关转发的上报数据，并将上报数据存储至预设存储系统；

预设存储系统包括不少于一个预设存储节点，用于分别存储到设备的上报数据；

小屏数据接口，与服务网关相连，用于获得小屏设备的数据请求，并基于数据请求通过服务网关获得通过收集服务集群存储至预设存储节点的与小屏设备对应的大屏设备的状态信息，其中，状态信息基于上报数据确定。

在线教学过程中，学生通过大屏设备学习，为了使家长能够实时获得学生的学习状态，确定其当前是否在学习，或者确定该大屏设备是否正常运行，可以将家长手持的小屏设备与大屏设备绑定，以便于当家长需要获得学生的学习状态时，可以通过小屏设备获取大屏设备的当前运行状态，从而确定学生通过大屏设备进行学习的进度或是否正在学习的状态。

若直接将大屏设备与小屏设备通过一个服务器绑定，当有大量的大屏设备及小屏设备同时在线时，就会对服务器的运行造成一定的影响，降低用户体验。

为了避免这一问题，本方案中通过具有不少于一个收集服务节点的收集服务集群获得多个大屏设备的数据，通过多个收集服务节点分别获得多个大屏设备的数据，就降低了每个收集服务节点的数据处理量，避免了大量的大小屏设备同时在线时，一个收集服务节点的数据处理量过大的问题。

本实施例公开的数据监控系统包括服务网关，该服务网关用于获得不少于一个大屏设备的上报数据，并能够将上报数据转发至收集服务集群中。

服务网关具体为微服务网关，其中，微服务是一种架构，一个大型复杂软件应用由一个或多个微服务组成。在微服务架构中，不同的微服务可以有不同的网络地址，各个微服务之间通过互相调用完成用户请求。在客户端和服务端之间增加微服务网关，通过微服务网关获得客户端的请求，由微服务网关对各个微服务进行调用。

通过服务网关获得所有接入系统的设备的数据，并对接收到的数据进行转发。具体的，服务网关可获得接入系统的所有大屏设备发送的上报数据，以便于对所有上报数据进行转发，便于存储；另外，服务网关还可以获得接入系统的所有小屏设备发送的数据请求，以便于对所有数据请求进行转发，便于在获得请求的数据后，将请求的数据发送至相应的小屏设备。

在服务网关获得大屏设备的上报数据后，将上报数据转发至收集服务集群，收集服务集群是由多个收集服务节点组成的，每个收集服务节点分别用于获得服务网关转发的上报数据，并将上报数据存储至预设存储系统。

收集服务集群中的每个收集服务节点均用于获得服务网关转发的数据，只是不同的收集服务节点用于获得服务网关转发的不同的数据，每一个收集服务节点能够获得不同的设备发送至服务网关的数据。

若服务网关获得大屏设备的上报数据，则服务网关将大屏设备的上报数据发送至收集服务集群中的一个特定的收集服务节点，该收集服务节点用于接收特定的大屏设备发送的上报数据，则这些特定的大屏设备发送的上报数据均会通过服务网关被发送至该特定的收集服务节点，即收集服务节点与大屏设备是相互对应的关系，其可以具体为一对多的关系，即一个收集服务节点可以与多个大屏设备对应。其中，服务网关将获得的大屏设备的上报数据转发至收集服务集群时，服务网关以负载均衡的方式直接将上报数据转发至收集服务节点中。

收集服务集群中包括多个收集服务节点，每个收集服务节点可以与多个大屏设备对应，这就使得收集服务集群能够获得较多的大屏设备的数据，并分别通过收集服务节点对获得的数据进行处理转发，以便于通过不同的收集服务节点对较多的大屏设备的数据进行处理，从而提高数据处理的速度。

收集服务节点将获得的服务网关转发的上报数据存储至预设存储系统，预设存储系统中包括不少于一个预设存储节点，每个预设存储节点分别用于存储不同的大屏设备的上报数据。

预设存储系统可以为redis集群，redis集群为一个高性能的key-value存储系统，预设存储节点即为redis节点。

收集服务集群获取到的上报数据，可以均匀存储至不同的redis节点中，以使不同的redis节点存储的数据量相同或大致相同。

收集服务节点可以与预设存储节点为一一对应的关系，也可以为一对多或者多对一的关系，即一个收集服务节点接收到的待存储的数据可以存储在一个预设存储节点中，也可以分别存储在不同的预设存储节点中，或者，多个收集服务节点接收到的待存储的数据可以存储在一个预设存储节点中，也可以分别存储在多个预设存储节点中。

以收集服务节点与预设存储节点一一对应为例，即收集服务集群中有预设数量的收集服务节点，则预设存储系统中有预设数量的预设存储节点，每一个收集服务节点均有一个对应的预设存储节点，通过服务网关转发的上报数据经过收集服务节点，会被存储至与该收集服务节点对应的预设存储节点。

具体的，大屏设备发送的上报数据存储的框图如图2所示，包括：大屏设备21，服务网关22，收集服务集群23，预设存储系统24。其中，大屏设备21包括：第一大屏设备211，第二大屏设备212及第三大屏设备213；收集服务集群23中包括多个收集服务节点231，预设存储系统24中包括多个预设存储节点241，并且，预设存储节点与收集服务节点是一一对应的关系。其上报数据的存储流程可以为：不同的大屏设备分别发送上报数据至服务网关，服务网关将接收到的较多的上报数据分别转发至不同的收集服务节点，收集服务节点将其接收到的上报数据分别发送至对应的预设存储节点中进行存储。

其中，第一大屏设备、第二大屏设备及第三大屏设备分别为不同的大屏设备。

对应的，若服务网关获得的是小屏设备发送的数据请求，服务网关通过小屏数据接口获得小屏设备发送的数据请求，服务网关同样能够获得不同的小屏设备发送的数据请求。

具体的，预先将小屏设备与大屏设备进行关联，以便于当小屏设备发送数据请求时，直接从预设存储系统中查找与小屏设备关联的大屏设备的相关数据进行反馈；或者，也可以为，在获得小屏设备发送的数据请求后，基于数据请求确定其指定的大屏设备，从预设存储系统中查找该大屏设备的相关数据进行反馈。

本实施例公开的数据监控系统，包括：服务网关，用于获得不少于一个大屏设备的上报数据，并将上报数据转发至收集服务集群；收集服务集群，包括不少于一个收集服务节点，用于分别获得服务网关转发的上报数据，并将上报数据存储至预设存储系统；预设存储系统，包括不少于一个预设存储节点，分别用于存储不同的大屏设备的上报数据；小屏数据接口，与服务网关相连，用于获得小屏设备的数据请求，基于数据请求通过服务网关获得通过收集服务集群存储至预设存储节点的与小屏设备对应的大屏设备的状态信息，其中，状态信息基于上报数据确定。本方案通过收集服务集群实现对获得的多个大屏设备的数据的分别存储，并在小屏设备需要获得相应的大屏设备的状态数据时，能够通过收集服务集群实现对存储有相应上报数据的预设存储节点的访问，避免了大屏设备与小屏设备的长连接，缓解了服务端的压力。

本实施例公开了一种数据监控系统，其结构示意图如图1所示，包括：

服务网关11，收集服务集群12，预设存储系统13及小屏数据接口14。

除与上一实施例相同的结构外，本实施例中的收集服务集群还能够用于：在获得大屏设备通过服务网关转发的上报数据后，基于上报数据确定大屏设备的状态信息。

大屏设备发送上报数据至服务网关，以便于对其进行存储，该上报数据可以为：能够表明大屏设备当前处于在线教学的过程中的数据，如：大屏设备与在线教学系统有交互信号的传输，或者，大屏设备上的在线教学系统处于在线教学的状态，或者，大屏设备拍摄大屏设备的用户学习的照片或短视频等。

收集服务集群在获得大屏设备发送的上报数据后，对上报数据进行分析，确定大屏设备的状态信息，基于该上报数据确定大屏设备当前是处于在线状态，还是处于异常状态。

若确定大屏设备的状态为在线状态，则通过相应的预设存储节点存储该大屏设备的上报数据的同时，存储其状态信息；若确定大屏设备的状态为异常状态，则通过相应的预设存储节点存储该大屏设备的上报数据的同时，存储器状态信息，同时，还可以发送异常状态的提示信息至小屏设备。

进一步的，收集服务集群基于上报数据确定大屏设备的状态信息，可以为：

收集服务集群获得服务网关转发的大屏设备的上报数据，则直接确定大屏设备的状态为在线状态；若收集服务集群在预设时段内未获得服务网关转发的大屏设备的上报数据，确定大屏设备的状态为异常状态。

即只要收集服务集群接收到服务网关转发的大屏设备的上报数据，无需对该上报数据进行分析，就可以直接确定大屏设备当前处于在线状态，若大屏设备的状态为异常状态，则不会发送上报数据至服务网关，即只有大屏设备处于在线教学的状态时，大屏设备才会发送上报数据至服务网关。

具体的，在大屏设备处于在线状态时，设置预设时间间隔，从大屏设备切换为在线状态的时刻开始，每间隔该预设时间间隔，就发送一次上报数据至服务网关，以便于收集服务集群能够对大屏设备的状态进行监控；只要间隔预设时间间隔没有接收到大屏设备发送的上报数据，就认为大屏设备处于异常状态。

或者，收集服务集群获得服务网关转发的大屏设备的上报数据，对上报数据进行分析，基于对上报数据进行分析得到的分析结果确定大屏设备的状态为在线状态或异常状态。

具体的，无论大屏设备的状态如何，大屏设备都会间隔一定时长发送一次上报数据，收集服务集群在获得大屏设备的上报数据后，并不能直接基于上报数据确定大屏设备当前是否处于在线状态，需要对其进行分析，大屏设备处于在线状态时与其处于异常状态时，其上报数据中的内容是不同的，因此，基于对上报数据的分析能够确定大屏设备的当前状态。

在确定大屏设备的状态为在线状态时，则收集服务集群为该大屏设备的状态续约，以使小屏设备通过收集服务集群获取大屏设备的状态时，能够确定该大屏设备在什么时间段处于持续在线状态，在什么时间段处于异常状态。

进一步的，收集服务集群中的每个收集服务节点分别与一个预设存储节点连接，若收集服务节点确定与其连接的预设存储节点在第一预设时长内未接收到第一大屏设备发送的上报数据，则确定第一大屏设备的状态为离线状态。

收集服务集群不仅能够通过是否接收到服务网关转发的大屏设备的上报数据确定大屏设备的状态，还能够通过对预设存储节点进行分析，确定哪一个预设存储节点是否长时间未收到上报数据，或者，哪一个预设存储节点是否长时间未收到满足预设数据量的上报数据。

每个预设存储节点每间隔一定的时长能够存储一定数据量的上报数据，该一定数据量的上报数据可以为一个大屏设备的上报数据，也可以为预设几个大屏设备的上报数据，该一定的时长可以为第一预设时长。当在该一定的时长内没有接收到上报数据，或者没有接收到满足预设数据量的上报数据时，可确定大屏设备的状态为离线状态。

若确定某个大屏设备的状态为离线状态，则可以将该大屏设备的标识信息从在线列表中删除，以便于记录存储。该在线列表可以为用于存储该大屏设备的预设存储节点中的列表，该列表中包括该预设存储节点所存储的上报数据中处于在线状态的大屏设备的标识信息箱。

其中，异常状态包括离线状态，也包括其他状态，如：正常下线状态等。

进一步的，若收集服务节点确定与其连接的预设存储节点在第二预设时长内未接收到第一大屏设备发送的上报数据，确定补偿时长，补偿时长用于延长大屏设备发送上报数据的预设时长，其中，第二预设时长小于第一预设时长；若确定在补偿时长内未接收到第一大屏设备发送的上报数据，则确定第一大屏设备的状态为离线状态；若确定在补偿时长内接收到第一大屏设备发送的上报数据，存储上报数据至预设存储节点。

确定大屏设备处于离线状态的过程，可具体为：首先由收集服务节点确定预设存储节点在第二预设时长内未接收到第一大屏设备发送的上报数据，该第二预设时长可以为第一大屏设备预先设定需要发送上报数据的预设时间间隔，若在该预设时间间隔内预设存储节点没有接收到待存储的上报数据，则为了避免网络延时或者收集服务节点的问题导致的任务的卡顿，设置一个补偿时长，只要在该补偿时长内，能够接收到第一大屏设备发送的上报数据并对其进行存储，则可确定第一大屏设备处于在线状态，其在第二预设时长内未接收到上报数据，可能是由于网络延时或者收集服务节点的问题导致的任务卡顿造成的；若在补偿时长内，仍没有接收到第一大屏设备发送的上报数据，则可以确定该第一大屏设备为离线状态，而非是任务卡顿导致的，从而保证大屏设备只要在该补偿时长内发送上报数据就确认其处于在线状态，避免误删的情况发生。

进一步的，若在补偿时长内，预设存储节点接收到第一大屏设备发送的上报数据，则重新调整第一大屏设备发送上报数据的时间节点，从预设存储节点接收到第一大屏设备发送的上报数据的时刻开始，每间隔预设时间间隔由第一大屏设备发送一次上报数据，以保证对第一大屏设备的状态确定的准确性。

本实施例公开的数据监控系统，包括：服务网关，用于获得不少于一个大屏设备的上报数据，并将上报数据转发至收集服务集群；收集服务集群，包括不少于一个收集服务节点，用于分别获得服务网关转发的上报数据，并将上报数据存储至预设存储系统；预设存储系统，包括不少于一个预设存储节点，分别用于存储不同的大屏设备的上报数据；小屏数据接口，与服务网关相连，用于获得小屏设备的数据请求，基于数据请求通过服务网关获得通过收集服务集群存储至预设存储节点的与小屏设备对应的大屏设备的状态信息，其中，所述状态信息基于所述上报数据确定。本方案通过收集服务集群实现对获得的多个大屏设备的数据的分别存储，并在小屏设备需要获得相应的大屏设备的状态数据时，能够通过收集服务集群实现对存储有相应上报数据的预设存储节点的访问，避免了大屏设备与小屏设备的长连接，缓解了服务端的压力。

本实施例公开了一种数据监控系统，其结构示意图如图3所示，包括：

服务网关31，收集服务集群32，预设存储系统33，小屏数据接口34及小屏服务集群35。

除与上一实施例相同的结构外，本实施例公开的数据监控系统还可以包括：小屏服务集群。

其中，小屏服务集群包括不少于一个小屏服务节点，分别与小屏数据接口连接，用于获得小屏设备的数据请求，基于发送数据请求的小屏设备确定与数据请求对应的小屏服务节点，以便于小屏服务节点能够给予数据请求输出大屏数据请求至服务网关，从而获得与大屏数据请求对应的大屏设备的状态数据。

小屏服务集群中包括多个小屏服务节点，多个小屏服务节点的作用是相同的，分别用于获得不同的小屏设备的数据请求，每个小屏服务节点可以获得多个小屏设备的数据请求，不同的小屏服务节点获得的数据请求的来源不同。

在小屏服务集群中设置多个小屏服务节点的功能与在收集服务集群中设置多个收集服务节点的功能相同，均是为了使服务节点能够获得更多的数据，并能够同时处理，以提高数据的处理速度，降低每个服务节点的数据处理量。

具体的，小屏设备发送大屏数据请求的框图如图4所示，包括：小屏服务集群41，小屏服务集群包括的多个小屏服务节点411，服务网关42，收集服务集群43，以及收集服务集群包括的多个收集服务节点431。

当小屏服务集群中的某个小屏服务节点接收到大屏数据请求，即某个小屏设备请求获得大屏设备的状态信息，则用户会通过小屏设备发出数据请求，则小屏服务器节点接收到该数据请求，小屏服务节点基于该数据请求可以确定该数据请求是为了获取大屏设备的状态信息的大屏设备请求，则该小屏服务节点将该大屏数据请求通过服务网关进行转发，转发至收集服务集群中与该大屏数据请求中的大屏数据对应的收集服务节点中，通过该收集服务节点从对应的预设存储节点中调取该大屏数据请求对应的大屏设备的状态信息，该收集服务节点将该状态信息通过服务网关转发至该小屏服务节点，由小屏服务节点将该状态信息发送至发出大屏数据请求的小屏设备，以便于家长能够通过小屏设备随时确定学生在大屏设备上的在线学习情况，提高了系统中较多的大屏设备及小屏设备同时在线时，对大屏设备状态进行确定的交互效率。

本实施例公开的数据监控系统，包括：服务网关，用于获得不少于一个大屏设备的上报数据，并将上报数据转发至收集服务集群；收集服务集群，包括不少于一个收集服务节点，用于分别获得服务网关转发的上报数据，并将上报数据存储至预设存储系统；预设存储系统，包括不少于一个预设存储节点，分别用于存储不同的大屏设备的上报数据；小屏数据接口，与服务网关相连，用于获得小屏设备的数据请求，基于数据请求通过服务网关获得通过收集服务集群存储至预设存储节点的与小屏设备对应的大屏设备的状态信息，其中，所述状态信息基于所述上报数据确定。本方案通过收集服务集群实现对获得的多个大屏设备的数据的分别存储，并在小屏设备需要获得相应的大屏设备的状态数据时，能够通过收集服务集群实现对存储有相应上报数据的预设存储节点的访问，避免了大屏设备与小屏设备的长连接，缓解了服务端的压力。

本实施例公开了一种数据监控方法，其流程图如图5所示，包括：

步骤S51、获得不少于一个大屏设备的上报数据；

步骤S52、确定获得的上报数据对应的收集服务节点，通过对应的收集服务节点转发上报数据；

步骤S53、将上报数据存储至与收集服务节点对应的预设存储节点，以便于当获得小屏设备的数据请求时，能够通过对应的收集服务节点从预设存储节点获得与小屏设备对应的大屏设备的状态信息，状态信息基于上报数据确定。

进一步的，还包括：

在获得大屏设备发送的上报数据后，基于上报数据确定大屏设备的状态信息，并将状态信息与上报数据对应存储。

进一步的，基于上报数据确定大屏设备的状态信息，包括：

在获得大屏设备发送的上报数据后，确定大屏设备的状态为在线状态；若在预设时段内未获得大屏设备的上报数据，确定大屏设备的状态为异常状态；

或，

在获得大屏设备发送的上报数据后，对上报数据进行分析，基于对上报数据进行分析得到的分析结果确定大屏设备的状态为在线状态或异常状态。

进一步的，收集服务集群中的每个收集服务节点分别与一个所述预设存储节点连接，若收集服务节点确定与其连接的预设存储节点在第一预设时长内未接收到第一大屏设备发送的上报数据，则确定第一大屏设备的状态为离线状态。

进一步的，若收集服务节点确定与其连接的预设存储节点在第一预设时长内未接收到第一大屏设备发送的上报数据，则确定第一大屏设备的状态为离线状态，包括：

若收集服务节点确定与其连接的预设存储节点在第二预设时长内未接收到第一大屏设备发送的上报数据，确定补偿时长，补偿时长用于延长大屏设备发送上报数据的预设时长，其中，第二预设时长小于第一预设时长；若确定在补偿时长内未接收到第一大屏设备发送的上报数据，则确定第一大屏设备的状态为离线状态；若确定在补偿时长内接收到第一大屏设备发送的上报数据，存储上报数据至预设存储节点。

本实施例公开的数据监控方法是基于上述实施例公开的数据监控系统实现的，在此不再赘述。

本实施例公开的数据监控方法，应用于数据监控系统，数据监控系统包括：服务网关，用于获得不少于一个大屏设备的上报数据，并将上报数据转发至收集服务集群；收集服务集群，包括不少于一个收集服务节点，用于分别获得服务网关转发的上报数据，并将上报数据存储至预设存储系统；预设存储系统，包括不少于一个预设存储节点，分别用于存储不同的大屏设备的上报数据；小屏数据接口，与服务网关相连，用于获得小屏设备的数据请求，基于数据请求通过服务网关获得通过收集服务集群存储至预设存储节点的与小屏设备对应的大屏设备的状态信息，其中，所述状态信息基于所述上报数据确定。本方案通过收集服务集群实现对获得的多个大屏设备的数据的分别存储，并在小屏设备需要获得相应的大屏设备的状态数据时，能够通过收集服务集群实现对存储有相应上报数据的预设存储节点的访问，避免了大屏设备与小屏设备的长连接，缓解了服务端的压力。

本申请实施例还提供了一种可读存储介质，其上存储有计算机程序，所述计算机程序被处理器加载并执行，实现上述数据监控方法的各步骤，具体实现过程可以参照上述实施例相应部分的描述，本实施例不做赘述。

本申请还提出了一种计算机程序产品或计算机程序，该计算机程序产品或计算机程序包括计算机指令，该计算机指令存储在计算机可读存储介质中。电子设备的处理器从计算机可读存储介质读取该计算机指令，处理器执行该计算机指令，使得该电子设备执行上述基于数据监控方法方面或数据监控系统方面的各种可选实现方式中所提供方法，具体实现过程可以参照上述相应实施例的描述，不做赘述。

本说明书中各个实施例采用递进的方式描述，每个实施例重点说明的都是与其他实施例的不同之处，各个实施例之间相同相似部分互相参见即可。对于实施例公开的装置而言，由于其与实施例公开的方法相对应，所以描述的比较简单，相关之处参见方法部分说明即可。

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

结合本文中所公开的实施例描述的方法或算法的步骤可以直接用硬件、处理器执行的软件模块，或者二者的结合来实施。软件模块可以置于随机存储器(RAM)、内存、只读存储器(ROM)、电可编程ROM、电可擦除可编程ROM、寄存器、硬盘、可移动磁盘、CD-ROM、或技术领域内所公知的任意其它形式的存储介质中。

对所公开的实施例的上述说明，使本领域专业技术人员能够实现或使用本申请。对这些实施例的多种修改对本领域的专业技术人员来说将是显而易见的，本文中所定义的一般原理可以在不脱离本申请的精神或范围的情况下，在其它实施例中实现。因此，本申请将不会被限制于本文所示的这些实施例，而是要符合与本文所公开的原理和新颖特点相一致的最宽的范围。

Claims (10)

1.一种数据监控系统，其特征在于，包括：

服务网关，用于获得不少于一个大屏设备的上报数据，并将所述上报数据转发至收集服务集群；

收集服务集群，包括不少于一个收集服务节点，用于分别获得所述服务网关转发的上报数据，并将所述上报数据存储至预设存储系统；

预设存储系统，包括不少于一个预设存储节点，用于分别存储大屏设备的上报数据；

小屏数据接口，与所述服务网关相连，用于获得小屏设备的数据请求，并基于所述数据请求通过所述服务网关获得通过所述收集服务集群存储至预设存储节点的与所述小屏设备对应的大屏设备的状态信息，其中，所述状态信息基于所述上报数据确定。

2.根据权利要求1所述的系统，其特征在于，所述收集服务集群还用于：

在获得大屏设备通过服务网关转发的上报数据后，基于所述上报数据确定所述大屏设备的状态信息。

3.根据权利要求2所述的系统，其特征在于，所述收集服务集群基于所述上报数据确定所述大屏设备的状态信息，包括：

所述收集服务集群获得所述服务网关转发的大屏设备的上报数据，确定所述大屏设备的状态为在线状态；若所述收集服务集群在预设时段内未获得所述服务网关转发的大屏设备的上报数据，确定所述大屏设备的状态为异常状态；

或，

所述收集服务集群获得所述服务网关转发的大屏设备的上报数据，对所述上报数据进行分析，基于对所述上报数据进行分析得到的分析结果确定所述大屏设备的状态为在线状态或异常状态。

4.根据权利要求1所述的系统，其特征在于，所述收集服务集群还用于：

所述收集服务集群中的每个收集服务节点分别与一个所述预设存储节点连接，若所述收集服务节点确定与其连接的预设存储节点在第一预设时长内未接收到第一大屏设备发送的上报数据，则确定所述第一大屏设备的状态为离线状态，其中，所述第一大屏设备为所述不少于一个大屏设备中的至少一个。

5.根据权利要求4所述的系统，其特征在于，所述若所述收集服务节点确定与其连接的预设存储节点在第一预设时长内未接收到第一大屏设备发送的上报数据，则确定所述第一大屏设备的状态为离线状态，包括：

若所述收集服务节点确定与其连接的预设存储节点在第二预设时长内未接收到第一大屏设备发送的上报数据，确定补偿时长，所述补偿时长用于延长第一大屏设备发送上报数据的预设时长，其中，所述第二预设时长小于所述第一预设时长；

若确定在所述补偿时长内未接收到所述第一大屏设备发送的上报数据，则确定所述第一大屏设备的状态为离线状态；

若确定在所述补偿时长内接收到所述第一大屏设备发送的上报数据，存储所述上报数据至所述预设存储节点。

6.根据权利要求1所述的系统，其特征在于，还包括：

小屏服务集群，包括不少于一个小屏服务节点，分别与所述小屏数据接口连接，用于获得所述小屏设备的数据请求，基于发送所述数据请求的小屏设备确定与所述数据请求对应的小屏服务节点，以便于所述小屏服务节点能够基于所述小屏设备输出的数据请求转发大屏数据请求至所述服务网关，从而获得与所述大屏数据请求对应的大屏设备的状态数据。

7.一种数据监控方法，其特征在于，包括：

获得不少于一个大屏设备的上报数据；

确定获得的所述上报数据对应的收集服务节点，通过对应的所述收集服务节点转发所述上报数据；

将所述上报数据存储至与所述收集服务节点对应的预设存储节点，以便于当获得小屏设备的数据请求时，能够通过对应的所述收集服务节点从所述预设存储节点获得与所述小屏设备对应的大屏设备的状态信息，其中，所述状态信息基于所述上报数据确定。

8.根据权利要求7所述的方法，其特征在于，还包括：

在获得大屏设备发送的上报数据后，基于所述上报数据确定所述大屏设备的状态信息，并将所述状态信息与所述上报数据对应存储。

9.根据权利要求8所述的方法，其特征在于，所述基于所述上报数据确定所述大屏设备的状态信息，包括：

在获得所述大屏设备发送的上报数据后，确定所述大屏设备的状态为在线状态；若在预设时段内未获得所述大屏设备的上报数据，确定所述大屏设备的状态为异常状态；

或，

在获得所述大屏设备发送的上报数据后，对所述上报数据进行分析，基于对所述上报数据进行分析得到的分析结果确定所述大屏设备的状态为在线状态或异常状态。

10.一种可读存储介质，用于至少存储一组指令集；

所述指令集用于被调用并至少执行如权利要求7-9中任一项所述的数据监控的方法。

Images