CN105357069A - 分布式节点服务状态监测的方法、装置及系统 - Google Patents

Abstract

本发明公开了一种分布式节点服务状态监测的方法，包括：接收计算节点按照预定时间间隔发送服务状态信息；根据所述服务状态信息，更新数据库中所述计算节点的所述服务状态信息的更新时间；将所述更新时间与当前系统时间作差，得到差值；若所述差值不大于所述阈值，则所述计算节点为正常计算节点；若所述差值大于所述阈值，则所述计算节点为故障计算节点；该方法能够可以快速定位出现问题的计算节点，从而快速的解决问题；本发明还公开了一种分布式节点服务状态监测的装置及系统。

Description

分布式节点服务状态监测的方法、装置及系统

技术领域

本发明涉及计算机领域，特别涉及一种分布式节点服务状态监测的方法、装置及系统。

背景技术

在云计算环境下，物理服务器的管理调度是至关重要的，但是云计算的规模一般都比较较大，当出现某些故障时，一台台节点的排查是非常耗费精力的，而且效率低下。

如何快速对分布式节点服务状态进行有效的监测，是本领域技术人员需要解决的技术问题。

发明内容

本发明的目的是提供一种分布式节点服务状态监测的方法、装置及系统，可以快速定位出现问题的计算节点，从而快速的解决问题，保证计算节点的准确调度。

为解决上述技术问题，本发明提供一种分布式节点服务状态监测的方法，包括：

接收计算节点按照预定时间间隔发送服务状态信息；

根据所述服务状态信息，更新数据库中所述计算节点的所述服务状态信息的更新时间；

将所述更新时间与当前系统时间作差，得到差值；

若所述差值不大于所述阈值，则所述计算节点为正常计算节点；

若所述差值大于所述阈值，则所述计算节点为故障计算节点。

其中，还包括：

所述系统中的所有节点都通过NTP服务器进行时间同步。

其中，将所述更新时间与当前系统时间作差，得到差值包括：

遍历每个所述计算节点，依次计算每个所述计算节点更新时间与当前系统时间作差，得到差值。

其中，若所述差值大于所述阈值，则所述计算节点为故障计算节点还包括：

则设定所述计算节点的服务为不可用，并将所述计算节点的服务状态信息更新到所述数据库中。

其中，还包括：

若更新数据库中所述计算节点的所述服务状态信息的更新时间，则将所述数据库中所述计算节点中前一次的更新时间删除。

本发明提供一种分布式节点服务状态监测的装置，包括：

接收模块，用于接收计算节点按照预定时间间隔发送服务状态信息；

更新模块，用于根据所述服务状态信息，更新数据库中所述计算节点的所述服务状态信息的更新时间；

计算模块，用于将所述更新时间与当前系统时间作差，得到差值；

判断模块，用于若所述差值不大于所述阈值，则判定所述计算节点为正常计算节点；若所述差值大于所述阈值，则判定所述计算节点为故障计算节点。

其中，还包括：

同步模块，用于所述装置与NTP服务器进行时间同步。

其中，所述计算模块包括：

遍历每个所述计算节点，依次计算每个所述计算节点更新时间与当前系统时间作差，得到差值。

其中，还包括：

警告模块，用于则设定所述计算节点的服务为不可用，并将所述计算节点的服务状态信息更新到所述数据库中。

本发明提供一种分布式节点服务状态监测的系统，包括：

如上述任一项所述的装置；

NTP服务器，用于将系统中所有的节点进行时间同步；

计算节点，用于按照预定时间间隔向所述装置发送服务状态信息。

本发明所提供的分布式节点服务状态监测的方法及装置，包括：接收计算节点按照预定时间间隔发送服务状态信息；根据所述服务状态信息，更新数据库中所述计算节点的所述服务状态信息的更新时间；将所述更新时间与当前系统时间作差，得到差值；若所述差值不大于所述阈值，则所述计算节点为正常计算节点；若所述差值大于所述阈值，则所述计算节点为故障计算节点；

该方法通过接收的计算节点的服务状态信息中的更新时间，与系统时间进行比较得到差值，并利用该差值与设定的阈值进行比较，并根据比较结果判定该计算节点是否异常；因此，该方法能够可以简单、快速定位出现问题的计算节点，从而快速的解决问题；保证计算节点的准确调度。

附图说明

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

图1为本发明实施例所提供的分布式节点服务状态监测的方法的流程图；

图2为本发明实施例所提供的分布式节点服务状态监测的装置的结构框图；

图3为本发明实施例所提供的分布式节点服务状态监测的系统的结构框图。

具体实施方式

本发明的核心是提供一种分布式节点服务状态监测的方法、装置及系统，可以快速定位出现问题的计算节点，从而快速的解决问题，保证计算节点的准确调度。

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

请参考图1，图1为本发明实施例所提供的分布式节点服务状态监测的方法的流程图；该方法可以包括：

s100、接收计算节点按照预定时间间隔发送服务状态信息；

其中，计算节点按照事先定义好的预定时间间隔即时间周期，循环发送其服务状态信息。计算节点的个数与系统的规模相对应，可以包括系统中全部的计算节点。即系统中所有的计算节点都要周期性循环往复的报告自身的服务状态，这个周期性可根据需要设置，但是设置的原则是一定要小于设定的允许的服务停止时间，假设服务停止时间是60S，那计算节点每隔70S才发送状态信息，那一定会被认定为服务不正常状态的，即设置的时间间隔必须小于60S。

s110、根据所述服务状态信息，更新数据库中所述计算节点的所述服务状态信息的更新时间；

其中，根据接收的计算节点发来的服务状态信息，将该服务状态信息中的系统时间更新到数据库中作为该计算节点的所述服务状态信息的更新时间。

s120、将所述更新时间与当前系统时间作差，得到差值；

其中，由于各个系统中的计算节点的个数不同，这里将更新时间与当前系统时间作差可以是通过遍历的方法进行，也可以是并行处理各个计算节点的更新时间，也可以是每当接收到一个计算节点发送的更新时间，就进行作差计算；可选的，将所述更新时间与当前系统时间作差，得到差值可以包括：遍历每个所述计算节点，依次计算每个所述计算节点更新时间与当前系统时间作差，得到差值。

s130、若所述差值不大于所述阈值，则所述计算节点为正常计算节点；

s140、若所述差值大于所述阈值，则所述计算节点为故障计算节点。

其中，根据计算节点定时发送服务状态信息并更新其服务状态，当该计算节点最后一次更新时间与当前管理节点系统时间差大于规定的阈值时，即认为该计算节点出现故障，不能接受云计算平台的调度。

即检验计算节点最后一次更新时间与当前的系统时间差是否大于系统定义的服务停止时间即阈值，如果是大于阈值，意味着某计算节点距离最近一次发送更新服务状态信息，已经很长时间没发送服务状态信息了，即认为该计算节点服务出现故障，在调度资源时避免调度该计算节点。例如，当阈值为60S，当计算节点的更新时间与系统时间差值是70S，即该计算节点隔了70S发送的服务状态信息，则该计算节点为故障节点，在调度资源时避免调度该计算节点。

基于上述技术方案，本发明实施例提供的分布式节点服务状态监测的方法，通过接收的计算节点的服务状态信息中的更新时间，与系统时间进行比较得到差值，并利用该差值与设定的阈值进行比较，并根据比较结果判定该计算节点是否异常；因此，该方法能够可以简单、快速定位出现问题的计算节点，从而快速的解决问题；保证计算节点的准确调度。

基于上述技术方案，该方法还可以包括：

所述系统中的所有节点都通过NTP服务器进行时间同步。

其中，当在分布式部署的环境架构下，一台NTP时间服务器是必须的，它可以保证环境里的所有节点的系统时钟是一致的，这对于后面计算时间差至关重要，否则可能会出现服务状态的误判。例如，在云计算平台所有的系统时间都要与时间服务器同步，保证云计算平台的所有节点系统时间一致的。

通过时间服务器可以提高该方法的准确性和可靠性。

基于上述任意技术方案，其中若所述差值大于所述阈值，则所述计算节点为故障计算节点还可以包括：

则设定所述计算节点的服务为不可用，并将所述计算节点的服务状态信息更新到所述数据库中。

其中，设定所述计算节点的服务为不可用，并将所述计算节点的服务状态信息更新到所述数据库中相应的字段中；系统可以通过判定计算节点的服务状态信息是否可用，来判断在计算节点调度时，是否可以选择该计算节点。例如，将计算节点中的服务标识设置为不可用，则系统通过对计算节点的服务标识的识别就可以判定该计算节点是否可用。提高计算节点调度的准确性。

基于上述任意技术方案，该方法还可用包括：

若更新数据库中所述计算节点的所述服务状态信息的更新时间，则将所述数据库中所述计算节点中前一次的更新时间删除。

通过在接收到新的更新时间后将之前的更新时间进行删除，可以避免在计算时在判断该更新时间是否为最新的更新时间，因此可以加快计算速度。也可以减轻系统的数据存储空间的存储压力。

基于上述技术方案，本发明实施例提供的分布式节点服务状态监测的方法，通过接收的计算节点的服务状态信息中的更新时间，与系统时间进行比较得到差值，并利用该差值与设定的阈值进行比较，并根据比较结果判定该计算节点是否异常；因此，该方法能够可以简单、快速定位出现问题的计算节点，从而快速的解决问题；保证计算节点的准确调度。提高计算速度，保证计算的可靠性和准确性。

本发明实施例提供了分布式节点服务状态监测的方法，可以通过上述方法能够实现家庭智能网关提供留言，并对该留言信息进行处理。

下面对本发明实施例提供的分布式节点服务状态监测的装置及系统进行介绍，下文描述的分布式节点服务状态监测的装置及系统与上文描述的分布式节点服务状态监测的方法可相互对应参照。

请参考图2，图2为本发明实施例所提供的分布式节点服务状态监测的装置的结构框图；该装置可以包括：

接收模块110，用于接收计算节点按照预定时间间隔发送服务状态信息；

更新模块120，用于根据所述服务状态信息，更新数据库中所述计算节点的所述服务状态信息的更新时间；

计算模块130，用于将所述更新时间与当前系统时间作差，得到差值；

判断模块140，用于若所述差值不大于所述阈值，则判定所述计算节点为正常计算节点；若所述差值大于所述阈值，则判定所述计算节点为故障计算节点。

基于上述技术方案，该装置还可以包括：

同步模块，用于所述装置与NTP服务器进行时间同步。

可选的，所述计算模块130包括：

遍历每个所述计算节点，依次计算每个所述计算节点更新时间与当前系统时间作差，得到差值。

基于上述技术方案，该装置还可以包括：

警告模块，用于则设定所述计算节点的服务为不可用，并将所述计算节点的服务状态信息更新到所述数据库中。

基于上述任意技术方案，该装置还可以包括：

删除模块，用于若更新数据库中所述计算节点的所述服务状态信息的更新时间，则将所述数据库中所述计算节点中前一次的更新时间删除。

请参考图3，图3为本发明实施例所提供的分布式节点服务状态监测的系统的结构框图；该系统可以包括：

分布式节点服务状态监测的装置100；

NTP服务器200，用于将系统中所有的节点进行时间同步；

计算节点300，用于按照预定时间间隔向所述装置发送服务状态信息。

因为在云计算环境下，调度虚拟资源时，会选择计算节点，所以计算节点的服务必须保证是active的；云计算平台具有分布式部署拓扑，在云环境下，计算节点规模巨大，该系统可以使其上运行的计算节点的服务状态出现问题时能够快速定位，并给云计算下的资源调度提供一种准确的数据支撑。

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

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

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

以上对本发明所提供的分布式节点服务状态监测的方法及系统进行了详细介绍。本文中应用了具体个例对本发明的原理及实施方式进行了阐述，以上实施例的说明只是用于帮助理解本发明的方法及其核心思想。应当指出，对于本技术领域的普通技术人员来说，在不脱离本发明原理的前提下，还可以对本发明进行若干改进和修饰，这些改进和修饰也落入本发明权利要求的保护范围内。

Claims (10)

1.一种分布式节点服务状态监测的方法，其特征在于，包括：

接收计算节点按照预定时间间隔发送服务状态信息；

根据所述服务状态信息，更新数据库中所述计算节点的所述服务状态信息的更新时间；

将所述更新时间与当前系统时间作差，得到差值；

若所述差值不大于所述阈值，则所述计算节点为正常计算节点；

若所述差值大于所述阈值，则所述计算节点为故障计算节点。

2.如权利要求1所述的方法，其特征在于，还包括：

所述系统中的所有节点都通过NTP服务器进行时间同步。

3.如权利要求2所述的方法，其特征在于，将所述更新时间与当前系统时间作差，得到差值包括：

遍历每个所述计算节点，依次计算每个所述计算节点更新时间与当前系统时间作差，得到差值。

4.如权利要求1所述的方法，其特征在于，若所述差值大于所述阈值，则所述计算节点为故障计算节点还包括：

则设定所述计算节点的服务为不可用，并将所述计算节点的服务状态信息更新到所述数据库中。

5.如权利要求1至4任一项所述的方法，其特征在于，还包括：

若更新数据库中所述计算节点的所述服务状态信息的更新时间，则将所述数据库中所述计算节点中前一次的更新时间删除。

6.一种分布式节点服务状态监测的装置，其特征在于，包括：

接收模块，用于接收计算节点按照预定时间间隔发送服务状态信息；

更新模块，用于根据所述服务状态信息，更新数据库中所述计算节点的所述服务状态信息的更新时间；

计算模块，用于将所述更新时间与当前系统时间作差，得到差值；

判断模块，用于若所述差值不大于所述阈值，则判定所述计算节点为正常计算节点；若所述差值大于所述阈值，则判定所述计算节点为故障计算节点。

7.如权利要求6所述的装置，其特征在于，还包括：

同步模块，用于所述装置与NTP服务器进行时间同步。

8.如权利要求7所述的装置，其特征在于，所述计算模块包括：

遍历每个所述计算节点，依次计算每个所述计算节点更新时间与当前系统时间作差，得到差值。

9.如权利要求6所述的装置，其特征在于，还包括：

警告模块，用于则设定所述计算节点的服务为不可用，并将所述计算节点的服务状态信息更新到所述数据库中。

10.一种分布式节点服务状态监测的系统，其特征在于，包括：

如权利要求6至9任一项所述的装置；

NTP服务器，用于将系统中所有的节点进行时间同步；

计算节点，用于按照预定时间间隔向所述装置发送服务状态信息。