CN111865632B - 分布式数据存储集群的切换方法及切换指令发送方法和装置 - Google Patents

Abstract

本申请公开一种分布式数据存储集群的切换方法及装置，分布式数据存储集群切换指令的发送方法及装置，分布式数据存储集群的切换系统，以及计算机存储介质和电子设备。其中，所述切换方法包括：获取针对源分布式数据存储集群的切换指令；根据所述切换指令，开启与目标分布式数据存储集群之间的连接通道；将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群；从而能够分布式数据存储集群以及用户无感知的情况下，能够在线且瞬间地完成切换完成多个分布式数据存储集群的切换，减少切换占用时间，实现高可用。

Description

分布式数据存储集群的切换方法及切换指令发送方法和装置

技术领域

本申请涉及计算机应用领域，具体涉及一种分布式数据存储集群的切换方法及装置。本申请同时涉及一种分布式数据存储集群切换指令的发送方法及装置，计算机存储介质及电子设备。

背景技术

随着大数据的发展，分布式数据存储集群被广泛的应用到存储及服务领域，例如：HBase分布式数据存储集群，简称HBase集群。其是Hadoop生态下著名的NoSQL数据库和存储系统构建的存储集群，被广泛使用在搜索，商品订单，消费记录，监控系统，聊天推送等在线系统中，并在这些系统中有着举足轻重的作用。由于HBase本身是一个分布式数据存储系统，因此，在单机宕机等故障下能够自动恢复，不会影响业务。然而，由其构建的HBase集群，在大规模宕机或者网络故障等问题发生时，则仍然会导致由HBase构成的分布式数据存储集群长时间不可用，即恢复时间较长，从而导致相关服务受到影响。

为解决此问题，现有HBase加入了同步(Replication)机制，即集群间的数据同步机制。Replication能够让主HBase集群中的数据实时地同步到备HBase集群中。因此，当主HBase集群出现故障时，用户仍然可以访问备HBase集群，从而达到高可用的目的。

但是，由于HBase集群的客户端仅支持访问单个HBase集群，也就是说，HBase集群的客户端仅支持配置一个HBase集群的地址，因此，在整个生命周期中，只能向已配置的HBase集群的地址发送请求。如果当已配置的HBase集群出现故障无法服务时，即使还有其他HBase集群可以正常服务，依然无法自动切换至其他HBase集群进行访问。该种情况，为保证可用性有两种解决方式：

1、需要先停止HBase集群的进程，修改HBase集群的配置，使其访问地址指向可用的HBase集群，再重启HBase集群，方能开始访问可用的HBase集群。

2、用户需要侵入业务的逻辑，实现一套复杂的切换系统来完成这一系列复杂的动作。

无论是上述哪种切换方式，均会导致主备/容灾切换的速度较慢，无法达到高可用的目的。

发明内容

本申请提供一种分布式数据存储集群的切换方法，以解决现有技术中主备/容灾切换的速度较慢的问题。本申请另外提供分布式数据存储集群切换指令的发送方法。

本申请提供一种分布式数据存储集群的切换方法，包括：

获取针对源分布式数据存储集群的切换指令；

根据所述切换指令，开启与目标分布式数据存储集群之间的连接通道；

将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

在一些实施例中，所述获取针对分布式数据存储集群的切换指令，包括：

监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知；

根据所述变更通知获取针对分布式数据存储集群的切换指令。

在一些实施例中，所述根据所述变更通知获取针对分布式数据存储集群的切换指令，包括：

根据所述变更通知发送获取切换指令请求；

接收针对所述分布式数据存储集群的切换指令。

在一些实施例中，所述监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知，包括：

基于针对源分布式数据存储集群的访问请求的失败状态，监听所述分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对所述分布式数据存储集群的变更通知。

在一些实施例中，所述监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知，包括：

分别监听来自至少两个分布式协调服务侧的所述管理节点，获取所述分布式协调服务侧各自管理节点中的变更通知。

在一些实施例中，所述根据所述切换指令，开启与目标分布式数据存储集群之间的连接通道，包括：

解析所述切换指令中的切换内容；

根据所述切换内容，调用开启所述目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道。

在一些实施例中，所述根据所述切换内容，调用开启所述目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道，包括：

根据调用的所述启动接口，启用所述切换内容中描述所述目标分布式数据存储集群的访问地址。

在一些实施例中，还包括：

根据所述切换指令，关闭与源分布式数据存储集群之间的连接通道。

在一些实施例中，所述根据所述切换指令，关闭与源分布式数据存储集群之间的连接通道，包括：

根据所述切换内容，调用关闭所述源分布式数据存储集群连接通道的关闭接口，关闭与所述源分布式数据存储集群之间的连接通道。

在一些实施例中，所述根据所述切换内容，调用关闭所述源分布式数据存储集群连接通道的关闭接口，关闭与所述源分布式数据存储集群之间的连接通道，包括：

根据调用的所述关闭接口，禁用所述切换内容中描述所述源分布式数据存储集群的访问地址。

本申请还提供一种分布式数据存储集群的切换装置，包括：

获取单元，用于获取针对分布式数据存储集群的切换指令；

切换单元，用于根据所述切换指令，开启与目标分布式数据存储集群之间的连接通道；

访问请求发送单元，用于将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

本申请还提供一种分布式数据存储集群切换指令的发送方法，包括：

获取针对源分布式数据存储集群的访问请求；

根据所述访问请求生成针对源分布式数据存储集群的切换指令；

将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧。

在一些实施例中，所述获取针对源分布式数据存储集群的访问请求，包括：

获取针对源分布式数据存储集群的访问请求的请求时长；

当所述请求时长大于响应时长时，获取针对源分布式数据存储集群的访问请求。

在一些实施例中，所述当所述请求时长大于响应时长时，获取针对源分布式数据存储集群的访问请求，包括：

当所述请求时长大于响应时长的上限值时，获取针对源分布式数据存储集群的访问请求。

在一些实施例中，所述将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧，包括：

将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧的管理节点。

在一些实施例中，所述将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧的管理节点，包括：

将所述切换指令分别发送至一个或多个分布式协调服务侧的管理节点。

本申请还提供一种分布式数据存储集群切换指令的发送装置，包括：

获取单元，用于获取针对分布式数据存储集群的访问请求；

生成单元，用于根据所述访问请求生成针对分布式数据存储集群的切换指令；

切换指令发送单元，用于将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧。

本申请还提供一种分布式数据存储集群的切换系统，包括：分布式数据存储集群切换器、分布式协调服务侧和分布式数据存储集群切换管理侧；

所述分布式数据存储集群切换器，用于根据针对分布式数据存储集群的访问请求生成切换指令，并将所述切换指令发送至所述分布式协调服务侧；

所述分布式协调服务侧，用于接收所述分布式数据存储集群切换器发送的所述切换指令；

所述分布式数据存储集群切换管理侧，用于监听所述分布式协调服务侧接收到的所述切换指令，根据所述切换指令，关闭所述源分布式数据存储集群的连接通道，并开启目标分布式数据存储集群的连接通道，通道开启将所述切换指令中针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

在一些实施例中，所述分布式协调服务侧包括：管理节点；

所述分布式数据存储集群切换器具体用于将所述切换指令发送至用于描述分布式数据存储集群切换信息的所述管理节点；

所述管理节点用于接收所述分布式数据存储集群切换器发送的所述切换指令。

在一些实施例中，所述分布式数据存储集群切换管理器包括：切换指令监听器和分布式数据存储集群切换连接服务侧；

所述切换指令监听器，用于监听分布式协调服务侧中的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知，根据所述变更通知获取针对分布式数据存储集群的切换指令；

所述分布式数据存储集群切换连接服务侧，用于根据所述切换指令，关闭所述源分布式数据存储集群的连接通道，并开启目标分布式数据存储集群的连接通道，并将所述切换指令中针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

本申请还提供一种计算机存储介质，用于存储程序；

所述程序在被所述处理器读取执行时，使得所述处理器执行如上所述的分布式数据存储集群的切换方法中的步骤，或者执行如上所述的分布式数据存储集群切换指令的发送方法中的步骤。

本申请还提供一种电子设备，包括：

处理器；

存储器，用于存储程序，所述程序在被所述处理器读取执行时，使得所述电子设备执行如上所述的分布式数据存储集群的切换方法中的步骤，或者执行如上所述的分布式数据存储集群切换指令的发送方法中的步骤。

与现有技术相比，本申请具有以下优点:

本申请提供一种分布式数据存储集群的切换方法，包括：获取针对源分布式数据存储集群的切换指令；根据所述切换指令，关闭与源分布式数据存储集群之间的连接通道，并开启与目标分布式数据存储集群之间的连接通道；将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群；从而能够分布式数据存储集群以及用户无感知的情况下，能够在线且瞬间地完成切换完成多个分布式数据存储集群的切换，减少切换占用时间，实现高可用。

本申请还提供一种分布式数据存储集群切换指令的发送方法，包括：获取针对源分布式数据存储集群的访问请求；根据所述访问请求生成针对源分布式数据存储集群的切换指令；将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧，从而分布式数据存储集群能够根据切换指令完成源分布式数据存储集群与目标分布式数据存储集群之间的切换。另外，发送方法中可以将切换指令发送到多个分布式协调服务侧的管理节点上，从而在某个分布式协调服务侧不可用时，不会影响其他分布式协调服务侧中管理节点接收切换指令。

附图说明

图1是本申请提供的一种分布式数据存储集群的切换方法实施例的流程图；

图2是本申请提供的一种分布式数据存储集群的切换装置实施例的结构示意图；

图3是本申请提供的一种分布式数据存储集群切换指令的发送方法实施例的流程图；

图4是本申请提供的一种分布式数据存储集群切换指令的发送装置实施例的结构示意图；

图5是本申请提供的一种分布式数据存储集群的切换系统实施例的结构示意图。

具体实施方式

在下面的描述中阐述了很多具体细节以便于充分理解本申请。但是本申请能够以很多不同于在此描述的其它方式来实施，本领域技术人员可以在不违背本申请内涵的情况下做类似推广，因此本申请不受下面公开的具体实施的限制。

本申请中使用的术语是仅仅出于对特定实施例描述的目的，而非旨在限制本申请。在本申请中和所附权利要求书中所使用的描述方式例如：“一种”、“第一”、和“第二”等，并非对数量上的限定或先后顺序上的限定，而是用来将同一类型的信息彼此区分。

基于上述背景技术中的描述，虽然分布式数据存储集群具有数据同步的机制，即：主数据存储集群中的数据能够实时的同步到备数据存储集群中，但是，由于针对主数据存储集群的客户端仅配置有单一的访问地址，即：在主数据存储集群出现问题时，仅可切换到已配置的单一备数据存储集群进行访问，故而在已配置的单一备数据存储集群出现故障时会导致数据访问不可用，此时，需要重新进行相关配置以及重启等一系列的操作后，针对分布式数据存储集群的客户端方可访问可用备数据存储集群，而无法自动切换到其他可用的备数据存储集群进行数据访问，该种切换方式均会导致切换速度降低，延长集群恢复时间，进而无法达到高可用。

因此，本申请提供的分布式数据存储集群的切换方法不存在任何重启等操作，即可实现多个数据存储集群之间的自动切换，也就是，当分布式数据存储集群不可用时，能够自动切换到其他分布式数据存储集群，进而保证正常的数据访问，且切换过程对于访问数据存储集群的访问者毫无感知。下面将对本申请提供一种分布式数据存储集群的切换方法进行详细说明。

请参考图1所示，图1是本申请提供的一种分布式数据存储集群的切换方法实施例的流程图，该切换方法包括：

步骤S101：获取针对源分布式数据存储集群的切换指令。

所述步骤S101中涉及的分布式数据存储集群可以是指基于HBase(HadoopDatabase)分布式存储系统中存储数据的分布式数据存储集群，即：HBase集群。HBase是一个高可靠性、高性能、面向列、可伸缩的分布式存储系统。该HBase集群中具有同步机制(Replication)，能够将各个数据存储集群中的数据进行实时同步，从而保证HBase集群中各个数据存储集群中数据的一致性。

切换指令可以理解为，针对多个分布式数据存储集群，当针对当前访问数据存储集群不可用时，切换到另一个可用的数据存储集群的信息。其中，当前访问数据存储集群可以看做是源分布式数据存储集群。

在本实施例中，所述获取针对源分布式数据存储集群的切换指令的具体实现过程可以包括：

监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知；

根据所述变更通知获取针对分布式数据存储集群的切换指令。

其中，分布式协调服务侧(Zookeeper)是一个分布式的，开放源码的分布式应用程序协调服务，是Hadoop和HBase的重要组件。它是一个为分布式应用提供一致性服务的软件，集群的管理者，监视着集群中各个节点的状态根据节点提交的反馈进行下一步合理操作，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

分布式协调服务侧具有状态变化推送的功能即：Watch机制，该Watch机制用于将分布式协调服务节点上的状态变化通知给分布式数据存储集群，该节点可以为管理节点。即：Znode(分布式协调服务侧的节点：管理节点)发生变化。例如：Znode本身的增加，删除，修改，以及子Znode的变化，以及描述分布式数据存储集群切换信息的变化可以通过Watch机制通知到分布式数据存储集群(客户端)。

在本实施例中，通过管理节点(RedirectNode)来描述分布式数据存储集群的切换信息。

以上是对分布式协调服务侧的解释说明，实际上，在获取针对分布式数据存储集群的切换指令时，本实施例，是对所述分布式协调服务侧设定的管理节点(RedirectNode)进行监听，当监听到管理节点的节点内容有变化时，则获取管理节点中针对分布式数据存储集群切换的变更通知，之后根据变更通知获取针对分布式数据存储集群的切换指令。也就是说，当管理节点的节点内容发生变更时，会通过Watch机制推送变更通知，监听到该推送的变更通知后，将根据所述变更通知向所述管理节点发送获取切换指令的请求，进而接收来自管理节点根据获取切换指令请求发送的切换指令，所述切换指令中包括节点变更的内容，也就是集群切换的信息。因此，所述根据所述变更通知获取针对分布式数据存储集群的切换指令，包括：

根据所述变更通知发送获取切换指令请求；

接收针对所述分布式数据存储集群的切换指令。

所述管理节点的节点内容发生变化的原因之一是当前访问的分布式数据存储集群不可用，进而需要切换到其他分布式数据存储集群继续进行访问，因此，所述监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知，包括：

基于针对源分布式数据存储集群的访问请求的失败状态，监听所述分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对所述分布式数据存储集群的变更通知。可以理解为，所谓监听可以根据源分布式数据库存储集群是否能够提供正常服务来启动，当用户在针对源分布式数据存储集群的访问请求失败的情况下，则对所述管理节点进行监听，以便获得相关的变更通知以及切换指令。当然，也可以对管理节点实时进行监听，不论针对源分布式数据存储集群的访问请求是正常状态还是失败状态，均进行监听。

在一些实施例中，监听的管理节点可以包括多个，也就是说，分布式协调服务侧也可以是多个集群，每个集群上分别具有管理节点，监听每一个分布式协调服务侧的管理节点，进而能够保证在源分布式数据存储集群出现故障或不可用的情况下，能够通过分布式协调服务集群的管理节点保证切换成功，因为，采用分布式协调服务集群能够避免某一分布式协调服务侧的管理节点出现故障或宕机不可用的情况下，还有其他分布式协调服务侧的管理节点能够提供切换指令，进而为保证正常切换提供基础。因此，所述监听分布式协调服务侧中的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知，包括：

分别监听来自至少两个分布式协调服务侧的所述管理节点，获取所述分布式协调服务侧各自管理节点中的变更通知。

需要说明的是，当分布式协调服务为多个集群时，对于每一个分布式协调服务集群的管理节点需要分别监听，也就是，监听每一个分布式协调服务集群管理节点，达到高可用的目的，当然，也可以设置监听分布式协调服务集群的管理节点的数量。

在基于分布式协调服务侧的管理节点获得切换指令后，则需要根据切换指令的切换内容，对所述分布式数据存储集群进行切换，将针对不可用的源分布式数据存储集群的访问请求，切换到可用的目标分布式数据存储集群，以便完成用户的访问操作，进而执行步骤S102。

步骤S102：根据所述切换指令，开启与目标分布式数据存储集群之间的连接通道。

所述步骤S102中的源分布式数据存储集群可以是指用户针对当前分布式存储集群进行访问的集群，基于切换，可以理解的是，针对当前分布式存储集群进行访问的集群存在不可用的情况。所谓不可用至少有一种解释，即：分布式存储集群存在故障不可用，且切换到其他集群的时间较长。

目标分布式数据存储集群可以是指基于源分布式数据存储集群不可用的情况下，确定的可用的其他分布式数据存储集群，即用户可以正常访问的分布式数据存储集群。

所谓连接通道可以理解为用户访问请求与分布式数据存储集群之间的连接通道，通道连接后，用户可以针对可用的分布式数据存储集群正常进行相关的访问操作。

所述步骤S102的目的在于，将不可用的源分布式数据存储集群切换到可用的目标分布式数据存储集群，以实现用户的访问操作。因此，需要对切换指令进行解析获得切换内容，例如：源分布式数据存储集群的相关信息，以及目标分布式数据存储集群的相关信息等，通过解析的切换内容，对源分布式数据存储集群和目标分布式数据存储集群进行切换，因此，所述步骤S102包括：

解析所述切换指令中的切换内容；

根据所述切换内容，调用开启所述目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道。

可以理解的是，还可以包括：

根据所述切换指令，关闭与源分布式数据存储集群之间的连接通道。

其中，关闭与源分布式数据存储集群之间的连接通道的关闭时间点可以是在开启与目标分布式数据存储集群之间的连接通道之前或者之后，或者开启过程中均可，即可以根据需求设定触发关闭与源分布式数据存储集群之间的连接通道的关闭时间。

在本实施例中，所述根据所述切换内容，关闭与源分布式数据存储集群之间的连接通道，可以通过调用关闭所述源分布式数据存储集群连接通道的关闭接口，关闭与所述源分布式数据存储集群之间的连接通道，能够将不可用的源分布式数据存储集群的连接通道关闭，快速的切换到与所述目标分布式数据存储集群之间的连接通道上，无需进行重新配置以及重新启动等操作，实现分布式数据存储集群之间的快速切换，达到高可用的目的。

为实现连通通道的关闭与开启，本实施例中，在关闭与所述源分布式数据存储集群之间的连接通道时，可以通过根据调用的所述关闭接口，例如：HBase中创建connection连接所提供的Close接口，所述Close接口，提供中断连接。所述关闭资源方式可以是禁用所述切换内容中描述所述源分布式数据存储集群的访问地址。

在开启与所述目标分布式数据存储集群之间的连接通道可以通过根据调用的所述启动接口，启用所述切换内容中描述所述目标分布式数据存储集群的访问地址，从而实现源分布式数据存储集群与目标分布式数据存储集群之间的切换。

所谓切换即为将用户当前访问的源分布式数据存储集群的访问地址切换到目标分布式数据存储集群的访问地址。切换完毕后，需要执行步骤S103，以便用户执行相关访问操作。

步骤S103：将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

所述步骤S103的目的在于，用户能够在针对源分布式数据存储集群发送访问请求，且源分布式数据存储集群不可用的情况下，无感知的进入到目标分布式数据存储集群中进行相应的访问操作，因此，在所述步骤S102完成切换后，用户针对源分布式数据存储集群的访问请求会被自动发送至所述目标分布式数据存储集群，进而使得用户能够在所述目标分布式数据存储集群上完成相关的访问操作。

本申请提供的分布式数据存储集群的切换方法，能够在上层业务(可以理解为用户侧)无感知的情况下，完成客户端(分布式数据存储集群)多集群访问的切换，用户无需修改分布式数据存储集群代码，也无需在业务代码中实现复杂的切换逻辑。相比现有技术中用户停止客户端(分布式数据存储集群)，修改客户端(分布式数据存储集群)配置，然后重启客户端(分布式数据存储集群)的方式实现集群间的切换，本申请提供的方案能够在线，且瞬间地完成切换，减少不可用时间，实现高可用。

以上是对本申请提供的一种分布式数据存储集群的切换方法实施例的说明。与前述提供的一种分布式数据存储集群的切换方法实施例相对应，本申请还公开一种分布式数据存储集群的切换装置实施例，请参看图2，由于装置实施例基本相似于方法实施例，所以描述得比较简单，相关之处参见方法实施例的部分说明即可。下述描述的装置实施例仅仅是示意性的。

如图2所示，图2是本申请提供的一种分布式数据存储集群的切换装置实施例的结构示意图，该装置包括：

获取单元201，用于获取针对分布式数据存储集群的切换指令；

所述获取单元201包括：监听子单元和获取子单元；

所述监听子单元，用于监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知；

获取子单元，用于根据所述变更通知获取针对分布式数据存储集群的切换指令。

所述获取子单元包括：发送子单元和接收子单元；

所述发送子单元，用于根据所述变更通知发送获取切换指令请求；

所述接收子单元，用于接收针对所述分布式数据存储集群的切换指令。

所述监听子单元具体用于基于针对源分布式数据存储集群的访问请求的失败状态，监听所述分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对所述分布式数据存储集群的变更通知。

所述监听子单元为至少两个，分别监听与监听子单元对应的至少两个分布式协调服务侧的所述管理节点，获取所述分布式协调服务侧各自管理节点中的变更通知。

切换单元202，用于根据所述切换指令，开启与目标分布式数据存储集群之间的连接通道；

所述切换单元包括：解析子单元和启动接口调用子单元；

所述解析子单元用于解析所述切换指令中的切换内容；

所述关闭接口调用子单元，用于根据所述切换内容，调用关闭所述源分布式数据存储集群连接通道的关闭接口，关闭与所述源分布式数据存储集群之间的连接通道；

所述启动接口调用子单元，用于根据所述切换内容，调用开启所述目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道。

为能够将不可用的源分布式数据存储集群的连接通道关闭，快速的切换到与所述目标分布式数据存储集群之间的连接通道上，进而还包括：

关闭单元，用于根据所述切换指令，关闭与源分布式数据存储集群之间的连接通道。

所述关闭单元包括：关闭接口调用子单元，用于根据所述切换内容，调用关闭所述源分布式数据存储集群连接通道的关闭接口，关闭与所述源分布式数据存储集群之间的连接通道。

所述关闭接口调用子单元包括：禁用子单元，用于根据调用的所述关闭接口，禁用所述切换内容中描述所述源分布式数据存储集群的访问地址。

所述启动接口调用子单元包括：启用子单元，用于根据调用的所述启动接口，启用所述切换内容中描述所述目标分布式数据存储集群的访问地址。

访问请求发送单元203，用于将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

所述访问请求发送单元203能够在用户针对源分布式数据存储集群发送访问请求，且源分布式数据存储集群不可用的情况下，无感知的进入到目标分布式数据存储集群中进行相应的访问操作，因此，在所述步骤S102完成切换后，用户针对源分布式数据存储集群的访问请求会被自动发送至所述目标分布式数据存储集群，进而使得用户能够在所述目标分布式数据存储集群上完成相关的访问操作。

以上是对本申请提供的一种分布式数据存储集群的切换装置实施例的说明。基于上述内容，本申请还提供的一种分布式数据存储集群切换指令的发送方法，如图3所示，图3是本申请提供的一种分布式数据存储集群切换指令的发送方法实施例的流程图，该发送方法包括：

步骤S301：获取针对分布式数据存储集群的访问请求。

所述步骤S301中的访问请求可以是指用户基于分布式数据存储集群的访问操作请求，当然也可以理解为用户针对分布式数据存储集群中的某一数据库的访问操作请求。

所述访问请求中可以包括访问分布式数据存储集群的相关信息、用户信息、访问内容信息等至少一种信息。

分布式数据存储集群可以理解为有多个数据存储系统构成的集群，每个数据存储系统能够存储数据库中的部分数据。

所述步骤S301的目的是获取用户针对分布式数据存储集群的访问请求，以便为后续集群的切换提供基础。那么，在用户针对分布式数据存储集群的访问请求不成功的情况下，才需要对分布式数据存储集群进行切换，以保证用户的正常访问操作，因此，所述步骤S301可以包括：

获取针对分布式数据存储集群的访问请求的请求时长；

当所述请求时长大于响应时长时，获取针对分布式数据存储集群的访问请求。

也就是说，当用户向源分布式数据存储集群发送访问请求后，在设定的响应时间范围内未收到任何相关信息，则可以判断处源分布式数据存储集群出现故障，进而获取所述访问请求，当然，也可以在收到针对访问请求响应的不可用等相关信息后获取所述访问请求。

基于上述实施例中的当所述请求时长大于响应时长时，获取针对分布式数据存储集群的访问请求，可以包括：

当所述请求时长大于响应时长的上限值时，获取针对源分布式数据存储集群的访问请求。

步骤S302：根据所述访问请求生成针对源分布式数据存储集群的切换指令。

所述步骤S302的目的在于当源分布式数据存储集群出现不可用等情况时，将根据获取的访问请求生成针对源分布式数据存储集群的切换指令，以便后续将源分布式数据存储集群切换到目标分布式数据存储集群。

因此，所述切换指令中可以包括源分布式数据存储集群的相关信息和目标分布式数据存储集群的相关信息等。

步骤S303：将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧。

所述步骤S303的目的在于，当源分布式数据存储集群出现不可用的情况下，将生成的切换指令发送出去，以便对源分布式数据存储集群进行切换，保证用户的正常访问操作。

其中，所述分布式协调服务侧可以参考上述步骤S101中的描述，此处不再赘述。

为实现后续分布式数据存储集群的成功切换，避免存在多个不可用的分布式数据存储集群而导致切换失败，所述步骤S303可以包括：

将所述切换指令分别发送至一个或多个分布式协调服务侧的管理节点。

也就是说，分布式协调服务侧的管理节点可以是多个，即分布式协调服务侧是以集群的方式存在，一个分布式协调服务侧具有一个管理节点，进而保证切换成功率也就是高可用性。

以上是对本申请提供的一种分布式数据存储集群切换指令的发送方法实施例的说明。与前述提供的一种分布式数据存储集群切换指令的发送方法实施例相对应，本申请还公开一种分布式数据存储集群切换指令的发送装置实施例，请参看图4，由于装置实施例基本相似于方法实施例，所以描述得比较简单，相关之处参见方法实施例的部分说明即可。下述描述的装置实施例仅仅是示意性的。

如图4所示，图4是本申请提供的一种分布式数据存储集群切换指令的发送装置实施例的结构示意图，该发送装置包括：

获取单元401，用于获取针对分布式数据存储集群的访问请求。

所述获取单元401包括：请求时长获取子单元，用于获取针对源分布式数据存储集群的访问请求的请求时长。

所述获取单元401具体用于当所述请求时长大于响应时长时，获取针对源分布式数据存储集群的访问请求。

基于请求时长获取子单元，所述获取单元401具体可以用于当所述请求时长大于响应时长的上限值时，获取针对源分布式数据存储集群的访问请求。

生成单元402，用于根据所述访问请求生成针对分布式数据存储集群的切换指令。

切换指令发送单元403，用于将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧。

切换指令发送单元403具体用于将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧的管理节点。

为保证高可用，即切换的成功率，所述切换指令发送单元403具体可以将所述切换指令分别发送至一个或多个分布式协调服务侧的管理节点。

上述对本申请提供的布式数据存储集群切换指令的发送装置实施例的说明为示意性的具体内容可以参考本申请提供的分布式数据存储集群的切换方法和切换指令的发送方法相关介绍。

基于上述内容，本申请还提供的一种分布式数据存储集群的切换系统，如图5所示，图5是本申请提供的一种分布式数据存储集群的切换系统实施例的结构示意图。该切换系统包括：

分布式数据存储集群切换器(ClusterSwitcher)501、分布式协调服务侧(Zookeeper)502和分布式数据存储集群切换管理侧(MulticusterConnectionImpl)503；

所述分布式数据存储集群切换器501，用于根据针对源分布式数据存储集群506的访问请求生成切换指令，并将所述切换指令发送至所述分布式协调服务侧502。

所述分布式协调服务侧502，用于接收所述分布式数据存储集群切换器501发送的所述切换指令。所述分布式协调服务侧(Zookeeper)502包括有管理节点(RedirectNode)502-1，管理节点(RedirectNode)502-1接收所述切换指令。

所述分布式数据存储集群切换管理侧503，用于监听所述分布式协调服务侧502接收到的所述切换指令，根据所述切换指令，关闭所述源分布式数据存储集群506的连接通道，并开启目标分布式数据存储集群507的连接通道，通道开启将所述切换指令中针对源分布式数据存储集群506的访问请求，发送至所述目标分布式数据存储集群507。其中，所述分布式数据存储集群切换管理侧503(MulticusterConnectionImpl)包括：切换监听器(SwitchWatcher)503-1和多集群切换的连接服务(MulticusterConnection)503-2。

在本实施例中，所述分布式数据存储集群切换管理侧实现了分布式数据存储集群(HBase)中的连接类(ClusterConnection Interface)的接口，在使用过程中，可以是通过修改分布式数据存储集群(HBase)中关于连接(connection)类的配置项“hbase.client.connection.impl”来实现替换原有逻辑，即：将配置项中原生的“HConnectionImplementation”修改为“MultiClusterConnectionImpl”即可。

本申请提供的分布式数据存储集群(HBase)的切换系统，最终将根据切换指令将源分布式数据存储集群切换为目标分布式数据存储集群，由目标分布式数据存储集群提供访问资源，从而保证源分布式数据存储集群和目标分布式数据存储集群之间的切换速度，实现高可用性。

需要说明的是，所谓主/备分布式数据存储集群可以是指主分布式数据存储集群，即：主集群；备分布式数据存储集群，即：备集群。通常情况下，用户访问的源分布式数据存储集群即为主集群，当主集群出现故障不可用时，切换到目标分布式数据存储集群即为备集群，因此，源分布式数据存储集群也可以不限定为主集群，即用户当前要访问却无法访问的集群即为源分布式数据存储集群。

基于上述内容，本申请还提供一种计算机存储介质，用于存储程序；

所述程序在被所述处理器读取执行时，使得所述处理器执行如上所述的分布式数据存储集群的切换方法中的步骤，或者执行如上所述的分布式数据存储集群切换指令的发送方法中的步骤。

本申请还提供一种电子设备，包括：

处理器；

存储器，用于存储程序，所述程序在被所述处理器读取执行时，使得所述电子设备执行如上所述的分布式数据存储集群的切换方法中的步骤，或者执行如上所述的分布式数据存储集群切换指令的发送方法中的步骤。

在一个典型的配置中，计算设备包括一个或多个处理器(CPU)、输入/输出接口、网络接口和内存。

内存可能包括计算机可读介质中的非永久性存储器，随机存取存储器(RAM)和/或非易失性内存等形式，如只读存储器(ROM)或闪存(flash RAM)。内存是计算机可读介质的示例。

1、计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括，但不限于相变内存(PRAM)、静态随机存取存储器(SRAM)、动态随机存取存储器(DRAM)、其他类型的随机存取存储器(RAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、快闪记忆体或其他内存技术、只读光盘只读存储器(CD-ROM)、数字多功能光盘(DVD)或其他光学存储、磁盒式磁带，磁带磁磁盘存储或其他磁性存储设备或任何其他非传输介质，可用于存储可以被计算设备访问的信息。按照本文中的界定，计算机可读介质不包括非暂存电脑可读媒体(transitorymedia)，如调制的数据信号和载波。

2、本领域技术人员应明白，本申请的实施例可提供为方法、系统或计算机程序产品。因此，本申请可采用完全硬件实施例、完全软件实施例或结合软件和硬件方面的实施例的形式。而且，本申请可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。

本申请虽然以较佳实施例公开如上，但其并不是用来限定本申请，任何本领域技术人员在不脱离本申请的精神和范围内，都可以做出可能的变动和修改，因此本申请的保护范围应当以本申请权利要求所界定的范围为准。

Claims (20)

1.一种分布式数据存储集群的切换方法，其特征在于，包括：

获取针对源分布式数据存储集群的切换指令；包括：监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知；根据所述变更通知获取针对分布式数据存储集群的切换指令；

解析所述切换指令中的切换内容；

根据所述切换内容，调用开启目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道；

将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

2.根据权利要求1所述的分布式数据存储集群的切换方法，其特征在于，所述根据所述变更通知获取针对分布式数据存储集群的切换指令，包括：

根据所述变更通知发送获取切换指令请求；

接收针对所述分布式数据存储集群的切换指令。

3.根据权利要求1所述的分布式数据存储集群的切换方法，其特征在于，所述监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知，包括：

基于针对源分布式数据存储集群的访问请求的失败状态，监听所述分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对所述分布式数据存储集群的变更通知。

4.根据权利要求1所述的分布式数据存储集群的切换方法，其特征在于，所述监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知，包括：

分别监听来自至少两个分布式协调服务侧的所述管理节点，获取所述分布式协调服务侧各自管理节点中的变更通知。

5.根据权利要求1所述的分布式数据存储集群的切换方法，其特征在于，所述根据所述切换内容，调用开启所述目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道，包括：

根据调用的所述启动接口，启用所述切换内容中描述所述目标分布式数据存储集群的访问地址。

6.根据权利要求1所述分布式数据存储集群的切换方法，其特征在于，还包括：

根据所述切换指令，关闭与源分布式数据存储集群之间的连接通道。

7.根据权利要求6所述的分布式数据存储集群的切换方法，其特征在于，所述根据所述切换指令，关闭与源分布式数据存储集群之间的连接通道，包括：

根据所述切换内容，调用关闭所述源分布式数据存储集群连接通道的关闭接口，关闭与所述源分布式数据存储集群之间的连接通道。

8.根据权利要求7所述的分布式数据存储集群的切换方法，其特征在于，所述根据所述切换内容，调用关闭所述源分布式数据存储集群连接通道的关闭接口，关闭与所述源分布式数据存储集群之间的连接通道，包括：

根据调用的所述关闭接口，禁用所述切换内容中描述所述源分布式数据存储集群的访问地址。

9.一种分布式数据存储集群的切换装置，其特征在于，包括：

获取单元，用于获取针对分布式数据存储集群的切换指令；具体用于监听分布式协调服务侧的用于描述分布式数据存储集群切换信息的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知；根据所述变更通知获取针对分布式数据存储集群的切换指令；

切换单元，用于解析所述切换指令中的切换内容；根据所述切换内容，调用开启目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道；

访问请求发送单元，用于将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

10.一种分布式数据存储集群切换指令的发送方法，其特征在于，包括：

获取针对源分布式数据存储集群的访问请求；

根据所述访问请求生成针对源分布式数据存储集群的切换指令；

将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧；以使分布式数据存储集群切换管理侧解析所述切换指令中的切换内容，根据所述切换内容，调用开启目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道，并将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

11.根据权利要求10所述的分布式数据存储集群切换指令的发送方法，其特征在于，所述获取针对源分布式数据存储集群的访问请求，包括：

获取针对源分布式数据存储集群的访问请求的请求时长；

当所述请求时长大于响应时长时，获取针对源分布式数据存储集群的访问请求。

12.根据权利要求11所述的分布式数据存储集群切换指令的发送方法，其特征在于，所述当所述请求时长大于响应时长时，获取针对源分布式数据存储集群的访问请求，包括：

当所述请求时长大于响应时长的上限值时，获取针对源分布式数据存储集群的访问请求。

13.根据权利要求10所述的分布式数据存储集群切换指令的发送方法，其特征在于，所述将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧，包括：

将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧的管理节点。

14.根据权利要求13所述的分布式数据存储集群切换指令的发送方法，其特征在于，所述将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧的管理节点，包括：

将所述切换指令分别发送至一个或多个分布式协调服务侧的管理节点。

15.一种分布式数据存储集群切换指令的发送装置，其特征在于，包括：

获取单元，用于获取针对分布式数据存储集群的访问请求；

生成单元，用于根据所述访问请求生成针对分布式数据存储集群的切换指令；

切换指令发送单元，用于将所述切换指令发送至用于管理分布式数据存储集群切换的分布式协调服务侧，以使分布式数据存储集群切换管理侧解析所述切换指令中的切换内容，根据所述切换内容，调用开启目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道，并将针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

16.一种分布式数据存储集群的切换系统，其特征在于，包括：分布式数据存储集群切换器、分布式协调服务侧和分布式数据存储集群切换管理侧；

所述分布式数据存储集群切换器，用于根据针对分布式数据存储集群的访问请求生成切换指令，并将所述切换指令发送至所述分布式协调服务侧；

所述分布式协调服务侧，用于接收所述分布式数据存储集群切换器发送的所述切换指令；

所述分布式数据存储集群切换管理侧，用于监听所述分布式协调服务侧接收到的所述切换指令解析所述切换指令中的切换内容，根据所述切换内容，调用开启目标分布式数据存储集群连接通道的启动接口，开启与所述目标分布式数据存储集群之间的连接通道，通道开启将所述切换指令中针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群；还包括用于监听分布式协调服务侧中的管理节点，获取所述管理节点中针对分布式数据存储集群切换的变更通知，根据所述变更通知获取针对分布式数据存储集群的切换指令。

17.根据权利要求16所述的分布式数据存储集群的切换系统，其特征在于，所述分布式协调服务侧包括：管理节点；

所述分布式数据存储集群切换器具体用于将所述切换指令发送至用于描述分布式数据存储集群切换信息的所述管理节点；

所述管理节点用于接收所述分布式数据存储集群切换器发送的所述切换指令。

18.根据权利要求17所述的分布式数据存储集群的切换系统，其特征在于，所述分布式数据存储集群切换管理侧包括分布式数据存储集群切换连接服务侧，用于根据所述切换指令，关闭所述源分布式数据存储集群的连接通道，并开启目标分布式数据存储集群的连接通道，并将所述切换指令中针对源分布式数据存储集群的访问请求，发送至所述目标分布式数据存储集群。

19.一种计算机存储介质，用于存储程序；

所述程序在被处理器读取执行时，使得所述处理器执行如权利要求1至8中的任意一项所述的分布式数据存储集群的切换方法中的步骤，或者执行如权利要求10至14中的任意一项所述的分布式数据存储集群切换指令的发送方法中的步骤。

20.一种电子设备，包括：

处理器；

存储器，用于存储程序，所述程序在被所述处理器读取执行时，使得所述电子设备执行如权利要求1至8中的任意一项所述的分布式数据存储集群的切换方法中的步骤，或者执行如权利要求10至14中的任意一项所述的分布式数据存储集群切换指令的发送方法中的步骤。