CN105656964B - 数据推送的实现方法及装置 - Google Patents

Abstract

本发明提供了一种数据推送的实现方法及装置，应用于多个推送节点的移动终端管理系统，该实现方法包括：获取推送任务，推送任务包括目标终端信息和待推送数据信息，目标终端信息包括目标终端的所在地；获取推送节点的状态信息；根据推送节点的状态信息以及目标终端信息，建立推送节点与目标终端的对应关系，其中，对于一目标终端，优先将该目标终端与该目标终端所在地且处于空闲状态的推送节点相对应；根据对应关系，确定推送节点对应的目标终端，并将该目标终端的推送任务下发给该推送节点。通过将管理平台的集中访问分散到多个推送节点，有效降低了管理平台的负荷，目标终端访问推送节点即可得到数据，有效降低远距离数据传输时延。

Description

数据推送的实现方法及装置

技术领域

本发明涉及数据业务及安全领域，尤其涉及一种数据推送的实现方法及装置。

背景技术

移动终端管理系统又称移动设备管理，用于集中管理企业的移动智能终端设备。随着移动终端管理技术的不断发展，移动终端管理一般还包括移动应用管理和移动内容管理。移动终端管理系统一般由管理平台和移动终端客户端两个部分构成。其中管理平台的架构可分为应用模块、推送模块、数据存储模块等几个部分，负责管理设备和下发指令，客户端负责接收指令和执行。

现有数据推送流程：应用模块将数据推送任务传递给推送模块，数据推送任务分为两种：一种是消息推送，推送模块将消息数据直接推送至移动终端；另一种是文件或应用推送，推送模块首先将将数据存储的统一资源定位符地址以消息推送的形式推送至移动终端，之后由移动终端连接到管理平台获取数据。

对于大规模终端推送的需求，目前的解决方案是集中化部署多台应用服务器、推送服务器和数据库服务器，在前端部署负载均衡设备的技术来分担消息推送和终端的数据请求，但同样也会存在以下问题：

全部终端集中向管理平台请求数据，容易造成管理平台的负荷过高(包括服务器硬件资源和出口带宽)，影响系统性能；终端所处的地理位置分散的情况下(比如需要向全国范围内多个省的用户推送数据)，数据需要长距离传输(比如从北京访问广东地区的服务器)，导致网络传输延时较高，数据实际推送性能下降；在服务器集中部署的情况下，如果平台与移动终端通信数据被攻击者获取，容易形成针对管理平台的分布式拒绝服务攻击，从而导致整个系统无法正常运行。

发明内容

为了克服终端集中访问管理平台造成的管理平台负荷过高、终端过于分散造成的网络传输时延过大以及易被分布式拒绝服务攻击的问题，本发明提供了一种数据推送的实现方法及装置。

为了解决上述技术问题，本发明采用如下技术方案：

依据本发明的一个方面，提供了一种数据推送的实现方法，应用于多个推送节点的移动终端管理系统，所述实现方法包括：获取推送任务，所述推送任务包括目标终端信息和待推送数据信息，所述目标终端信息包括目标终端的所在地；获取推送节点的状态信息，所述状态信息包括工作状态和基础状态，所述工作状态包括：空闲状态、异常状态和忙碌状态，所述基础状态包括所述推送节点的所在地；根据所述推送节点的状态信息以及所述目标终端信息，建立推送节点与目标终端的对应关系，其中，对于一目标终端，优先将该目标终端与该目标终端所在地且处于空闲状态的推送节点相对应；根据所述对应关系，确定推送节点对应的目标终端，并将该目标终端的推送任务下发给该推送节点。

可选的，所述获取推送节点的状态信息包括：向所述推送节点发送状态请求；接收所述推送节点返回的状态信息。

可选的，所述建立推送节点与目标终端的对应关系包括：遍历所获取的各个推送节点；若当前遍历到的推送节点工作状态为空闲状态，建立该当前遍历到的推送节点与其所在地的目标终端之间的对应关系。

可选的，所述建立推送节点与目标终端的对应关系还包括：若当前遍历到的推送节点工作状态为异常状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。

可选的，所述建立推送节点与目标终端的对应关系还包括：若当前遍历到的推送节点工作状态为忙碌状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。

依据本发明的另一个方面，提供了一种数据推送的实现装置应用于多个推送节点的移动终端管理系统，所述实现装置包括：获取模块，用于获取推送任务，所述推送任务包括目标终端信息和待推送数据信息，所述目标终端信息包括目标终端的所在地；采集模块，用于获取推送节点的状态信息，所述状态信息包括工作状态和基础状态，所述工作状态包括：空闲状态、异常状态和忙碌状态，所述基础状态包括所述推送节点的所在地；处理模块，用于根据所述推送节点的状态信息以及所述目标终端信息，建立推送节点与目标终端的对应关系，其中，对于一目标终端，优先将该目标终端与该目标终端所在地且处于空闲状态的推送节点相对应；任务下发模块，用于根据所述对应关系，确定推送节点对应的目标终端，并将该目标终端的推送任务下发给该推送节点。

可选的，所述采集模块进一步包括：请求单元，用于向所述推送节点发送状态请求；接收单元，用于接收所述推送节点返回的状态信息。

可选的，所述处理模块进一步包括：遍历单元，用于遍历所获取的各个推送节点；第一处理单元，用于若当前遍历到的推送节点工作状态为空闲状态，建立该当前遍历到的推送节点与其所在地的目标终端之间的对应关系。

可选的，所述处理模块进一步包括：第二处理单元，用于若当前遍历到的推送节点工作状态为异常状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。

可选的，所述处理模块进一步包括：第三处理单元，用于若当前遍历到的推送节点工作状态为忙碌状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。

本发明的有益效果是：通过将管理平台的集中访问分散到多个推送节点，有效降低了管理平台的负荷，即使某个推送节点故障或遭受到攻击，管理平台仍可将推送任务调度到其他推送节点，形成云化的推送方式，有效提升了系统的健壮性；目标终端只需要访问本省(或由管理平台分配的省份)内的推送节点即可获取数据，有效降低了远距离数据传输延时。

附图说明

图1表示本发明实施例数据推送的实现方法的流程图；

图2表示本发明实施例获取推送节点的状态信息的流程图；

图3表示本发明实施例建立推送节点与目标终端的对应关系的流程图之一；

图4表示本发明实施例建立推送节点与目标终端的对应关系的流程图之二；

图5表示本发明实施例处于空闲状态的推送节点处理流程图；

图6表示本发明实施例处于异常状态的推送节点处理流程图；

图7表示本发明实施例处于忙碌状态的推送节点处理流程图；

图8表示本发明实施例数据推送的实现装置的示意图；

图9表示本发明实施例数据推送的实现装置采集模块的示意图；

图10表示本发明实施例数据推送的实现装置处理模块的示意图。

具体实施方式

为使本发明的目的、技术方案和优点更加清楚，下面将结合附图及具体实施例对本发明进行详细描述。

如图1所示，本发明实施例数据推送的实现方法的流程图，该方法包括以下步骤：

步骤S100、获取推送任务，推送任务包括目标终端信息和待推送数据信息，目标终端信息包括目标终端的所在地；

应当说明的是，每个目标终端对应各自的待推送数据信息，待推送数据信息可以是消息数据，也可以是数据统一资源定位符地址。

步骤S200、获取推送节点的状态信息，状态信息包括工作状态和基础状态，工作状态包括：空闲状态、异常状态和忙碌状态，基础状态包括推送节点的所在地；

应当说明的是，可以在全国各省的互联网数据中心机房设立推送节点，由管理平台统一管理；基础状态还包括当前推动节点的中央处理器、内存、存储、网络的情况，推送任务队列状态，推送任务信息(终端总量、推送数据大小、已完成推送终端数量、当前推送任务开始时间)，异常原因，状态信息反馈时间。

步骤S300、根据推送节点的状态信息以及目标终端信息，建立推送节点与目标终端的对应关系，其中，对于一目标终端，优先将该目标终端与该目标终端所在地且处于空闲状态的推送节点相对应；

步骤S400、根据对应关系，确定推送节点对应的目标终端，并将该目标终端的推送任务下发给该推送节点。

应当说明的是，通过将管理平台的集中访问分散到多个推送节点，有效降低了管理平台的负荷，即使某个推送节点故障或遭受到攻击，管理平台仍可将推送任务调度到其他推送节点，形成云化的推送方式，有效提升了系统的健壮性；目标终端只需要访问本省(或由管理平台分配的省份)内的推送节点即可获取数据，有效降低了远距离数据传输延时；管理平台与推送节点的数据传输可采用加密通道，使得数据传输过程中更加安全。

图2是图1中步骤S200的流程图，步骤S200包括以下步骤：

步骤S500、向推送节点发送状态请求；

步骤S600、接收推送节点返回的状态信息。

应当说明的是，根据已配置的推送节点列表向每个推送节点发送状态请求，接收推送节点的反馈，从而获取推送节点的状态信息。

图3为图1步骤S300中建立推送节点与目标终端的对应关系具体步骤，包括：

步骤S700、遍历所获取的各个推送节点；

步骤S800、若当前遍历到的推送节点工作状态为空闲状态，建立该当前遍历到的推送节点与其所在地的目标终端之间的对应关系；

步骤S900、若当前遍历到的推送节点工作状态为异常状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系；

步骤S1000、若当前遍历到的推送节点工作状态为忙碌状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。

应当说明的是，遍历所获取的各个推送节点时无固定的遍历顺序，即步骤S800、步骤S900、步骤S1000无固定先后顺序，较佳的，如图4所示，本发明实施例建立推送节点与目标终端的对应关系的流程图之二，遍历所获取的各个推送节点时，根据推送节点的状态信息，按推动节点的工作状态，依次遍历空闲状态的推动节点、异常状态的工作节点、忙碌状态的推送节点，并对不同工作状态的推送节点进行不同的处理。

如图5所示，本发明实施例处于空闲状态的推送节点处理流程图，若当前遍历到的推送节点工作状态为空闲状态；为了避免目标终端过多造成该目标终端所在地的推送节点负荷过大，设置预期推送时长，根据该当前遍历到的推送节点的所在地与该当前遍历到的推送节点对应的目标终端的所在地，计算推送任务时长；若推送任务时长未超过预期推送时长，将当前遍历到的推送节点与其所在地的目标终端加入推送任务，并对该当前遍历到的推送节点进行标记，即建立该当前遍历到的推送节点与其所在地的目标终端之间的对应关系；若推送任务时长超过预期推送时长，将当前遍历到的推送节点对应的目标终端分为两部分，其中一部分目标终端与当前遍历到的推送节点加入推送任务，并对当前遍历到的推送节点进行标记，另一部分目标终端进入待推送终端列表；

如图6所示，本发明实施例处于异常状态的推送节点处理流程图，若当前遍历到的推送节点工作状态为异常状态且空闲状态的推送节点处理完成即空闲状态的推送节点已全部被遍历，则遍历所有推送节点寻找未占用且处于空闲状态的推送节点，较佳的，从邻近当前遍历到的推送节点的推送节点开始遍历，可以是地理上的距离邻近也可以是数据传输路线上的邻近，若未遍历到未占用且处于空闲状态的推送节点，将继续遍历所有推送节点，若遍历到未占用且处于空闲状态的推送节点，将该空闲状态的推送节点和之前遍历到的异常状态的推送节点所在地的目标终端加入推送任务，并对该空闲状态的推送节点进行标记。

如图7所示，本发明实施例处于忙碌状态的推送节点处理流程图，若当前遍历到的推送节点工作状态为忙碌状态，且空闲状态和忙碌状态的推送节点处理完成即空闲状态和忙碌状态的推送节点已全部被遍历，计算将当前遍历到的推送节点与其所在地的目标终端加入推送任务的推送任务时长，若该推送任务时长未超过预期推送时长，则将当前遍历到的推送节点与其所在地的目标终端加入推送计划，并对该当前遍历到的推送节点进行标记；若该推送任务时长超过预期推送时长，则遍历所有推送节点寻找未占用且处于空闲状态的推送节点，较佳的，从邻近当前遍历到的推送节点的推送节点开始遍历，可以是地理上的距离邻近也可以是数据传输路线上的邻近，若遍历到未占用且处于空闲状态的推送节点，将该空闲状态的推送节点和之前遍历到的忙碌状态的推送节点所在地的目标终端加入推送任务，并对该空闲状态的推送节点进行标记；若未遍历到未占用且处于空闲状态的推送节点，将之前遍历到的忙碌状态的推送节点与其所在地的目标终端加入推送任务，并对之前遍历到的忙碌状态的推送节点进行标记；对不同工作状态的推送节点进行处理也可采用人工选择方式，管理员手动优先将目标终端与该目标终端所在地且处于空闲状态的推送节点相对应。

如图4所示，本发明实施例待推送终端列表处理流程图，若空闲状态、异常状态和忙碌状态的推送节点处理完成即空闲状态、异常状态和忙碌状态的推送节点全部被遍历，遍历待推送终端列表中目标终端所在地的推送节点的临近推送节点；若遍历到未占用且处于空闲状态的推送节点，将待推送终端列表中目标终端与当前遍历到的推送节点加入推送任务，并对该当前遍历到的推送节点进行标记；若未遍历到未占用且处于空闲状态的推送节点，将待推送终端列表中目标终端与其所在地的推送节点加入推送任务。

如图8所示，本发明实施例数据推送的实现装置的示意图，该实现装置包括：获取模块10、采集模块20、处理模块30、任务下发模块40；获取模块10，用于获取推送任务，所述推送任务包括目标终端信息和待推送数据信息，所述目标终端信息包括目标终端的所在地；采集模块20，用于获取推送节点的状态信息，所述状态信息包括工作状态和基础状态，所述工作状态包括：空闲状态、异常状态和忙碌状态，所述基础状态包括所述推送节点的所在地；处理模块30，用于根据所述推送节点的状态信息以及所述目标终端信息，建立推送节点与目标终端的对应关系，其中，对于一目标终端，优先将该目标终端与该目标终端所在地且处于空闲状态的推送节点相对应；任务下发模块40，用于根据所述对应关系，确定推送节点对应的目标终端，并将该目标终端的推送任务下发给该推送节点。

如图9所示，本发明实施例数据推送的实现装置采集模块20的示意图，采集模块20包括请求单元21和接收单元22；请求单元21，用于向所述推送节点发送状态请求；接收单元22，用于接收所述推送节点返回的状态信息。

如图10所示，本发明实施例数据推送的实现装置处理模块30的示意图，处理模块30包括遍历单元31、第一处理单元32、第二处理单元33、第三处理单元34；遍历单元31，用于遍历所获取的各个推送节点；第一处理单元32，用于若当前遍历到的推送节点工作状态为空闲状态，建立该当前遍历到的推送节点与其所在地的目标终端之间的对应关系；第二处理单元33，用于若当前遍历到的推送节点工作状态为异常状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系；第三处理单元34，用于若当前遍历到的推送节点工作状态为忙碌状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。

应当说明的是，通过将管理平台的集中访问分散到多个推送节点，有效降低了管理平台的负荷，即使某个推送节点故障或遭受到攻击，管理平台仍可将推送任务调度到其他推送节点，形成云化的推送方式，有效提升了系统的健壮性；目标终端只需要访问本省(或由管理平台分配的省份)内的推送节点即可获取数据，有效降低了远距离数据传输延时。

以上的是本发明的优选实施方式，应当指出对于本技术领域的普通人员来说，在不脱离本发明的原理前提下还可以作出若干改进和润饰，这些改进和润饰也在本发明的保护范围内。

Claims (6)

1.一种数据推送的实现方法，应用于多个推送节点的移动终端管理系统，其特征在于，所述实现方法包括：

获取推送任务，所述推送任务包括目标终端信息和待推送数据信息，所述目标终端信息包括目标终端的所在地；

获取推送节点的状态信息，所述状态信息包括工作状态和基础状态，所述工作状态包括：空闲状态、异常状态和忙碌状态，所述基础状态包括所述推送节点的所在地；

根据所述推送节点的状态信息以及所述目标终端信息，建立推送节点与目标终端的对应关系，其中，对于一目标终端，优先将该目标终端与该目标终端所在地且处于空闲状态的推送节点相对应；

根据所述对应关系，确定推送节点对应的目标终端，并将该目标终端的推送任务下发给该推送节点；

所述获取推送节点的状态信息包括：

向所述推送节点发送状态请求；

接收所述推送节点返回的状态信息；

所述建立推送节点与目标终端的对应关系包括：

遍历所获取的各个推送节点；

若当前遍历到的推送节点工作状态为空闲状态，根据该当前遍历到的推送节点的所在地与该当前遍历到的推送节点对应的目标终端的所在地，计算推送任务时长；若推送任务时长未超过预期推送时长，建立该当前遍历到的推送节点与其所在地的目标终端之间的对应关系；若推送任务时长超过预期推送时长，将当前遍历到的推送节点对应的目标终端分为两部分，其中一部分目标终端与当前遍历到的推送节点加入推送任务，另一部分目标终端进入待推送终端列表。

2.如权利要求1所述的实现方法，其特征在于，所述建立推送节点与目标终端的对应关系还包括：

若当前遍历到的推送节点工作状态为异常状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。

3.如权利要求1所述的实现方法，其特征在于，所述建立推送节点与目标终端的对应关系还包括：

若当前遍历到的推送节点工作状态为忙碌状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。

4.一种数据推送的实现装置，应用于多个推送节点的移动终端管理系统，其特征在于，所述实现装置包括：

获取模块，用于获取推送任务，所述推送任务包括目标终端信息和待推送数据信息，所述目标终端信息包括目标终端的所在地；

采集模块，用于获取推送节点的状态信息，所述状态信息包括工作状态和基础状态，所述工作状态包括：空闲状态、异常状态和忙碌状态，所述基础状态包括所述推送节点的所在地；

处理模块，用于根据所述推送节点的状态信息以及所述目标终端信息，建立推送节点与目标终端的对应关系，其中，对于一目标终端，优先将该目标终端与该目标终端所在地且处于空闲状态的推送节点相对应；

任务下发模块，用于根据所述对应关系，确定推送节点对应的目标终端，并将该目标终端的推送任务下发给该推送节点；

所述采集模块进一步包括：

请求单元，用于向所述推送节点发送状态请求；

接收单元，用于接收所述推送节点返回的状态信息；

所述处理模块进一步包括：

遍历单元，用于遍历所获取的各个推送节点；

第一处理单元，用于若当前遍历到的推送节点工作状态为空闲状态，根据该当前遍历到的推送节点的所在地与该当前遍历到的推送节点对应的目标终端的所在地，计算推送任务时长；若推送任务时长未超过预期推送时长，建立该当前遍历到的推送节点与其所在地的目标终端之间的对应关系；若推送任务时长超过预期推送时长，将当前遍历到的推送节点对应的目标终端分为两部分，其中一部分目标终端与当前遍历到的推送节点加入推送任务，另一部分目标终端进入待推送终端列表。

5.如权利要求4所述的实现装置，其特征在于，所述处理模块进一步包括：

第二处理单元，用于若当前遍历到的推送节点工作状态为异常状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。

6.如权利要求4所述的实现装置，其特征在于，所述处理模块进一步包括：

第三处理单元，用于若当前遍历到的推送节点工作状态为忙碌状态，优先建立临近该当前遍历到的推送节点且处于空闲状态的推送节点与该当前遍历到的推送节点所在地的目标终端之间的对应关系。