CN114666346A - 分布式集群时间同步方法、装置及计算机可读存储介质 - Google Patents

Abstract

本申请公开了分布式集群时间同步方法、装置及计算机可读存储介质，涉及计算机领域。通过接收业务节点发送的请求Tick的指令并确定当前Tick；根据请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；按照接收请求Tick的指令的顺序向对应的业务节点发送新的Tick。通过采用逻辑时钟的方式使得各业务节点的交互达成时间同步，避免了集群中数据不同步的问题。

Description

分布式集群时间同步方法、装置及计算机可读存储介质

技术领域

本申请涉及计算机领域，特别是涉及分布式集群时间同步方法、装置及计算机可读存储介质。

背景技术

分布式系统(distributed system)是建立在网络之上的软件系统，具有高度的内聚性和透明性。在分布式系统中，时间同步往往是很让人头疼的一件事情。普通意义上讲时间是一个绝对量，但具体到每个计算机时，时间就是一个相对量。分布式系统中各节点的时间存在细微差异，这对于高并发的分布式集群也是难以接受的。许多与时间相关的中间件一旦出现时间不同步，就会出现集群中各个模块数据不同步问题，例如远程字典服务(Remote Dictionary Server，Redis)的定时失效。

传统的使用网络时间协议(Network Time Protocol，NTP)服务器这种物理时钟进行的时间同步，仍然会由于网络延时、处理响应等问题，导致时间上存在细微差异。

鉴于上述问题，设计一种分布式集群时间同步方法，实现分布式系统的多节点的时间同步，是该领域技术人员亟待解决的问题。

发明内容

本申请的目的是提供一种分布式集群时间同步方法、装置及计算机可读存储介质，实现分布式系统的多节点的时间同步。

为解决上述技术问题，本申请提供一种分布式集群时间同步方法，应用于包含有业务节点和定时节点的分布式集群，所述业务节点为多个，所述方法应用于所述定时节点，所述方法包括：

接收所述业务节点发送的请求Tick的指令；

确定当前Tick；

根据所述请求Tick的指令的数量生成对应数量的新的Tick，其中，新的 Tick在当前Tick的基础上依次加1；

按照接收所述请求Tick的指令的顺序向对应的所述业务节点发送新的 Tick。

优选地，所述接收所述业务节点发送的请求Tick的指令包括：

读取消息缓存队列中的所述请求Tick的指令；

其中，所述消息缓存队列用于存储所述业务节点发送的所述请求Tick的指令。

优选地，所述接收所述业务节点发送的请求Tick的指令包括：

通过TCP socket接收所述业务节点发送的所述请求Tick的指令。

优选地，在所述接收所述业务节点发送的请求Tick的指令之前，还包括：

根据物理时间重置Tick。

优选地，所述定时节点为两个，两个所述定时节点通信连接；

所述确定当前Tick包括：

获取另一个所述定时节点发送的新的Tick，以作为当前所述定时节点的当前所述Tick。

优选地，分布式集群还包括Ingress12；所述Ingress12连接两个所述定时节点，并连接所述业务节点，以用于当一个所述定时节点处理所述业务节点发送的请求Tick的指令时，切换另一个所述定时节点接收其他所述业务节点发送的请求Tick的指令。

为解决上述技术问题，本申请还提供一种分布式集群，包括定时节点和业务节点，其中所述业务节点为多个；

所述业务节点用于向所述定时节点发送请求Tick的指令；

所述定时节点连接所述业务节点，用于根据所述请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；按照接收所述请求Tick的指令的顺序向对应的所述业务节点发送新的Tick。

为解决上述技术问题，本申请还提供一种分布式集群时间同步装置，包括：

接收模块，用于接收所述业务节点发送的请求Tick的指令；

确定模块，用于确定当前Tick；

生成模块，用于根据所述请求Tick的指令的数量生成对应数量的新的 Tick，其中，新的Tick在当前Tick的基础上依次加1；

发送模块，用于按照接收所述请求Tick的指令的顺序向对应的所述业务节点发送新的Tick。

为解决上述技术问题，本申请提供还一种分布式集群时间同步装置，包括：

存储器，用于存储计算机程序；

处理器，用于执行所述计算机程序时实现上述所述的分布式集群时间同步方法的步骤。

为解决上述技术问题，本申请提供还一种计算机可读存储介质，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现上述所述的分布式集群时间同步方法的步骤。

本申请所提供分布式集群时间同步方法，通过接收业务节点发送的请求 Tick的指令并确定当前Tick；根据请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；按照接收请求Tick 的指令的顺序向对应的业务节点发送新的Tick。通过采用逻辑时钟的方式使得各业务节点的交互达成时间同步，避免了集群中数据不同步的问题。

此外，本申请还提供了一种分布式集群时间同步装置及计算机可读存储介质，效果同上。

附图说明

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

图1为本申请实施例提供的一种分布式集群时间同步方法的流程图；

图2为本申请实施例提供的一种分布式集群组网的示意图；

图3为本申请实施例提供的一种业务节点和定时节点间通信的示意图；

图4为本申请实施例提供的一种消息队列缓存请求Tick的指令的示意图；

图5为本申请实施例提供的一种TCP报文格式的示意图；

图6为本申请实施例提供的另一种分布式集群时间同步方法的流程图；

图7为本申请实施例提供的另一种分布式集群组网的示意图；

图8为本申请实施例提供的一种分布式集群时间同步装置的结构示意图；

图9为本申请实施例提供的另一种分布式集群时间同步装置的结构示意图。

具体实施方式

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

本申请的核心是提供一种分布式集群时间同步方法、装置及计算机可读存储介质，使各业务节点的交互达成时间同步，避免了集群中数据不同步的问题。

为了使本技术领域的人员更好地理解本申请方案，下面结合附图和具体实施方式对本申请作进一步的详细说明。

图1为本申请实施例提供的一种分布式集群时间同步方法的流程图。可以理解的是，在分布式系统中，时间同步很重要，同样往往是很让人头疼的一件事情。普通意义上讲时间是一个绝对量，是物质的永恒运动、变化的持续性、顺序性的表现；但具体到每个计算机时，时间就是一个相对量。即便使用NTP服务器进行时间同步，仍然会由于网络延时、处理响应等问题，导致时间上存在细微差异。这种差异对于高并发的分布式集群也是难以接受的。许多与时间相关的中间件一旦出现时间不同步，就会出现集群中各个模块数据不同步问题。因此为了解决上述问题，本申请实施例提供了一种分布式集群时间同步方法，应用于包含有业务节点10和定时节点11的分布式集群，业务节点10为多个，方法应用于定时节点11，方法包括：

S10：接收业务节点10发送的请求Tick的指令。

S11：确定当前Tick。

S12：根据请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1。

S13：按照接收请求Tick的指令的顺序向对应的业务节点10发送新的 Tick。

可以理解的是，逻辑时钟的概念已提出很久，逻辑时钟是分布式系统的特性，要求的是系统节点进展之间的相对一致性。只有相关的系统才需要有逻辑时钟同步，同步的目的是维持事件的顺序性。除时间的基本特性外，逻辑时钟与物理时钟之间没有通用意义上的明确的关系；相比于物理时钟来说，逻辑时钟更适用于分布式系统。tick就是逻辑时钟中相对时间的单位，这对于区分分布式系统中事件发生的先后顺序，有重要意义。

因此，本实施例中的方法基于逻辑时钟，能够广泛应用于各种分布式集群中。在具体实施中，分布式集群除各个业务节点10之外，独立运行一个节点作为时间同步器，即定时节点11；图2为本申请实施例提供的一种分布式集群组网的示意图。如图2所示，定时节点11与多个业务节点10连接，在整个网络中作为服务端，能够接收所有业务节点10的请求，生成全局唯一的逻辑时间单元，并返回给业务节点10，其中对于业务节点10的具体数量不做限制，根据具体的实施情况而定，只需保证业务节点10与定时节点11连接即可。

具体地，定时节点11首先接收业务节点10发送的请求Tick的指令，这里对于发送指令至定时节点11的业务节点10不做限制，可以为不同的业务节点10分别发送指令，也可以为一个业务节点10分时发送指令，还可以不同业务节点10分时发送指令。在接收到业务节点10发送的请求Tick的指令之后，定时节点11首先确认当前的Tick，以便为业务节点10赋予准确的逻辑时间。在确定当前的Tick之后，定时节点11生成与请求Tick的指令的数量相同数量的新的Tick，需要注意的是，根据业务节点10发送指令的先后顺序，此处生成的新的Tick遵守逻辑时间，新的Tick在当前Tick的基础上依次加1。图3为本申请实施例提供的一种业务节点10和定时节点11间通信的示意图。如图3所示，第一业务节点和第二业务节点均发送请求Tick的指令至定时节点，定时节点首先接收到第一业务节点的请求Tick的指令，确定当前Tick后，发送Tick至第一业务节点，此时Tick为101；第二业务节点向定时节点发送请求Tick的指令，定时节点接收指令后确认当前Tick为101，则新的Tick为101加1，即为102，因此定时节点发送Tick为102至第二业务节点。如图3所示，在第二业务节点第一次向定时节点请求Tick之后，再一次的发送请求Tick的指令至定时节点；此时定时节点确认当前Tick为102，在当前Tick的基础上加1，再次发送给第二业务节点的Tick即为103。以此类推，每一次业务节点10向定时节点11请求的Tick，均为定时节点11在当前Tick的基础上加1的新的Tick，具有唯一性。业务节点10接收到Tick后，继续处理后续的逻辑操作。

需要注意的是，本实施例中对于定时节点11与业务节点10间的传输方式不做限制，根据具体的实施情况而定；对于定时节点11的数量也不做限制，只需保证定时节点11发送给业务节点10的Tick具有唯一性，各业务节点10 时间同步，根据具体的实施情况而定。

本实施例中，分布式集群时间同步方法通过接收业务节点发送的请求 Tick的指令并确定当前Tick；根据请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；按照接收请求Tick 的指令的顺序向对应的业务节点发送新的Tick。通过采用逻辑时钟的方式使得各业务节点的交互达成时间同步，避免了集群中数据不同步的问题。

在上述实施例的基础上：

作为一种优选的实施例，接收业务节点10发送的请求Tick的指令包括：

读取消息缓存队列中的请求Tick的指令；

其中，消息缓存队列用于存储业务节点10发送的请求Tick的指令。

在具体实施中，当存在多个业务节点10时，可能会存在多个节点在短时间内需要进行大量的逻辑处理，从而需要向定时节点11发送大量的请求Tick 的指令。为了防止在这种情况下，定时节点11的宕机，在本实施例中，接收业务节点10发送的请求Tick的指令是通过读取消息缓存队列中的请求Tick 的指令来实现的。图4为本申请实施例提供的一种消息队列缓存请求Tick的指令的示意图。如图4所示，当多个业务节点10发送多个请求时，所有的请求根据请求的先后顺序缓存在消息缓存队列中；图4中消息缓存队列中的 request即为标识业务节点10向定时节点11申请Tick请求。定时节点11读取消息缓存队列中的请求，进行上述实施例中生成Tick的步骤，并分别发送生成的Tick至对应的业务节点10。

需要注意的是，在定时节点11向发送请求的业务节点10发送Tick时，不需要建立对大量Tick进行缓存的队列，直接向各业务节点10发送即可。

本实施例中，通过设置存储业务节点请求Tick的指令的消息缓存队列，起到缓存请求的作用，使得定时节点能够依次处理大量的请求，防止定时节点的宕机。

在上述实施例的基础上：

作为一种优选的实施例，接收业务节点10发送的请求Tick的指令包括：

通过TCP socket接收业务节点10发送的请求Tick的指令。

上述实施例中，对于定时节点11与业务节点10间的传输方式不做限制，根据具体的实施情况而定。在本实施例中，作为一种优选的实施例，通过传输控制协议(Transmission Control Protocol，TCP)套接字(Socket)接收业务节点10发送的请求Tick的指令。可以理解的是，TCP是面向连接的一种传输控制协议。属于传输层协议。TCP连接之后，连接双方可以互相发送和接收消息，在双方没有主动断开之前，连接一直存在，属于长连接。而与之类似的用户数据包协议(User Datagram Protocol，UDP)在数据传输前没有交换信息，这就导致数据传输时容易丢失数据。因此在分布式系统的各业务节点10 时间同步中，使用TCP socket的传输方式更加可靠。

图5为本申请实施例提供的一种TCP报文格式的示意图。如图5所示，数据报上方为报文中的固有字段；而在业务节点10与定时节点11的数据传输中，数据报的内容即为request：标识业务节点10向定时节点11申请Tick 请求；以及response：标识定时节点11响应消息，带有实际生成的Tick的值。

本实施例中，通过TCP socket接收业务节点发送的请求Tick的指令，使得业务节点和定时节点的数据传输安全，传输数据准确可靠。

图6为本申请实施例提供的另一种分布式集群时间同步方法的流程图，为了使定时节点11在首次与向业务节点10发送Tick时确定当前的Tick，在图1的基础上，如图6所示，在接收业务节点10发送的请求Tick的指令之前，还包括：

S14：根据物理时间重置Tick。

可以理解的是，分布式系统中定时节点11不一定随时处于工作状态。当一个定时节点11被启动时，需要对Tick进行重置；具体为以当前定时节点 11所在的实体设备上的物理时间为基准，对Tick进行重置，用于确定当前 Tick以便后续为业务节点10提供Tick。需要注意的是，物理时间即为授时中心的标准时间。

本实施例中，为了使定时节点在首次与向业务节点发送Tick时确定当前的Tick，在接收业务节点发送的请求Tick的指令之前，根据物理时间重置 Tick，确定了第一次的Tick，便于后续向业务节点发送新的Tick。

在上述实施例的基础上：

作为一种优选的实施例，定时节点11为两个，两个定时节点11通信连接；

确定当前Tick包括：

获取另一个定时节点11发送的新的Tick，以作为当前定时节点11的当前Tick。

在分布式集群中，定时节点11需要与其他节点一同作为微服务注册到分布式集群的服务列表中，以便其他业务节点10访问；因此定时节点11对可靠性要求较高。采用了两个定时节点11能够使分布式系统节点的时间同步更加可靠。

需要注意的是，两个定时节点11在工作时需要保证向业务节点10发送 Tick的时序性。在具体实施中，当前定时节点11需要不断获取另一个节点发送的新的Tick作为当前节点的；一旦接收到请求Tick的指令时，当前节点将当前Tick加1新得到的Tick，发送给业务节点10。

本实施例中，在分布式集群中设置两个定时节点，同时承担为业务节点提供Tick的工作，更加可靠。

在上述实施例的基础上：

作为一种优选的实施例，分布式集群还包括Ingress12；Ingress12连接两个定时节点11，并连接业务节点10，以用于当一个定时节点11处理业务节点10发送的请求Tick的指令时，切换另一个定时节点11接收其他业务节点10发送的请求Tick的指令。

图7为本申请实施例提供的另一种分布式集群组网的示意图。如图7所示，两个定时节点11分别连接Ingress12，通过Ingress12连接到个业务节点 10。在一个定时节点11工作时，若有业务节点10发送了请求Tick的指令， Ingress12会切换连接，使得该指令发送至另一个未处于工作状态的定时节点 11。还可以设置两个定时节点11交替处理业务节点10发送的请求Tick的指令，在这里不做限制，根据具体的实施情况而定。

本实施例中，通过设置Ingress切换两个定时节点与业务节点的Tick传输，使得分布式集群中两个定时节点负载均衡。

图2为本申请实施例提供的一种分布式集群组网的示意图，如图2所示，分布式集群包括定时节点11和业务节点10，其中业务节点10为多个；

业务节点10用于向定时节点11发送请求Tick的指令；

定时节点11连接业务节点10，用于根据请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；按照接收请求Tick的指令的顺序向对应的业务节点10发送新的Tick。

本装置实施例产生的有益效果与上述方法实施例产生的有益效果相对应，这里不做重复。

在上述实施例中，对于分布式集群时间同步方法进行了详细描述，本申请还提供分布式集群时间同步装置对应的实施例。需要说明的是，本申请从两个角度对装置部分的实施例进行描述，一种是基于功能模块的角度，另一种是基于硬件结构的角度。

图8为本申请实施例提供的一种分布式集群时间同步装置的结构示意图，如图8所示，分布式集群时间同步装置包括：

接收模块13，用于接收业务节点10发送的请求Tick的指令。

确定模块14，用于确定当前Tick。

生成模块15，用于根据请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1。

发送模块16，用于按照接收请求Tick的指令的顺序向对应的业务节点10 发送新的Tick。

此外，该装置还提供了以下模块：

读取模块，用于读取消息缓存队列中的请求Tick的指令。

重置模块，用于根据物理时间重置Tick。

获取模块，用于当存在两个定时节点(11)时，获取另一个所述定时节点(11)发送的新的Tick，以作为当前所述定时节点(11)的当前所述Tick。

本实施例所提供的分布式集群时间同步装置，通过接收业务节点发送的请求Tick的指令并确定当前Tick；根据请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；按照接收请求Tick的指令的顺序向对应的业务节点发送新的Tick。通过采用逻辑时钟的方式使得各业务节点的交互达成时间同步，避免了集群中数据不同步的问题。

图9为本申请实施例提供的另一种分布式集群时间同步装置的结构示意图，如图9所示，分布式集群时间同步装置包括：

存储器20，用于存储计算机程序。

处理器21，用于执行计算机程序时实现如上述实施例中所提到的分布式集群时间同步方法的步骤。

本实施例提供的分布式集群时间同步装置可以包括但不限于智能手机、平板电脑、笔记本电脑或台式电脑等。

其中，处理器21可以包括一个或多个处理核心，比如4核心处理器、8核心处理器等。处理器21可以采用DSP(Digital Signal Processing，数字信号处理)、 FPGA(Field－Programmable Gate Array，现场可编程门阵列)、 PLA(Programmable Logic Array，可编程逻辑阵列)中的至少一种硬件形式来实现。处理器21也可以包括主处理器和协处理器，主处理器是用于对在唤醒状态下的数据进行处理的处理器，也称CPU(Central ProcessingUnit，中央处理器)；协处理器是用于对在待机状态下的数据进行处理的低功耗处理器。在一些实施例中，处理器21可以在集成有GPU(Graphics Processing Unit，图像处理器)，GPU用于负责显示屏所需要显示的内容的渲染和绘制。一些实施例中，处理器21还可以包括AI(Artificial Intelligence，人工智能)处理器，该AI处理器用于处理有关机器学习的计算操作。

存储器20可以包括一个或多个计算机可读存储介质，该计算机可读存储介质可以是非暂态的。存储器20还可包括高速随机存取存储器，以及非易失性存储器，比如一个或多个磁盘存储设备、闪存存储设备。本实施例中，存储器20至少用于存储以下计算机程序201，其中，该计算机程序被处理器21加载并执行之后，能够实现前述任一实施例公开的分布式集群时间同步方法的相关步骤。另外，存储器20所存储的资源还可以包括操作系统202和数据203 等，存储方式可以是短暂存储或者永久存储。其中，操作系统202可以包括 Windows、Unix、Linux等。数据203可以包括但不限于分布式集群时间同步方法涉及到的数据。

在一些实施例中，分布式集群时间同步装置还可包括有显示屏22、输入输出接口23、通信接口24、电源25以及通信总线26。

本领域技术人员可以理解，图9中示出的结构并不构成对分布式集群时间同步装置的限定，可以包括比图示更多或更少的组件。

最后，本申请还提供一种计算机可读存储介质对应的实施例。计算机可读存储介质上存储有计算机程序，计算机程序被处理器执行时实现如上述方法实施例中记载的步骤。

可以理解的是，如果上述实施例中的方法以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本申请的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，执行本申请各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：U盘、移动硬盘、只读存储器(Read-Only Memory，ROM)、随机存取存储器(Random Access Memory，RAM)、磁碟或者光盘等各种可以存储程序代码的介质。

本实施例所提供的计算机可读存储介质，存储有计算机程序，计算机程序被处理器执行时实现如上述方法实施例中记载的步骤；通过接收业务节点发送的请求Tick的指令并确定当前Tick；根据请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；按照接收请求Tick的指令的顺序向对应的业务节点发送新的Tick。通过采用逻辑时钟的方式使得各业务节点的交互达成时间同步，避免了集群中数据不同步的问题。

以上对本申请所提供的分布式集群时间同步方法、装置及计算机可读存储介质进行了详细介绍。说明书中各个实施例采用递进的方式描述，每个实施例重点说明的都是与其他实施例的不同之处，各个实施例之间相同相似部分互相参见即可。对于实施例公开的装置而言，由于其与实施例公开的方法相对应，所以描述的比较简单，相关之处参见方法部分说明即可。应当指出，对于本技术领域的普通技术人员来说，在不脱离本申请原理的前提下，还可以对本申请进行若干改进和修饰，这些改进和修饰也落入本申请权利要求的保护范围内。

还需要说明的是，在本说明书中，诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来，而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。

Claims (10)

1.一种分布式集群时间同步方法，其特征在于，应用于包含有业务节点和定时节点的分布式集群，所述业务节点为多个，所述方法应用于所述定时节点，所述方法包括：

接收所述业务节点发送的请求Tick的指令；

确定当前Tick；

根据所述请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；

按照接收所述请求Tick的指令的顺序向对应的所述业务节点发送新的Tick。

2.根据权利要求1所述的分布式集群时间同步方法，其特征在于，所述接收所述业务节点发送的请求Tick的指令包括：

读取消息缓存队列中的所述请求Tick的指令；

其中，所述消息缓存队列用于存储所述业务节点发送的所述请求Tick的指令。

3.根据权利要求1所述的分布式集群时间同步方法，其特征在于，所述接收所述业务节点发送的请求Tick的指令包括：

通过TCP socket接收所述业务节点发送的所述请求Tick的指令。

4.根据权利要求1所述的分布式集群时间同步方法，其特征在于，在所述接收所述业务节点发送的请求Tick的指令之前，还包括：

根据物理时间重置Tick。

5.根据权利要求1所述的分布式集群时间同步方法，其特征在于，所述定时节点为两个，两个所述定时节点通信连接；

所述确定当前Tick包括：

获取另一个所述定时节点发送的新的Tick，以作为当前所述定时节点的当前所述Tick。

6.根据权利要求5所述的分布式集群时间同步方法，其特征在于，分布式集群还包括Ingress(12)；所述Ingress(12)连接两个所述定时节点，并连接所述业务节点，以用于当一个所述定时节点处理所述业务节点发送的请求Tick的指令时，切换另一个所述定时节点接收其他所述业务节点发送的请求Tick的指令。

7.一种分布式集群，其特征在于，包括定时节点和业务节点，其中所述业务节点为多个；

所述业务节点用于向所述定时节点发送请求Tick的指令；

所述定时节点连接所述业务节点，用于根据所述请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；按照接收所述请求Tick的指令的顺序向对应的所述业务节点发送新的Tick。

8.一种分布式集群时间同步装置，其特征在于，包括：

接收模块，用于接收所述业务节点发送的请求Tick的指令；

确定模块，用于确定当前Tick；

生成模块，用于根据所述请求Tick的指令的数量生成对应数量的新的Tick，其中，新的Tick在当前Tick的基础上依次加1；

发送模块，用于按照接收所述请求Tick的指令的顺序向对应的所述业务节点发送新的Tick。

9.一种分布式集群时间同步装置，其特征在于，包括：

存储器，用于存储计算机程序；

处理器，用于执行所述计算机程序时实现如权利要求1至6任一项所述的分布式集群时间同步方法的步骤。

10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如权利要求1至6任一项所述的分布式集群时间同步方法的步骤。

Images