CN113806813A - 一种多数据源的数据隔离切换方法和系统 - Google Patents

Abstract

本发明涉及一种多数据源的数据隔离切换方法和系统，方法包括获取数据源信息，根据该数据源信息连接对应的数据源，创建数据源连接池，将该数据源连接池注册到上下文容器中，并生成该数据源的唯一标识；数据处理过程中，获取数据处理需要的数据源的唯一标识，从而从上下文容器获取对应的数据源连接池，供数据处理。与现有技术相比，本发明可实现动态加载和动态销毁数据源的方式，不需要重新修改程序、发布应用程序的等，实时性和易操作性更强，支持加载多个不同的数据源，以支撑不同的业务需求。

Description

一种多数据源的数据隔离切换方法和系统

技术领域

本发明涉及数据源控制技术领域，尤其是涉及一种多数据源的数据隔离切换方法和系统。

背景技术

在现在的IT系统中，数据源控制是核心中的核心，任何的业务功能，最终都落在的数据存储中，而数据也是企业最重要的IT资产。

数据源的基本原理是程序获取数据源的连接信息，需要使用时，通过连接信息和数据源协议，连接上数据服务，通过将特定的数据操作指令传输给数据服务，数据服务执行对应的操作，并将结果返回给调用方。

目前的数据源使用方法分为以下两种：实时连接，初始化连接池。两种数据源的管理和使用方式都有其弊端。

1、实时连接方式是在使用数据源操作时，拿到数据源相关连接参数信息，通过特定协议建立连接，发送相关操作，在动作完成后释放对应的连接，并销毁此次连接的对象信息。此方案较为灵活，但是有以下三大弊端：

其一是每个数据源操作前都需要获取连接信息，并建立对应的连接，并且在时候销毁，会给代码编程带来极大的冗余工作，耦合业务逻辑；

其二是单独的连接和释放连接操作会带来严重的性能损耗，网络连接的建立，通信，关闭是系统性能的重要瓶颈。

其三是没有统一的地方管理数据源连接参数和配置。散落在每个不同的业务逻辑中，难以维护和升级。

2、初始化数据源连接池在应用程序启动时，通过配置读取到数据源相关连接参数信息，通过协议建立连接，并将此数据源对象存储在内存中，供所有地方使用。此方案好处是统一管理数据源连接参数和配置信息，并且只需要在程序初始化时建立数据源连接池，提升了新能。但是此方案同样存在以下弊端：

其一，此方案不够灵活，只能在程序初始化时加载对应的数据源连接池。

其二，只有一个可供使用的全局数据源连接，无法满足多个数据源的业务需求。

其三，如果需要修改数据源连接信息，需要修改对应的代码和配置，并重新部署整个服务，对一网络web服务而言，停机部署和更新的都是直接影响到业务和企业工作的，会带来很大的效率损失。

发明内容

本发明的目的就是为了克服上述现有技术存在的缺陷而提供一种实时性和易操作性更强，支持加载多个不同的数据源的多数据源的数据隔离切换方法和系统。

本发明的目的可以通过以下技术方案来实现：

一种多数据源的数据隔离切换方法，包括获取数据源信息，根据该数据源信息连接对应的数据源，创建数据源连接池，将该数据源连接池注册到上下文容器中，并生成该数据源的唯一标识；

数据处理过程中，获取数据处理需要的数据源的唯一标识，从而从上下文容器获取对应的数据源连接池，供数据处理。

进一步地，所述方法还包括新数据源注册步骤，该新数据源注册步骤具体为：

S101：获取待注册数据源的数据源信息，

S102：根据所述数据源信息进行数据源连接测试，若连接成功，则执行步骤S103，否则返回步骤S101；

S103：判断连接成功的数据源是否存在在当前的上下文容器中，若存在，则返回步骤S101，否则执行步骤S104；

S104：根据所述数据源信息，连接该数据源，创建数据源连接池，将该数据源连接池注册到上下文容器中，并生成该数据源的唯一标识。

进一步地，所述方法还包括数据源注销步骤，该数据源注销步骤具体为：

S201：生成移除数据源事件；

S202：监听并获取所述数据源事件，判断所述数据源事件对应的数据源是否有活动连接正在使用，若有，则执行步骤S203，否则执行步骤S204；

S203：将该数据源在所述上下文容器中的注册信息删除，等待当前活动连接完成工作后，删除该数据源的所有连接，并销毁对应的数据源连接池。

S204：删除该数据源的所有连接，销毁对应的数据源连接池，将该数据源在所述上下文容器中的注册信息删除。

进一步地，采用雪花算法生成所述数据源的唯一标识。

进一步地，所述从上下文容器获取对应的数据源连接池，供数据处理具体为：

从上下文容器获取对应的数据源连接池，将该数据源连接池绑定到当前线程的线程上下文中，进行数据处理。

进一步地，数据处理过程中，获取数据处理需要的数据源的唯一标识具体为：

在会话控制中的全局参数中加入需要的数据源的唯一标识；

数据处理过程中，通过解析会话控制中的全局参数，获取数据处理需要的数据源的唯一标识。

本发明还提供一种多数据源的数据隔离切换系统，包括存储器和处理器，所述存储器存储有计算机程序，处理器调用所述计算机程序执行如上所述的方法的步骤。

与现有技术相比，本发明具有以下优点：

(1)本发明在根据数据源建立数据源连接池的基础上，还将数据源连接池注册到上下文容器中，并配备唯一标识；数据处理过程中，根据该唯一标识，即可加载对应的数据源连接池，供调用处理；

现有技术中每个数据源连接池直接在程序初始化时建立，程序代码直接关联数据源连接池，需要修改数据源连接信息时，无法在程序运行时实现，需要修改程序代码和配置，并重新部署整个服务，重新在初始化时加载数据源连接池，带来很大的效率损失；

本发明对各个数据源连接池设置对应的唯一标识，程序根据该唯一标识加载对应的数据源连接池，如果需要新增或销毁数据源，可在程序运行时，通过会话控制根据唯一标识记载对应的数据源，通过生成移除数据源事件销毁上下文容器中的数据源，无需停机部署、不需要重新修改程序、发布应用程序等，实时性和易操作性更强，支持加载多个不同的数据源，以支撑不同的业务需求。

(2)本发明采取session全局参数传递当前操作需要的数据源标识，做到与具体的代码和框架解耦，不依赖代码开发控制和技术框架限制。

(3)本发明使用ThreadLocal(线程上下文)，可以保证在一个线程的全逻辑中，使用的数据源一致，此颗粒度既能够解决不同的操作需要使用不同的数据源，也能够满足相同的一批程序执行过程中使用同一个数据源，不需要单独建立连接，大大提升性能，简化逻辑。

附图说明

图1为本发明实施例中提供的一种数据源动态注册加载管理流程图。

具体实施方式

为使本发明实施例的目的、技术方案和优点更加清楚，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。通常在此处附图中描述和示出的本发明实施例的组件可以以各种不同的配置来布置和设计。

因此，以下对在附图中提供的本发明的实施例的详细描述并非旨在限制要求保护的本发明的范围，而是仅仅表示本发明的选定实施例。基于本发明中的实施例，本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。

实施例1

本实施例提供一种多数据源的数据隔离切换方法，包括获取数据源信息，根据该数据源信息连接对应的数据源，创建数据源连接池，将该数据源连接池注册到上下文容器中，并生成该数据源的唯一标识；

数据处理过程中，获取数据处理需要的数据源的唯一标识，从而从上下文容器获取对应的数据源连接池，供数据处理。

当有新的数据源注册时，使用雪花算法生成此数据源的唯一标识，并将此数据实例化的数据源连接池加载到全局上下文容器中；当数据源注销时，销毁此数据源连接池和全局上下文中映射关系，此过程包含以下步骤：

新数据源注册步骤：

S101：用户创建或者维护新的数据源信息，即数据源连接信息，

S102：服务端接收到数据源信息后，尝试对此数据源连接信息测试连接，若连接成功，则执行步骤S103，否则返回步骤S101；

S103：判断连接成功的数据源是否存在在当前的上下文容器中，若存在，则返回步骤S101，否则执行步骤S104；

S104：根据数据源信息，服务端连接该数据源，创建数据源连接池，将该数据源连接池注册到上下文容器中，并生成该数据源的唯一标识。

数据源注销步骤：

S201：如果此数据源不再使用，则需要发送移除数据源事件；

S202：监听并获取数据源事件，判断数据源事件对应的数据源是否有活动连接正在使用，若有，则执行步骤S203，否则执行步骤S204；

S203：将该数据源在上下文容器中的注册信息删除，等待当前活动连接完成工作后，删除该数据源的所有连接，并销毁对应的数据源连接池。

S204：删除该数据源的所有连接，销毁对应的数据源连接池，将该数据源在上下文容器中的注册信息删除。

上述数据源动态加载和动态注销流程说明了某个数据源的全生命周期，在数据源使用过程中，根据当前session(会话控制)的上下文信息切换，动态解析session中参数，转换为数据源的雪花id，并通过此雪花id获取到数据源的连接池，将此连接池信息绑定到当前Thread(线程)的ThreadLocal(线程上下文)中，保证数据源中的连接池可用且线程隔离，线程执行完毕后销毁此ThreadLocal中的内容，以防止线程复用时出错；

图1所示为本实施例方法中数据源动态注册加载管理流程，完成多数据源动态注册和加载控制。下面以一个新的数据源连接为例，结合图1进行详细描述：

在步骤401中，客户端向服务端发送新的数据源连接信息，地址为localhost:3306，用户名为definesys，密码为definesys；

在步骤402中，服务端接收到此连接信息，尝试建立数据源连接；

在步骤403中，判断连接是否成功，如果成功，执行步骤404；如果不成功，则结束；

在步骤404中，解析当前数据源连接参数，并获取唯一标识，执行405；

在步骤405中，判断当前数据源连接池是否已经注册到全局上下文的容器中，如果已经注册，则结束并返回成功；如果不存在，则执行406；

在步骤406中，根据数据源参数，创建此数据源连接池，并使用雪花算法生成唯一标识，执行407；

在步骤407中，将此数据源连接池实例注册到全局上下文容器中，并使用雪花id作为唯一标识。

本实施例还提供一种多数据源的数据隔离切换系统，包括存储器和处理器，所述存储器存储有计算机程序，处理器调用所述计算机程序执行如上所述的一种多数据源的数据隔离切换方法的步骤。

以上详细描述了本发明的较佳具体实施例。应当理解，本领域的普通技术人员无需创造性劳动就可以根据本发明的构思做出诸多修改和变化。因此，凡本技术领域中技术人员依本发明的构思在现有技术的基础上通过逻辑分析、推理或者有限的实验可以得到的技术方案，皆应在由权利要求书所确定的保护范围内。

Claims (10)

1.一种多数据源的数据隔离切换方法，其特征在于，包括获取数据源信息，根据该数据源信息连接对应的数据源，创建数据源连接池，将该数据源连接池注册到上下文容器中，并生成该数据源的唯一标识；

数据处理过程中，获取数据处理需要的数据源的唯一标识，从而从上下文容器获取对应的数据源连接池，供数据处理。

2.根据权利要求1所述的一种多数据源的数据隔离切换方法，其特征在于，所述方法还包括新数据源注册步骤，该新数据源注册步骤具体为：

S101：获取待注册数据源的数据源信息，

S102：根据所述数据源信息进行数据源连接测试，若连接成功，则执行步骤S103，否则返回步骤S101；

S103：判断连接成功的数据源是否存在在当前的上下文容器中，若存在，则返回步骤S101，否则执行步骤S104；

S104：根据所述数据源信息，连接该数据源，创建数据源连接池，将该数据源连接池注册到上下文容器中，并生成该数据源的唯一标识。

3.根据权利要求1所述的一种多数据源的数据隔离切换方法，其特征在于，所述方法还包括数据源注销步骤，该数据源注销步骤具体为：

S201：生成移除数据源事件；

S202：监听并获取所述数据源事件，判断所述数据源事件对应的数据源是否有活动连接正在使用，若有，则执行步骤S203，否则执行步骤S204；

S203：将该数据源在所述上下文容器中的注册信息删除，等待当前活动连接完成工作后，删除该数据源的所有连接，并销毁对应的数据源连接池；

S204：删除该数据源的所有连接，销毁对应的数据源连接池，将该数据源在所述上下文容器中的注册信息删除。

4.根据权利要求1所述的一种多数据源的数据隔离切换方法，其特征在于，采用雪花算法生成所述数据源的唯一标识。

5.根据权利要求1所述的一种多数据源的数据隔离切换方法，其特征在于，所述从上下文容器获取对应的数据源连接池，供数据处理具体为：

从上下文容器获取对应的数据源连接池，将该数据源连接池绑定到当前线程的线程上下文中，进行数据处理。

6.根据权利要求1所述的一种多数据源的数据隔离切换方法，其特征在于，数据处理过程中，获取数据处理需要的数据源的唯一标识具体为：

在会话控制中的全局参数中加入需要的数据源的唯一标识；

数据处理过程中，通过解析会话控制中的全局参数，获取数据处理需要的数据源的唯一标识。

7.一种多数据源的数据隔离切换系统，其特征在于，包括存储器和处理器，所述存储器存储有计算机程序，处理器调用所述计算机程序执行以下步骤：

获取数据源信息，根据该数据源信息连接对应的数据源，创建数据源连接池，将该数据源连接池注册到上下文容器中，并生成该数据源的唯一标识；

数据处理过程中，获取数据处理需要的数据源的唯一标识，从而从上下文容器获取对应的数据源连接池，供数据处理。

8.根据权利要求7所述的一种多数据源的数据隔离切换系统，其特征在于，所述处理器的执行过程还包括新数据源注册步骤，该新数据源注册步骤具体为：

S101：获取待注册数据源的数据源信息，

S102：根据所述数据源信息进行数据源连接测试，若连接成功，则执行步骤S103，否则返回步骤S101；

S103：判断连接成功的数据源是否存在在当前的上下文容器中，若存在，则返回步骤S101，否则执行步骤S104；

S104：根据所述数据源信息，连接该数据源，创建数据源连接池，将该数据源连接池注册到上下文容器中，并生成该数据源的唯一标识。

9.根据权利要求7所述的一种多数据源的数据隔离切换系统，其特征在于，所述处理器的执行过程还包括数据源注销步骤，该数据源注销步骤具体为：

S201：生成移除数据源事件；

S202：监听并获取所述数据源事件，判断所述数据源事件对应的数据源是否有活动连接正在使用，若有，则执行步骤S203，否则执行步骤S204；

S203：将该数据源在所述上下文容器中的注册信息删除，等待当前活动连接完成工作后，删除该数据源的所有连接，并销毁对应的数据源连接池；

S204：删除该数据源的所有连接，销毁对应的数据源连接池，将该数据源在所述上下文容器中的注册信息删除。

10.根据权利要求7所述的一种多数据源的数据隔离切换系统，其特征在于，数据处理过程中，获取数据处理需要的数据源的唯一标识具体为：

在会话控制中的全局参数中加入需要的数据源的唯一标识；

数据处理过程中，通过解析会话控制中的全局参数，获取数据处理需要的数据源的唯一标识。

Images