CN105338037A - 一种动态调度方法及系统 - Google Patents

Abstract

本发明公开了一种动态调度方法，配置在线数据库与离线数据库之间的同步规则，根据所述同步规则将在线数据库中相应的在线数据同步到离线数据库；该方法还包括：接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息；根据所述请求数据信息及所述同步规则确定请求的业务数据类型；确定请求的业务数据为离线数据时，为所述用户终端调度离线数据库中对应的离线数据；确定请求的业务数据为在线数据时，为所述用户终端调度在线数据库中对应的在线数据。本发明还同时公开了一种动态调度系统。

Description

一种动态调度方法及系统

技术领域

本发明涉及互联网(WEB)应用领域，尤其涉及一种动态调度方法及系统。

背景技术

随着互联网技术的快速发展，基于客户端的WEB应用系统使用场景非常广泛。WEB应用系统是整个互联网的核心，为用户提供信息和服务，由于需要面对互联网中海量的信息资源以及用户需求的频繁变化，因此，WEB应用系统需要经常进行应用数据的更新、割接、以及系统的升级。

现有WEB应用系统中，应用数据一般存储于在线数据库中，例如，Oracle、MySQL等数据库，在线数据库中应用数据的更新、割接、以及所述在线数据库的升级、突发性宕机等一般都会引起服务的暂时中断，这极大地影响用户的体验。

发明人在实现本发明的过程中，发现现有的WEB应用系统至少存在以下缺陷：

1)现有WEB应用系统服务依赖于在线数据库，用户访问WEB应用系统时，由WEB应用服务器处理用户的业务请求消息，获取在线数据库中的业务数据并返回相应的业务响应消息，如果在线数据库中断则会造成业务的中断，此时，WEB应用服务器获取业务数据失败，用户就不能正常使用业务。

2)现有WEB应用系统直接访问在线数据库获取业务数据，对于一些被经常访问且变化不频繁的业务数据，访问在线数据库获取该类业务数据会给在线数据库造成较大压力，以致浪费系统资源。

发明内容

有鉴于此，本发明实施例期望提供一种动态调度方法及系统，不仅能减轻在线数据库的承载负荷并降低在线数据库的成本，还能提高系统的访问性能及健壮性。

为达到上述目的，本发明的技术方案是这样实现的：

本发明实施例提供了一种动态调度方法，配置在线数据库与离线数据库之间的同步规则，根据所述同步规则将在线数据库中相应的在线数据同步到离线数据库；该方法还包括：

接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息；

根据所述请求数据信息及所述同步规则确定请求的业务数据类型；

确定请求的业务数据为离线数据时，为所述用户终端调度离线数据库中对应的离线数据；

确定请求的业务数据为在线数据时，为所述用户终端调度在线数据库中对应的在线数据。

上述方案中，所述根据所述请求数据信息及所述同步配置规则确定请求的业务数据类型，包括：

根据所述请求数据信息确定请求的业务数据；

根据所述同步规则对所述业务数据进行分析与判断，确定所述业务数据的类型。

上述方案中，所述为所述用户终端调度离线数据库中相应的离线数据，包括：

将所述业务请求消息调度到访问离线数据库的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供离线数据。

上述方案中，所述将所述业务请求消息调度到访问离线数据库的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供离线数据，包括：

监控访问离线数据库的多个应用服务器的运行状态；

根据访问离线数据库的多个应用服务器的运行状态、访问离线数据库的多个应用服务器与离线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供对应的离线数据。

上述方案中，所述为所述用户终端调度在线数据库中对应的在线数据，包括：

将所述业务请求消息调度到访问在线数据库的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供离线数据。

上述方案中，所述将所述业务请求消息调度到访问在线数据库的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供离线数据，包括：

监控访问在线数据库的多个应用服务器的运行状态；

根据访问在线数据库的多个应用服务器的运行状态、访问在线数据库的多个应用服务器与在线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供对应的在线数据。

基于上述方法，本发明实施例还提供了一种动态调度系统，该系统包括：配置管理模块、接收模块、确定模块、动态调度模块；其中，

所述配置管理模块，用于配置在线数据库与离线数据库之间的同步规则，根据所述同步规则将在线数据库中相应的在线数据同步到离线数据库；

所述接收模块，用于接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息；

所述确定模块，用于根据所述请求数据信息及所述同步规则确定请求的业务数据类型；

所述动态调度模块，用于在确定模块确定请求的业务数据为离线数据时，为所述用户终端调度离线数据库中对应的离线数据；在确定模块确定请求的业务数据为在线数据时，为所述用户终端调度在线数据库中对应的在线数据。

上述方案中，所述确定模块具体用于：

根据所述请求数据信息确定请求的业务数据；

根据所述同步规则对所述业务数据进行分析与判断，确定所述业务数据的类型。

上述方案中，所述动态调度模块具体用于：

将所述业务请求消息调度到访问离线数据库的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供离线数据。

上述方案中，所述动态调度模块具体用于：

监控访问离线数据库的多个应用服务器的运行状态；

根据访问离线数据库的多个应用服务器的运行状态、访问离线数据库的多个应用服务器与离线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供对应的离线数据。

上述方案中，所述动态调度模块具体用于：

将所述业务请求消息调度到访问在线数据库的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供离线数据。

上述方案中，所述动态调度模块具体用于：

监控访问在线数据库的多个应用服务器的运行状态；

根据访问在线数据库的多个应用服务器的运行状态、访问在线数据库的多个应用服务器与在线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供对应的在线数据。

本发明实施例所提供的动态调度方法及系统，配置在线数据库与离线数据库之间的同步规则，根据所述同步规则将在线数据库中相应的在线数据同步到离线数据库；接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息；根据所述请求数据信息及所述同步规则确定请求的业务数据类型；确定请求的业务数据为离线数据时，为所述用户终端调度离线数据库中对应的离线数据；确定请求的业务数据为在线数据时，为所述用户终端调度在线数据库中对应的在线数据。如此，本发明实施例将一部分业务数据承载到离线数据库，根据请求的业务数据类型动态调度相应在线数据库或离线数据库中的业务数据，从而不再只依赖于在线数据库，能够减轻所述在线数据库的承载负荷并降低所述在线数据库的成本。

另外，本发明实施例即使在所述在线数据库异常中断时，仍然可由所述离线数据库为所述用户终端提供一部分WEB应用服务，因此，不会直接造成WEB应用服务的中断，从而提高了系统的访问性能及健壮性。

附图说明

图1为本发明实施例动态调度方法的实现流程示意图；

图2为本发明实施例一中的WEB应用系统的组成结构示意图；

图3为本发明实施例动态调度系统的组成结构示意图。

具体实施方式

本发明实施例中，配置在线数据库与离线数据库之间的同步规则，根据所述同步规则将在线数据库中相应的在线数据同步到离线数据库；接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息；根据所述请求数据信息及所述同步规则确定请求的业务数据类型；确定请求的业务数据为离线数据时，为所述用户终端调度离线数据库中对应的离线数据；确定请求的业务数据为在线数据时，为所述用户终端调度在线数据库中对应的在线数据。

下面结合附图对本发明具体实施方式作进一步说明。

本发明实施例提出了一种动态调度方法，应用于动态调度系统，如图1所示，该方法包括：

步骤S100：配置在线数据库与离线数据库之间的同步规则，根据所述同步规则将在线数据库中相应的在线数据同步到离线数据库。

这里，首先，建立在线数据库与离线数据库，所述在线数据库用于存储在线数据，所述离线数据库用于存储离线数据，所述在线数据库可采用Oracle、MySQL等数据库实现，所述离线数据库可采用本地数据库实现；

然后，配置在线数据库与离线数据库之间的同步规则，所述同步规则可以配置为将被经常访问且变化不频繁的业务数据看作离线数据，其他的业务数据看作在线数据，例如，将百度百科、百度文库等被经常访问且变化不频繁的业务数据看作离线数据，将新浪新闻、百度新闻等实时性较高且变化频繁的业务数据看作在线数据；也可以配置为根据业务需要将需要的业务数据看作离线数据，其他的业务数据看作在线数据；根据所述同步规则将所述在线数据库中相应的在线数据同步到所述离线数据库，即：根据所述同步规则将所述在线数据库中看作离线数据的在线数据备份到所述离线数据库中，并同步更新所述离线数据库中的离线数据。

步骤S101：接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息。

步骤S102：根据所述请求数据信息及所述同步规则确定请求的业务数据类型；确定请求的业务数据为离线数据时，转入步骤S103；确定请求的业务数据为在线数据时，转入步骤S104。

这里，所述业务数据类型包括在线数据、离线数据；

其中，具体如何根据所述请求数据信息及所述同步规则确定请求的业务数据类型，包括以下处理：

首先，根据所述请求数据信息确定请求的业务数据；然后，根据所述同步规则对所述业务数据进行分析与判断，确定所述业务数据的类型为离线数据或在线数据；

例如，若用户终端需要查看百度百科，则将所需请求数据信息携带于所述业务请求消息发送，接收到用户终端发送的业务请求消息时，先根据请求数据信息确定用户终端请求的是百度百科中的业务数据；然后，读取配置的同步规则，根据所述同步规则确定百度百科中的业务数据属于离线数据；

若用户终端需要查看新浪新闻，则将请求数据信息携带于业务请求消息中发送，接收到用户终端发送的业务请求消息时，先根据请求数据信息确定用户终端请求的是新浪新闻；然后，读取配置的同步规则，根据所述同步规则确定新浪新闻中的业务数据属于在线数据。

步骤S103：为所述用户终端调度离线数据库中对应的离线数据，结束本处理流程。

这里，可以预先配置多个访问离线数据库的应用服务器，并配置多个访问离线数据库的应用服务器与所述离线数据库的对应关系，即：每个访问离线数据库的应用服务器只能访问离线数据库中对应的离线数据。

这里，将所述业务请求消息调度到访问离线数据库的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供离线数据，具体实现方式如下：

监控访问离线数据库的多个应用服务器的运行状态；

根据访问离线数据库的多个应用服务器的运行状态、访问离线数据库的多个应用服务器与离线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供对应的离线数据。

步骤S104：为所述用户终端调度在线数据库中对应的在线数据。

这里，可以预先配置多个访问在线数据库的应用服务器，并配置多个访问在线数据库的应用服务器与所述在线数据库的对应关系，即：每个访问在线数据库的应用服务器只能访问离线数据库中对应的离线数据。

这里，将所述业务请求消息调度到访问离线数据库的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供离线数据，具体实现方式如下：

监控访问在线数据库的多个应用服务器的运行状态；

根据访问在线数据库的多个应用服务器的运行状态、访问在线数据库的多个应用服务器与在线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供对应的在线数据。

本发明实施例中，将一部分业务数据承载到离线数据库，根据请求的业务数据类型动态调度相应在线数据库或离线数据库中的业务数据，从而不再只依赖于在线数据库，能够减轻所述在线数据库的承载负荷并降低所述在线数据库的成本；另外，本发明实施例即使在所述在线数据库异常中断时，仍然可由所述离线数据库为所述用户终端提供一部分WEB应用服务，因此，不会直接造成WEB应用服务的中断，从而提高了系统的访问性能及健壮性。

为了更清楚地对本发明实施例进行说明，下面以实施例一为例，对本发明实施例中的动态调度流程进行描述。

实施例一

如图2所示，WEB应用系统包括：用户子系统200、应用服务集群子系统201、数据源子系统202；其中，

所述用户子系统200，用于获取用户信息，并处理用户的请求与响应；

所述应用服务集群子系统201，用于动态调度应用服务器集群；

所述数据源子系统202，用于管理在线数据及离线数据的数据源，并根据同步规则完成在线数据到离线数据的同步。

本发明实施例一中的动态调度流程，具体实现步骤如下：

步骤一、所述用户子系统200接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息；并将所述业务请求消息转发到所述应用服务集群子系统201；

步骤二、所述应用服务集群子系统201中的动态调度管理服务器实时地监控访问离线数据库及访问在线数据库的多个应用服务器的运行状态、以及应用服务器与数据源的对应关系；并在接收到所述业务请求消息时，首先根据所述业务请求消息中请求数据信息确定请求的业务数据，根据所述同步规则对所述业务数据进行分析与判断，确定所述业务数据的类型；确定请求的业务数据为离线数据时，转入步骤三；确定请求的业务数据为在线数据时，转入步骤四；

步骤三、动态调度管理服务器根据访问离线数据库的多个应用服务器的运行状态、访问离线数据库的多个应用服务器与离线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问所述应用服务集群子系统201中离线数据库为所述用户终端提供对应的离线数据；

步骤四、动态调度管理服务器根据访问在线数据库的多个应用服务器的运行状态、访问在线数据库的多个应用服务器与在线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问所述应用服务集群子系统201中在线数据库为所述用户终端提供对应的在线数据。

本发明实施例一中，所述应用服务集群子系统201中的动态调度管理服务器还实时地记录所述数据源子系统202中在线数据库及离线数据库的状态，当在线数据库由于升级、宕机等引起异常中断时，动态调度管理服务器将用户终端发送的业务请求消息调度到对应的访问离线数据库的应用服务器，由该应用服务器访问所述应用服务集群子系统201中离线数据库为所述用户终端提供对应的离线数据，以提供基本的数据访问服务；如此，所述WEB应用系统即使在所述在线数据库异常中断时，仍然可由所述离线数据库为所述用户终端提供一部分WEB应用服务，因此，不会直接造成WEB应用服务的中断，从而提高了所述WEB应用系统的访问性能及健壮性。

为实现上述方法，本发明实施例还提供了一种动态调度系统，由于该系统解决问题的原理与方法相似，因此，系统的实施过程及实施原理均可以参见前述方法的实施过程及实施原理描述，重复之处不再赘述。

如图3所示，本发明实施例提供的动态调度系统，该系统包括：配置管理模块300、接收模块301、确定模块302、动态调度模块303；其中，

所述配置模块300，用于配置在线数据库与离线数据库之间的同步规则，根据所述同步规则将在线数据库中相应的在线数据同步到离线数据库；

所述接收模块301，用于接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息；

所述确定模块302，用于根据所述请求数据信息及所述同步规则确定请求的业务数据类型；

所述动态调度模块303，用于在确定模块确定请求的业务数据为离线数据时，为所述用户终端调度离线数据库中对应的离线数据；在确定模块确定请求的业务数据为在线数据时，为所述用户终端调度在线数据库中对应的在线数据。

上功能模块或单元的划分方式仅为本发明实施例给出的一种优选实现方式，功能模块或单元的划分方式不构成对本发明的限制。为了描述的方便，以上所述设备的各部分以功能分为各种模块或单元分别描述。当然，在实施本发明时可以把各模块或单元的功能在同一个或多个软件或硬件中实现。

具体实施中，所述确定模块302具体用于：

根据所述请求数据信息确定请求的业务数据；

根据所述同步规则对所述业务数据进行分析与判断，确定所述业务数据的类型。

具体实施中，所述动态调度模块303具体用于：

将所述业务请求消息调度到访问离线数据库的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供离线数据。

具体实施中，所述动态调度模块303具体用于：

监控访问离线数据库的多个应用服务器的运行状态；

根据访问离线数据库的多个应用服务器的运行状态、访问离线数据库的多个应用服务器与离线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供对应的离线数据。

具体实施中，所述动态调度模块303具体用于：

将所述业务请求消息调度到访问在线数据库的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供离线数据。

具体实施中，所述动态调度模块303具体用于：

监控访问在线数据库的多个应用服务器的运行状态；

根据访问在线数据库的多个应用服务器的运行状态、访问在线数据库的多个应用服务器与在线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供对应的在线数据。

上述功能模块可以是软件功能模块，也可以是硬件设备。该作业调度系统可以是分布式系统或集中式系统，若为分布式系统，则上述功能模块可分别由硬件设备实现，各硬件设备之间通过网络交互；若是集中式系统，则上述各功能模块可由软件实现，集成在一个硬件设备中。其中，硬件设备可由服务器实现。

在实际应用中，当所述配置管理模块300、接收模块301、确定模块302、动态调度模块303集成于一个硬件设备中时，所述配置管理模块300、接收模块301、确定模块302、动态调度模块303可由位于动态调度系统中的中央处理器(CPU)、微处理器(MPU)、数字信号处理器(DSP)、或现场可编程门阵列(FPGA)实现。

尽管已描述了本发明的优选实施例，但本领域内的技术人员一旦得知了基本创造性概念，则可对这些实施例作出另外的变更和修改。所以，所附权利要求意欲解释为包括优选实施例以及落入本发明范围的所有变更和修改。

显然，本领域的技术人员可以对本发明进行各种改动和变型而不脱离本发明的精神和范围。这样，倘若本发明的这些修改和变型属于本发明权利要求及其等同技术的范围之内，则本发明也意图包含这些改动和变型在内。

Claims (12)

1.一种动态调度方法，其特征在于，配置在线数据库与离线数据库之间的同步规则，根据所述同步规则将在线数据库中相应的在线数据同步到离线数据库；所述方法还包括：

接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息；

根据所述请求数据信息及所述同步规则确定请求的业务数据类型；

确定请求的业务数据为离线数据时，为所述用户终端调度离线数据库中对应的离线数据；

确定请求的业务数据为在线数据时，为所述用户终端调度在线数据库中对应的在线数据。

2.根据权利要求1所述的方法，其特征在于，所述根据所述请求数据信息及所述同步配置规则确定请求的业务数据类型，包括：

根据所述请求数据信息确定请求的业务数据；

根据所述同步规则对所述业务数据进行分析与判断，确定所述业务数据的类型。

3.根据权利要求1所述的方法，其特征在于，所述为所述用户终端调度离线数据库中相应的离线数据，包括：

将所述业务请求消息调度到访问离线数据库的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供离线数据。

4.根据权利要求3所述的方法，其特征在于，所述将所述业务请求消息调度到访问离线数据库的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供离线数据，包括：

监控访问离线数据库的多个应用服务器的运行状态；

根据访问离线数据库的多个应用服务器的运行状态、访问离线数据库的多个应用服务器与离线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供对应的离线数据。

5.根据权利要求1所述的方法，其特征在于，所述为所述用户终端调度在线数据库中对应的在线数据，包括：

将所述业务请求消息调度到访问在线数据库的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供离线数据。

6.根据权利要求5所述的方法，其特征在于，所述将所述业务请求消息调度到访问在线数据库的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供离线数据，包括：

监控访问在线数据库的多个应用服务器的运行状态；

根据访问在线数据库的多个应用服务器的运行状态、访问在线数据库的多个应用服务器与在线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供对应的在线数据。

7.一种动态调度系统，其特征在于，所述系统包括：配置管理模块、接收模块、确定模块、动态调度模块；其中，

所述配置管理模块，用于配置在线数据库与离线数据库之间的同步规则，根据所述同步规则将在线数据库中相应的在线数据同步到离线数据库；

所述接收模块，用于接收用户终端发送的业务请求消息，所述业务请求消息中携带有请求数据信息；

所述确定模块，用于根据所述请求数据信息及所述同步规则确定请求的业务数据类型；

所述动态调度模块，用于在确定模块确定请求的业务数据为离线数据时，为所述用户终端调度离线数据库中对应的离线数据；在确定模块确定请求的业务数据为在线数据时，为所述用户终端调度在线数据库中对应的在线数据。

8.根据权利要求7所述的系统，其特征在于，所述确定模块具体用于：

根据所述请求数据信息确定请求的业务数据；

根据所述同步规则对所述业务数据进行分析与判断，确定所述业务数据的类型。

9.根据权利要求7所述的系统，其特征在于，所述动态调度模块具体用于：

将所述业务请求消息调度到访问离线数据库的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供离线数据。

10.根据权利要求9所述的系统，其特征在于，所述动态调度模块具体用于：

监控访问离线数据库的多个应用服务器的运行状态；

根据访问离线数据库的多个应用服务器的运行状态、访问离线数据库的多个应用服务器与离线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问离线数据库为所述用户终端提供对应的离线数据。

11.根据权利要求7所述的系统，其特征在于，所述动态调度模块具体用于：

将所述业务请求消息调度到访问在线数据库的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供离线数据。

12.根据权利要求11所述的系统，其特征在于，所述动态调度模块具体用于：

监控访问在线数据库的多个应用服务器的运行状态；

根据访问在线数据库的多个应用服务器的运行状态、访问在线数据库的多个应用服务器与在线数据库的对应关系，将所述业务请求消息调度到对应的应用服务器，由该应用服务器访问在线数据库为所述用户终端提供对应的在线数据。