分布式数据库访问方法及装置

摘要

本发明提供了一种分布式数据库访问方法及装置，主要涉及计算机领域，可应用于金融领域和其他领域，所述方法具体包含：获取分布式数据库的分库库号；根据待发送的短信内容的消息类别和所述分库库号生成包含所述分库库号的编码信息；将所述编码信息放置于待发送的短信内容中生成短信数据，将所述短信数据发送至预定接受方；以及，接收短信数据，根据所述短信数据的消息类别和所述短信数据中的所述编码信息解析获得对应的分库库号；根据所述分库库号进行数据库分库路由访问并执行对应的业务处理。

说明书

技术领域

本发明涉及计算机领域，可应用于金融领域和其他领域，尤指一种分布式数据库访问方法及装置。

背景技术

随着近年银行信用卡业务面临类互联网场景的高并发高容量的挑战，银行信用卡核心系统逐渐迁移到分布式平台系统，并采取数据库分库的方式对外提供服务。由于业务数据按照一定业务要素(分库键)进行分片存储,例如卡号、客户编号等，对应的联机服务报文中需要带有对应分库键进行数据库路由访问。而目前对应信用卡短信服务场景，基于保护客户隐私要求，一般短信内容中无完整的卡号等分片键信息，无法路由到正确的分库进行业务处理。系统在处理时一般有两种处理方法，一是建立手机号和分片键的对应关系，该方法增加了存储成本，且客户手机号会更改维护不便；二是对于短信服务轮询访问所有分库，将结果整合返回，该方法不能保证时效性，且无法通过横向扩容方式应对交易量并发量大增的情况，无法体现分布式系统的优势。

发明内容

本发明目的在于提供一种分布式数据库访问方法及装置，以在短信内容模板中增加分库健信息的实现方法，使得分布式系统后台接收短信服务请求后能直接或者间接获取到分库健信息进行路由访问对应的分库数据，以较低成本保证服务时效性同时避免轮询访问所有分库的处理。

为达上述目的，本发明所提供的分布式数据库访问方法，具体包含：获取分布式数据库的分库库号；根据待发送的短信内容的消息类别和所述分库库号生成包含所述分库库号的编码信息；将所述编码信息放置于待发送的短信内容中生成短信数据，将所述短信数据发送至预定接受方；以及，接收短信数据，根据所述短信数据的消息类别和所述短信数据中的所述编码信息解析获得对应的分库库号；根据所述分库库号进行数据库分库路由访问并执行对应的业务处理。

在上述分布式数据库访问方法中，优选的，根据待发送的短信内容的消息类别和所述分库库号生成包含所述分库库号的编码信息包含：当所述消息类别为邀请类短信时，获取待发送的短信内容所对应的短信模块；根据短信模板和业务数据所在的分库库号通过RSA算法进行加密获得加密数值；根据所述加密数值的字符串及长度信息组装生成编码信息。

在上述分布式数据库访问方法中，优选的，根据所述短信数据的消息类别和所述短信数据中的所述编码信息解析获得对应的分库库号包含：根据所述短信数据的消息类别和短信模板获得编码信息，根据所述编码信息按预设组成规则获得加密数值；根据所述加密数值通过RSA算法解密获得分库库号。

在上述分布式数据库访问方法中，优选的，根据待发送的短信内容的消息类别和所述分库库号生成包含所述分库库号的编码信息包含：当所述消息类别为答复类短信时，获取待发送的短信内容所对应的短信模块；根据短信模板和业务数据所在的分库库号通过RSA算法进行加密获得加密数值；根据所述加密数值按二十六进制转换后的英文对组装生成编码信息。

在上述分布式数据库访问方法中，优选的，根据所述短信数据的消息类别和所述短信数据中的所述编码信息解析获得对应的分库库号包含：根据所述短信数据的消息类别和短信模板获得编码信息，根据所述编码信息按二十六进制转换获得加密数值；根据所述加密数值通过RSA算法解密获得分库库号。

本发明还提供一种分布式数据库访问装置，所述装置包含分库信息编码模块、分库信息解码模块和通信模块；所述分库信息编码模块用于获取分布式数据库的分库库号；根据待发送的短信内容的消息类别和所述分库库号生成包含所述分库库号的编码信息；将所述编码信息放置于待发送的短信内容中生成短信数据；所述通信模块用于将所述分库信息编码模块生成的所述短信数据发送至预定接受方；以及，接收客户方提供的短信数据，将短信数据传输至所述分库信息解码模块；所述分库信息解码模块用于根据所述短信数据的消息类别和所述短信数据中的所述编码信息解析获得对应的分库库号；根据所述分库库号进行数据库分库路由访问并执行对应的业务处理。

在上述分布式数据库访问装置中，优选的，所述分库信息编码模块包含：当所述消息类别为邀请类短信时，获取待发送的短信内容所对应的短信模块；根据短信模板和业务数据所在的分库库号通过RSA算法进行加密获得加密数值；根据所述加密数值的字符串及长度信息组装生成编码信息。

在上述分布式数据库访问装置中，优选的，所述分库信息解码模块包含：根据所述短信数据的消息类别和短信模板获得编码信息，根据所述编码信息按预设组成规则获得加密数值；根据所述加密数值通过RSA算法解密获得分库库号。

在上述分布式数据库访问装置中，优选的，所述分库信息编码模块包含：当所述消息类别为答复类短信时，获取待发送的短信内容所对应的短信模块；根据短信模板和业务数据所在的分库库号通过RSA算法进行加密获得加密数值；根据所述加密数值按二十六进制转换后的英文对组装生成编码信息。

在上述分布式数据库访问装置中，优选的，所述分库信息解码模块包含：根据所述短信数据的消息类别和短信模板获得编码信息，根据所述编码信息按二十六进制转换获得加密数值；根据所述加密数值通过RSA算法解密获得分库库号。

本发明还提供一种电子设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现上述方法。

本发明还提供一种计算机可读存储介质，所述计算机可读存储介质存储有执行上述方法的计算机程序。

本发明的有益技术效果在于：采用了分库信息编码生成模块和解析模块分别进行分库号的编码和解码，并根据不同的短信类型进行适应业务场景的编码解码扩展功能；不仅实现成本低，无需建立手机号和分库键的映射关系，节省存储空间及手机号变更时的维护成本，而且系统处理性能高，无需全部分库轮询汇总结果，时效性有保证，且能利用分布式横向扩容方式应对交易量并发量大增的情况；同时，在短信内容中增加短信编码，既能隐藏分库信息同时保持较好的用户体验。

附图说明

此处所说明的附图用来提供对本发明的进一步理解，构成本申请的一部分，并不构成对本发明的限定。在附图中：

图1为本发明一实施例所提供的分布式数据库访问方法的流程示意图；

图2为本发明一实施例所提供的编码信息生成的流程示意图；

图3为本发明一实施例所提供的编码信息生成的流程示意图；

图4为本发明一实施例所提供的分布式数据库访问装置的结构示意图；

图5为本发明一实施例所提供的电子设备的结构示意图。

具体实施方式

以下将结合附图及实施例来详细说明本发明的实施方式，借此对本发明如何应用技术手段来解决技术问题，并达成技术效果的实现过程能充分理解并据以实施。需要说明的是，只要不构成冲突，本发明中的各个实施例及各实施例中的各个特征可以相互结合，所形成的技术方案均在本发明的保护范围之内。

另外，在附图的流程图示出的步骤可以在诸如一组计算机可执行指令的计算机系统中执行，并且，虽然在流程图中示出了逻辑顺序，但是在某些情况下，可以以不同于此处的顺序执行所示出或描述的步骤。

请参考图1所示，本发明所提供的分布式数据库访问方法，具体包含：

S101获取分布式数据库的分库库号；根据待发送的短信内容的消息类别和所述分库库号生成包含所述分库库号的编码信息；

S102将所述编码信息放置于待发送的短信内容中生成短信数据，将所述短信数据发送至预定接受方；

S103接收短信数据，根据所述短信数据的消息类别和所述短信数据中的所述编码信息解析获得对应的分库库号；

S104根据所述分库库号进行数据库分库路由访问并执行对应的业务处理。

在实际工作中，上述分布式数据库访问方法的实施流程可如下：

步骤1：在营销类短信模板中增加分库编码信息。

步骤2：创建一个分库信息编码生成模块，用于生成包括分库序号的编码信息；具体实施方式将在后续实施例中详细说明，在此就不再一一详述。

步骤3：创建一个分库信息编码解析模块，用于从短信的分库编码信息中解析获取分库序号；具体实施方式将在后续实施例中详细说明，在此就不再一一详述。

步骤4：系统发送营销类短信时，调用分库信息编码生成模块生成分库序号的编码信息，放置到短信内容中并发送给客户。

步骤5：系统接收到客户转发或答复的短信时，调用分库信息编码解析模块从短信的分库编码信息中解析获取分库序号，并进行数据库分库路由访问并完成业务处理。

请参考图2所示，在本发明一实施例中，根据待发送的短信内容的消息类别和所述分库库号生成包含所述分库库号的编码信息包含：

S201当所述消息类别为邀请类短信时，获取待发送的短信内容所对应的短信模块；

S202根据短信模板和业务数据所在的分库库号通过RSA算法进行加密获得加密数值；

S203根据所述加密数值的字符串及长度信息组装生成编码信息。

具体的，在实际工作中假设该分布式系统分库号为k，长度为klen；对于邀请类短信，输入短信模板编号和业务数据所在的分库序号，利用简单RSA算法进行生成加密后的数字i，长度为ilen。该模块最终生成短信编号为全数字编码X,长度为Xlen，并控制ilen

由此，在本发明另一实施例中，根据所述短信数据的消息类别和所述短信数据中的所述编码信息解析获得对应的分库库号包含：根据所述短信数据的消息类别和短信模板获得编码信息，根据所述编码信息按预设组成规则获得加密数值；根据所述加密数值通过RSA算法解密获得分库库号。例如：对于邀请类短信，系统截取短信内容获取到短信编号X，根据组成规则获取到加密后的数字i，通过RSA算法解密后得到分库号为k。

请参考图3所示，在本发明一实施例中，根据待发送的短信内容的消息类别和所述分库库号生成包含所述分库库号的编码信息包含：

S301当所述消息类别为答复类短信时，获取待发送的短信内容所对应的短信模块；

S302根据短信模板和业务数据所在的分库库号通过RSA算法进行加密获得加密数值；

S303根据所述加密数值按二十六进制转换后的英文对组装生成编码信息。

具体的，在实际工作中假设该分布式系统分库号为k，长度为klen；对于客户答复类短信，输入短信模板编号和业务数据所在的分库序号，利用简单RSA算法进行生成加密后的数字i，长度为ilen。该模块最终生成短信编号为全英文大写字符Y,长度为Ylen，Y由数字i按照26进制转换为对英文表示，例如i＝27，则Y＝AA。

由此，在本发明另一实施例中，根据所述短信数据的消息类别和所述短信数据中的所述编码信息解析获得对应的分库库号包含：根据所述短信数据的消息类别和短信模板获得编码信息，根据所述编码信息按二十六进制转换获得加密数值；根据所述加密数值通过RSA算法解密获得分库库号。例如：对于客户答复类短信，系统截取短信内容获取到短信编号Y，按照英文表示26进制转换获取到加密后的数字i，通过RSA算法解密后得到分库号为k。

综上，在实际工作中上述分库号的编码和解码方法可如下执行：

假设该分布式系统分库号为k，长度为klen，按照目前银行核心系统分布式情况，k一般不超过256；

1、分库号的编码方法

对于邀请类短信：输入短信模板编号和业务数据所在的分库序号，利用简单RSA算法进行生成加密后的数字i，i的字符串表示为I，长度为Ilen，按max(k)＝256计算，取Ilen＝3。该模块最终生成短信编号为全数字编码X,长度为Xlen，考虑到短信内容不影响客户体验，Xlen最多为6位，并控制ilen

2、分库号的解码方法：

对于邀请类短信：系统截取短信内容获取到短信编号X，根据组成规则获取到加密后的数字i，通过RSA算法解密后得到分库号为k。对于客户答复类短信：系统截取短信内容获取到短信编号Y，按照英文表示的26进制转换获取到加密后的数字i，通过RSA算法解密后得到分库号为k。

由此，系统发送短信时，生成分库序号的编码信息，放置到短信内容中并发送给客户。系统接收短信时，从短信的分库编码信息中解析获取分库序号，并进行数据库分库路由访问并完成业务处理。当然，本领域相关技术人员当可知，上述举例仅为便于理解本发明所提供的上述实施例的具体应用方式，并不对其做任何限定。

综上，通过上述编解码流程，可根据不同短信模板编号支持编码生成方法的扩展；实现成本低，无需建立手机号和分库键的映射关系，节省存储空间及手机号变更时的维护成本；系统处理性能高，无需全部分库轮询汇总结果，时效性有保证，且能利用分布式横向扩容方式应对交易量并发量大增的情况；在短信内容中增加短信编码，既能隐藏分库信息同时保持较好的用户体验。

请参考图4所示，本发明还提供一种分布式数据库访问装置，所述装置包含分库信息编码模块、分库信息解码模块和通信模块；所述分库信息编码模块用于获取分布式数据库的分库库号；根据待发送的短信内容的消息类别和所述分库库号生成包含所述分库库号的编码信息；将所述编码信息放置于待发送的短信内容中生成短信数据；所述通信模块用于将所述分库信息编码模块生成的所述短信数据发送至预定接受方；以及，接收客户方提供的短信数据，将短信数据传输至所述分库信息解码模块；所述分库信息解码模块用于根据所述短信数据的消息类别和所述短信数据中的所述编码信息解析获得对应的分库库号；根据所述分库库号进行数据库分库路由访问并执行对应的业务处理。

在本发明一实施例中，所述分库信息编码模块包含：当所述消息类别为邀请类短信时，获取待发送的短信内容所对应的短信模块；根据短信模板和业务数据所在的分库库号通过RSA算法进行加密获得加密数值；根据所述加密数值的字符串及长度信息组装生成编码信息；在另一实施例中，所述分库信息编码模块包含：当所述消息类别为答复类短信时，获取待发送的短信内容所对应的短信模块；根据短信模板和业务数据所在的分库库号通过RSA算法进行加密获得加密数值；根据所述加密数值按二十六进制转换后的英文对组装生成编码信息。

在本发明一实施例中，所述分库信息解码模块包含：根据所述短信数据的消息类别和短信模板获得编码信息，根据所述编码信息按预设组成规则获得加密数值；根据所述加密数值通过RSA算法解密获得分库库号；在另一实施例中，所述分库信息解码模块包含：根据所述短信数据的消息类别和短信模板获得编码信息，根据所述编码信息按二十六进制转换获得加密数值；根据所述加密数值通过RSA算法解密获得分库库号。

具体的，以实际工作中所述分布式数据库访问装置的工作流程为例，对上述实施例做详细说明，本领域相关技术人员当可知，该实施例仅为便于理解本发明所提供的分布式数据库访问装置的一种执行原理及流程，并不对其做任何限定。

1、某银行计划开展信用卡账单分期业务，在客户信用卡生成对账单后，对满足条件的某客户(假设客户信用卡尾号为1234)发送账单分期邀请短信(短信模板1)，客户直接转发该短信到银行官方电话号码，银行给客户发送账单分期方案(短信模板2)，客户再根据方案提示选择期数编辑短信回复给银行官方电话号码，以办理账单分期。

模板1(账单分期邀请短信模板)：

账单分期：您可为尾号****的信用卡本期账单(*月*日-*月*日)办理账单分期，*月*日前转发此短信至XXXXX即可申请。回复TDXS#HZFQ可退订该短信。(XX银行)

模板2(短信账单分期方案模板)：

您尾号为****的信用卡*月账单可账单分期金额*元，短信回复指定交易代码到XXXXX即可快速办理。

分6期(6个月)请发送“ZDFQ#6#1234”，手续费共计*元；

分12期(12个月)请发送“ZDFQ#12#1234”，手续费共计*元；

分24期(24个月)请发送“ZDFQ#24#1234”，手续费共计*元；

(XX银行)

假设该银行分布式数据库分为64个分库，该客户数据归属在第53个分库，使用本发明实现业务，具体实现步骤描述如下：

1)在营销类短信模板中增加分库编码信息：

短信模板1改为：

账单分期：您可为尾号****的信用卡本期账单(*月*日-*月*日)办理账单分期，*月*日前转发此短信至XXXXX即可申请。回复TDXS#HZFQ可退订该短信。短信编号(******)(XX银行)

短信模板2改为：

您尾号为****的信用卡*月账单可账单分期金额*元，短信回复指定交易代码到XXXXX即可快速办理。

分6期(6个月)请发送“ZDFQ#**#6#1234”，手续费共计*元；

分12期(12个月)请发送“ZDFQ#**#12#1234”，手续费共计*元；

分24期(24个月)请发送“ZDFQ#**#24#1234”，手续费共计*元；

(XX银行)

2)分库信息编码模块设计：

RSA算法设计，取质数P和Q，M＝P*Q，N＝(P-1)*(Q-1)，取与N互质的整数E，取整数D，使得E*D mod N＝1。E为加密公钥，D为私钥，则加密后编号i＝k

考虑到保证用户体验，对于邀请类短信短信编号X设定为6位，由I组装而成，设定组装规则为I的3位数字分别对应X的第2、4、6位，第1、3、5位由随机数字补充。系统运算后生成X为605972。

3)装置发送短信：

通过分库信息编码解析模块生成分库号编码信息，并发送给客户。短信内容为：

账单分期：您可为尾号1234的信用卡本期账单(*月*日-*月*日)办理账单分期，*月*日前转发此短信至XXXXX即可申请。回复TDXS#HZFQ可退订该短信。短信编号(605972)(XX银行)

4)客户转发短信至银行官方号码后，系统接收到短信：

调用分库信息编码解析模块从短信的分库编码信息中解析获取分库序号，并进行数据库分库路由访问并生成账单分期的方案。从短信内容中获取短信编号X＝605972，按组装规则得到I＝092，i＝92。解析模块根据公示k＝X

调用分库信息编码模块重新生成分库号编码信息i＝92，按26进制转换为英文字符则Y＝IB，放置到短信内容中并发送给客户。

短信内容为：

您尾号为1234的信用卡*月账单可账单分期金额*元，短信回复指定交易代码到XXXXX即可快速办理。

分6期(6个月)请发送“ZDFQ#IB#6#1234”，手续费共计*元；

分12期(12个月)请发送“ZDFQ#IB#12#1234”，手续费共计*元；

分24期(24个月)请发送“ZDFQ#IB#24#1234”，手续费共计*元；

(XX银行)

5)客户接收到短信,选择对应期数并编辑短信发送至银行官方号码：

调用分库信息编码解析模块从短信的分库编码信息中解析获取分库序号，并进行数据库分库路由访问并完成最终账单分期业务处理。从短信内容中获取短信编号Y＝IB，按转换规则得到I＝092，i＝92。解析模块根据公示k＝X

由此，本发明所提供的分布式数据库访问装置采用了分库信息编码生成模块和解析模块分别进行分库号的编码和解码，并根据不同的短信类型进行适应业务场景的编码解码扩展功能；不仅实现成本低，无需建立手机号和分库键的映射关系，节省存储空间及手机号变更时的维护成本，而且系统处理性能高，无需全部分库轮询汇总结果，时效性有保证，且能利用分布式横向扩容方式应对交易量并发量大增的情况；同时，在短信内容中增加短信编码，既能隐藏分库信息同时保持较好的用户体验。

本发明还提供一种电子设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现上述方法。

本发明还提供一种计算机可读存储介质，所述计算机可读存储介质存储有执行上述方法的计算机程序。

如图5所示，该电子设备600还可以包括：通信模块110、输入单元120、音频处理单元130、显示器160、电源170。值得注意的是，电子设备600也并不是必须要包括图5中所示的所有部件；此外，电子设备600还可以包括图5中没有示出的部件，可以参考现有技术。

如图5所示，中央处理器100有时也称为控制器或操作控件，可以包括微处理器或其他处理器装置和/或逻辑装置，该中央处理器100接收输入并控制电子设备600的各个部件的操作。

其中，存储器140，例如可以是缓存器、闪存、硬驱、可移动介质、易失性存储器、非易失性存储器或其它合适装置中的一种或更多种。可储存上述与失败有关的信息，此外还可存储执行有关信息的程序。并且中央处理器100可执行该存储器140存储的该程序，以实现信息存储或处理等。

输入单元120向中央处理器100提供输入。该输入单元120例如为按键或触摸输入装置。电源170用于向电子设备600提供电力。显示器160用于进行图像和文字等显示对象的显示。该显示器例如可为LCD显示器，但并不限于此。

该存储器140可以是固态存储器，例如，只读存储器(ROM)、随机存取存储器(RAM)、SIM卡等。还可以是这样的存储器，其即使在断电时也保存信息，可被选择性地擦除且设有更多数据，该存储器的示例有时被称为EPROM等。存储器140还可以是某种其它类型的装置。存储器140包括缓冲存储器141(有时被称为缓冲器)。存储器140可以包括应用/功能存储部142，该应用/功能存储部142用于存储应用程序和功能程序或用于通过中央处理器100执行电子设备600的操作的流程。

存储器140还可以包括数据存储部143，该数据存储部143用于存储数据，例如联系人、数字数据、图片、声音和/或任何其他由电子设备使用的数据。存储器140的驱动程序存储部144可以包括电子设备的用于通信功能和/或用于执行电子设备的其他功能(如消息传送应用、通讯录应用等)的各种驱动程序。

通信模块110即为经由天线111发送和接收信号的发送机/接收机110。通信模块(发送机/接收机)110耦合到中央处理器100，以提供输入信号和接收输出信号，这可以和常规移动通信终端的情况相同。

基于不同的通信技术，在同一电子设备中，可以设置有多个通信模块110，如蜂窝网络模块、蓝牙模块和/或无线局域网模块等。通信模块(发送机/接收机)110还经由音频处理器130耦合到扬声器131和麦克风132，以经由扬声器131提供音频输出，并接收来自麦克风132的音频输入，从而实现通常的电信功能。音频处理器130可以包括任何合适的缓冲器、解码器、放大器等。另外，音频处理器130还耦合到中央处理器100，从而使得可以通过麦克风132能够在本机上录音，且使得可以通过扬声器131来播放本机上存储的声音。

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

本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。

以上所述的具体实施例，对本发明的目的、技术方案和有益效果进行了进一步详细说明，所应理解的是，以上所述仅为本发明的具体实施例而已，并不用于限定本发明的保护范围，凡在本发明的精神和原则之内，所做的任何修改、等同替换、改进等，均应包含在本发明的保护范围之内。