流量切换方法、装置及服务器、存储介质与流程

未命名 09-01 阅读:110 评论:0


1.本技术涉及不同数据系统之间的流量切换技术,尤其涉及一种流量切换方法、装置及服务器、存储介质。


背景技术:

2.随着业务请求量和交易数据量的日益增加,银行倾向于使用分布式架构系统来处理业务和存储交易数据。但是分布式架构系统存在一些无法修复的缺点,例如在容灾方面,分布式架构系统在面临区域性故障时会产生更大的故障爆炸半径且无法灵活应急切换,以及无法灵活适应异地数据中心的部署需求。例如在容量方面,分布式架构系统中的服务器资源虽然可以随用户量和业务量的增长而横向扩展,但数据库连接数、服务提供方的连接数都会逐渐逼近上限,从而导致系统容量不足。
3.鉴于以上缺点,目前研发出单元化架构系统来改造原始的分布式架构系统。单元化架构系统可以实现单元内的亲和性部署,大幅降低不必要的跨单元访问,有效控制故障爆炸半径,提升切换的灵活性,更好地适应未来数据中心的多地和多中心的部署需求。除此之外,通过单元的划分和单元流量的管控,还可以保障数据库的连接数和服务提供方的连接数不会逼近上限,从而支持容量进行横向的灵活扩展。基于此,目前在进行业务处理时,需要实现分布式架构系统向单元化架构系统切流。
4.但是,如果分布式架构系统向单元化架构系统切流的过程中出现了突发状况而无法及时回流,就可能导致切流失败。切流失败不仅会影响单元化架构系统的运行,还会影响原始的分布式架构系统的正常运行。因此,如何制定完备的切流方案以应对可能发生的各种状态,从而提高切流的安全性和系统运行的稳定性,仍然是需要解决的。


技术实现要素:

5.本技术提供一种流量切换方法、装置及服务器、存储介质,用以解决如何制定完备的切流方案以应对可能发生的各种状态,从而提高切流的安全性和系统运行的稳定性的问题。
6.一方面,本技术提供一种流量切换方法,应用于单元化架构系统,所述单元化架构系统包括渠道单元、分区单元和公共单元;所述方法包括:
7.基于所述渠道单元,接收从分布式架构系统中调用的流量,并基于调用的流量验证所述渠道单元的流量回切功能和流量接入功能;
8.当所述渠道单元的流量回切功能和流量接入功能均验证通过时,从所述公共单元调用业务数据,并基于调用的业务数据和所述渠道单元发送的业务处理请求,验证所述分区单元的流量回切功能和数据处理功能;
9.当所述分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至所述单元化架构系统中。
10.其中一个实施例中,所述渠道单元包括处理层和多个负载均衡节点;所述基于调
用的流量验证所述渠道单元的流量回切功能和流量接入功能包括:
11.当所述调用的流量不支持切流,且确定每个所述负载均衡节点均能够将所述调用的流量回切至所述分布式架构系统时,确定所述渠道单元的流量回切功能验证通过;
12.当所述调用的流量支持切流,且确定所述接入层能够成功接入任意一个所述负载均衡节点基于所述调用的流量生成并发送的所述业务处理请求时,确定所述渠道单元的流量接入功能验证通过。
13.其中一个实施例中,每个所述负载均衡节点接收的所述调用的流量为所述分布式架构系统中全部流量中预设比例的流量;
14.多个所述负载均衡节点接收的总流量,等于所述分布式架构系统中全部流量。
15.其中一个实施例中,所述公共单元包括第一结构化数据库,所述方法还包括:
16.通过所述第一结构化数据库,查询所述调用的流量是否具有切流标识;
17.当所述调用的流量不具有切流标识时,确定所述调用的流量不支持切流。
18.其中一个实施例中,所述将分布式架构系统中的全部流量切换至所述单元化架构系统中时,所述第一结构化数据库用于存储所述分布式架构系统中的全部流量对应的业务数据。
19.其中一个实施例中,所述分区单元包括处理层和第二结构化数据库,所述调用的业务数据包括需要回切的第一业务数据和需要处理的第二业务数据;
20.所述基于调用的业务数据和所述渠道单元发送的业务处理请求,验证所述分区单元的流量回切功能和数据处理功能包括:
21.基于所述处理层接收所述第一业务数据,并在确认所述处理层能够将所述第一业务数据回切至所述分布式架构系统中时,确认所述分区单元的流量回切功能验证通过;
22.基于所述处理层接收所述第二业务数据和所述业务处理请求,并在确认所述处理层能够响应所述业务处理请求后处理所述第二业务数据,且能够将处理结果数据发送至所述第二结构化数据库中进行存储时,确认所述分区单元的数据处理功能验证通过。
23.其中一个实施例中,所述第二结构化数据库和所述分布式架构系统中的数据库之间维持协议实时同步。
24.其中一个实施例中,所述分布式架构系统中设置有存量负载均衡节点,所述分布式架构系统中的流量通过所述存量负载均衡节点切换至所述单元化架构系统中。
25.其中一个实施例中,所述单元化架构系统还包括监控节点、统计节点和报警节点,所述方法还包括:
26.当基于所述监控节点监控到所述渠道单元接入流量时出现异常时,基于所述统计节点记录所述渠道单元接入流量时的第一异常数据;
27.当基于所述监控节点监控到所述分区单元处理流量对应的业务数据时出现异常时,基于所述统计节点记录所述分区单元处理流量对应的业务数据时的第二异常数据;
28.当基于所述监控节点监控到所述公共单元存储业务数据时出现异常时,基于所述统计节点记录所述公共单元存储业务数据时的第三异常数据;
29.当所述统计节点记录到所述第一异常数据,或所述第二异常数据,或所述第三异常数据时,基于所述报警节点告警。
30.另一方面,本技术提供一种单元化架构系统,所述单元化架构系统包括渠道单元、
分区单元和公共单元,还包括:
31.第一验证模块,用于接收从分布式架构系统中调用的流量,并基于调用的流量验证所述渠道单元的流量回切功能和流量接入功能;
32.第二验证模块,用于当所述渠道单元的流量回切功能和流量接入功能均验证通过时,从所述公共单元调用业务数据,并基于调用的业务数据和所述渠道单元发送的业务处理请求,验证所述分区单元的流量回切功能和数据处理功能;
33.流量切换模块,用于当所述分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至所述单元化架构系统中。
34.另一方面,本技术提供一种服务器,包括:处理器,以及与所述处理器通信连接的存储器;
35.所述存储器存储计算机执行指令;
36.所述处理器执行所述存储器存储的计算机执行指令,以实现如第一方面所述的流量切换方法。
37.另一方面,本技术提供一种计算机可读存储介质,所述计算机可读存储介质中存储有计算机执行指令,当所述指令被执行时,使得计算机执行如第一方面所述的流量切换方法。
38.另一方面,本技术提供一种计算机程序产品,包括计算机程序,所述计算机程序被处理器执行时实现如第一方面所述的流量切换方法。
39.综上,本技术的实施例提供的流量切换方法,应用于单元化架构系统,该单元化架构系统包括渠道单元、分区单元和公共单元,该渠道单元用于接入流量,该分区单元用于处理流量对应的业务数据,该公共单元用于存储业务数据。该流量切换方法包括:基于该渠道单元,接收从分布式架构系统中调用的流量,并基于调用的流量验证该渠道单元的流量回切功能和流量接入功能;当该渠道单元的流量回切功能和流量接入功能均验证通过时,从该公共单元调用业务数据,并基于调用的业务数据和该渠道单元发送的业务处理请求,验证该分区单元的流量回切功能和数据处理功能;当该分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至该单元化架构系统中。
40.即,在进行切流之前,提前验证单元化架构系统的回流功能和正常业务处理能力,只有在回流功能通过验证时才执行切流过程。如此,如果分布式架构系统向单元化架构系统切流的过程中出现了突发状况,可以及时回流到分布式架构系统,避免影响原始的分布式架构系统的正常运行,提高切流的安全性和系统运行的稳定性。
附图说明
41.此处的附图被并入说明书中并构成本说明书的一部分,示出了符合本公开的实施例,并与说明书一起用于解释本公开的原理。
42.图1为本技术提供的流量切换方法的一种应用场景示意图;
43.图2为本技术的一个实施例提供的流量切换方法的流程示意图;
44.图3为本技术的一个实施例提供的流量切换方法中单元化架构系统和分布式架构系统之间的交互示意图;
45.图4为本技术的另一个实施例提供的流量切换方法中单元化架构系统和分布式架
构系统之间的交互示意图;
46.图5为本技术的一个实施例提供的流量切换装置的示意图;
47.图6为本技术的一个实施例提供的服务器的示意图。
48.通过上述附图,已示出本公开明确的实施例,后文中将有更详细的描述。这些附图和文字描述并不是为了通过任何方式限制本公开构思的范围,而是通过参考特定实施例为本领域技术人员说明本公开的概念。
具体实施方式
49.这里将详细地对示例性实施例进行说明,其示例表示在附图中。下面的描述涉及附图时,除非另有表示,不同附图中的相同数字表示相同或相似的要素。以下示例性实施例中所描述的实施方式并不代表与本公开相一致的所有实施方式。相反,它们仅是与如所附权利要求书中所详述的、本公开的一些方面相一致的装置和方法的例子。
50.在本技术的描述中,需要理解的是,术语“第一”、“第二”仅用于描述目的,而不能理解为指示或暗示相对重要性或者隐含指明所指示的技术特征的数量。由此,限定有“第一”、“第二”的特征可以明示或者隐含地包括一个或者更多个该特征。在本技术的描述中,“多个”的含义是两个或两个以上,除非另有明确具体的限定。
51.首先对本技术涉及到的名词进行解释:
52.单元:一个能满足重要对客业务的关键操作(包括完整事务处理)的自包含集合,在这个集合中包含了重要对客业务所需的大部分关键服务,以及分配给这个单元的数据。
53.单元化架构:把单元作为部署的基本单位,单元内部署了重要对客业务所需的大部分关键应用(或服务群组)。
54.vzone:即渠道单元,是逻辑单元的一种,部署在位于渠道入口的重要对客业务关键应用(或服务群组)。该对客业务关键应用或服务群组本身不参与业务逻辑的事务处理,只作为渠道业务指令的发起方。
55.rzone:即分区单元,是逻辑单元的一种,可根据数据中心的实际情况部署多个。分区单元部署位于渠道下游,按照用户维度(或在业务链路上统一的其他特征维度)进行拆分,或部署在各单元内对等部署的重要对客业务关键应用(或服务群组),不同分片的数据由不同单元内的服务节点处理。
56.gzone:即公共单元,是逻辑单元的一种,部署位于渠道下游,非重要对客业务关键应用(或服务群组),提供不可拆分的数据和服务,这些数据或服务可能会被rzone或vzone依赖。
57.负载均衡节点:server loader balancer,简称slb。slb是将访问流量根据转发策略分发到后台多台云服务器(ecs实例)的流量分发控制服务,来实现多台服务器提供相同的业务服务。负载均衡扩展了应用的服务能力,增强了应用的可用性。
58.随着业务请求量和交易数据量的日益增加,银行倾向于使用分布式架构系统来处理业务和存储交易数据。但是分布式架构系统存在一些无法修复的缺点,例如在容灾方面,分布式架构系统在面临区域性故障时会产生更大的故障爆炸半径且无法灵活应急切换,以及无法灵活适应异地数据中心的部署需求。例如在容量方面,分布式架构系统中的服务器资源虽然可以随用户量和业务量的增长而横向扩展,但数据库连接数、服务提供方的连接
数都会逐渐逼近上限,从而导致系统容量不足。
59.鉴于以上缺点,目前研发出单元化架构系统来改造原始的分布式架构系统。单元化架构系统可以实现单元内的亲和性部署,大幅降低不必要的跨单元访问,有效控制故障爆炸半径,提升切换的灵活性,更好地适应未来数据中心的多地多中心部署需求。除此之外,通过单元的划分和单元流量的管控,还可以保障数据库的连接数和服务提供方的连接数不会逼近上限,从而支持容量进行横向的灵活扩展。基于此,目前在进行业务处理时,需要实现分布式架构系统向单元化架构系统切流。但是,如果分布式架构系统向单元化架构系统切流的过程中出现了突发状况而无法及时回流,就可能导致切流失败。切流失败不仅会影响单元化架构系统的运行,还会影响原始的分布式架构系统的正常运行。
60.基于此,本技术提供一种流量切换方法、装置及服务器、存储介质。该流量切换方法应用于单元化架构系统,该单元化架构系统包括渠道单元、分区单元和公共单元。该流量切换方法包括:基于该渠道单元,接收从分布式架构系统中调用的流量,并基于调用的流量验证该渠道单元的流量回切功能和流量接入功能;当该渠道单元的流量回切功能和流量接入功能均验证通过时,从该公共单元调用业务数据,并基于调用的业务数据和该渠道单元发送的业务处理请求,验证该分区单元的流量回切功能和数据处理功能;当该分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至该单元化架构系统中。
61.即,在进行切流之前,提前验证单元化架构系统的回流功能和正常业务处理能力,只有在回流功能通过验证时才执行切流过程。如此,如果分布式架构系统向单元化架构系统切流的过程中出现了突发状况,可以及时回流到分布式架构系统,避免影响原始的分布式架构系统的正常运行,提高切流的安全性和系统运行的稳定性。
62.本技术提供的流量切换方法应用于电子设备,该电子设备例如设置有单元化架构系统的服务器。图1为本技术提供的流量切换方法的应用示意图,该流量切换方法应用于图1所示的单元化架构系统,该单元化架构系统包括渠道单元(vzone)、分区单元(rzone)和公共单元(gzone)。该渠道单元用于接入流量,该分区单元用于处理流量对应的业务数据,该公共单元用于存储业务数据。图1中,该电子设备基于渠道单元(vzone)接收从分布式架构系统中调用的流量,并基于调用的流量验证该渠道单元的流量回切功能和流量接入功能。当该渠道单元的流量回切功能和流量接入功能均验证通过时,从该公共单元调用业务数据,并基于调用的业务数据和该渠道单元发送的业务处理请求,验证该分区单元的流量回切功能和数据处理功能。当该分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至该单元化架构系统中。
63.请参见图2,本技术的一个实施例提供一种流量切换方法,应用于图1所示的单元化架构系统,该单元化架构系统包括渠道单元、分区单元和公共单元。该渠道单元用于接入流量,该分区单元用于处理流量对应的业务数据,该公共单元用于存储业务数据。
64.该流量切换方法包括:
65.s210,基于该渠道单元,接收从分布式架构系统中调用的流量,并基于调用的流量验证该渠道单元的流量回切功能和流量接入功能。
66.请参见图3,该渠道单元包括接入层和多个负载均衡节点slb(图3中仅示例性得示出了一个负载均衡节点),该分布式架构系统中设置有存量负载均衡节点slb。该分布式架
构系统中的流量通过该存量负载均衡节点切换至该单元化架构系统中,具体的,通过如图3所示的网络f5负载均衡,按比例逐步将流量切至渠道单元(vzone)。
67.在一个可选的实施例中,先部署分布式架构系统中的该存量负载均衡节点和该渠道单元的该负载均衡节点,再向网络部门申请专线切流申请。通过网络部门平台将一条专线流量清零(清零的方式可以是将专线流量迁移至其他专线),再通过网络变更,将一台负载均衡节点挂在已经清零流量的专线下,通过网络部门平台逐步将流量切回专线。具体的,通过网络f5负载均衡将部分流量转移到渠道单元的负载均衡节点。
68.在从分布式架构系统调用流量时,可以根据是否携带切流标识确定流量是否支持切流。基于调用的流量验证该渠道单元的流量回切功能和流量接入功能时,利用不支持切流的流量验证该渠道单元的流量回切功能,利用支持切流的流量验证该渠道单元的流量接入功能。
69.即,当该调用的流量不支持切流时,验证该渠道单元中的每个负载均衡节点是否能够将该调用的流量回切至该分布式架构系统。当确定每个该负载均衡节点均能够将该调用的流量回切至该分布式架构系统时,确定该渠道单元的流量回切功能验证通过。
70.当该调用的流量支持切流时,验证该渠道单元中的每个负载均衡节点是否能够成功接入该调用的流量。当确定每个负载均衡节点均能够成功接入该调用的流量,且每个负载均衡节点均能够基于该调用的流量生成业务处理请求时,确定每个负载均衡节点均能够成功接入流量。当确定该接入层能够成功接入任意一个该负载均衡节点基于该调用的流量生成并发送的该业务处理请求时,确定该接入层能够成功接入流量。该接入层将该业务处理请求发送至该分区单元。
71.当确定每个负载均衡节点均能够成功接入流量,且确定该接入层能够成功接入流量时,确定该渠道单元的流量接入功能验证通过。需要说明的是,在验证该渠道单元的流量回切功能时,需要保持该存量负载均衡节点和被验证的负载均衡节点并行。
72.在一个可选的实施例中,如图3所示,该公共单元包括第一结构化数据库(例如mysql),在确认该调用的流量是否具有切流标识时,通过该第一结构化数据库查询该调用的流量是否具有切流标识。具体的,通过协议分片查询该第一结构化数据库,并通过查询到的切流标识确认流量是否支持切流。
73.在一个可选的实施例中,每个该负载均衡节点接收的该调用的流量为该分布式架构系统中全部流量中预设比例的流量。该预设比例可以根据实际需要设置,例如该单元化架构系统包括4个负载均衡节点,该预设比例可以设置为25%。也就是说,以25%流量分别验证每个负载均衡节点的流量回切功能。即,多个该负载均衡节点接收的总流量,等于该分布式架构系统中全部流量,例如4个负载均衡节点接收的总流量等于该分布式架构系统中100%的流量。
74.s220,当该渠道单元的流量回切功能和流量接入功能均验证通过时,从该公共单元调用业务数据,并基于调用的业务数据和该渠道单元发送的业务处理请求,验证该分区单元的流量回切功能和数据处理功能。
75.在一个可选的实施例中,该业务数据指的是预选择的部分客户的业务数据,该部分客户例如银行内的员工。基于该业务数据验证该分区单元的流量回切能力时,需要该业务数据中至少包括能够回切的数据,以基于该能够回切的数据验证该分区单元的流量回切
能力。验证该分区单元的数据处理功能时,需要该业务数据中至少包括不需要回切且需要处理的数据,再基于该渠道单元接收业务处理请求,以处理该不需要回切且需要处理的数据,根据处理结果验证该分区单元的数据处理能力。
76.在一个可选的实施例中,该分区单元包括处理层和第二结构化数据库。该业务数据包括需要回切的第一业务数据和需要处理的第二业务数据。该需要回切的第一业务数据包括没有切流标识和无法处理的第一业务数据,该需要处理的第二业务数据指的是具有切流标识且需要给出处理结果的第二业务数据。在验证该分区单元的流量回切功能时,基于该处理层接收该第一业务数据,并在确认该处理层能够将该第一业务数据回切至该分布式架构系统中时,确认该分区单元的流量回切功能验证通过。在验证该分区单元的数据处理功能时,基于该处理层接收该第二业务数据和该业务处理请求,并在确认该处理层能够响应该业务处理请求后处理该第二业务数据,且能够将处理结果数据发送至该第二结构化数据库中进行存储时,确认该分区单元的数据处理功能验证通过。
77.s230,当该分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至该单元化架构系统中。
78.当该渠道单元的的流量回切功能和流量接入能力均验证通过,且该分区单元的流量回切能力和数据处理功能均验证沟通过时,证明该单元化架构系统具有可以及时回切的能力且可以正常运行。因此,即便在分布式架构系统向单元化架构系统切流的过程中出现了突发状况,也可以及时回流到该分布式架构系统,而不会因为无法及时回流导致切流失败。
79.例如,在验证该渠道单元的流量回切功能时,如果该单元化架构系统出现故障,则通过一键回切流水线以实施网络变更,将切换了的流量回切至该分布式架构系统。
80.所以,当该渠道单元的的流量回切功能和流量接入能力均验证通过,且该分区单元的流量回切能力和数据处理功能均验证沟通过时,将分布式架构系统中的全部流量切换至该单元化架构系统中。将该分布式架构系统中的全部流量切换至该单元化架构系统中时,可以先将该分布式架构系统中的部分流量切换至该单元化架构系统中,在该分布式架构系统中保留一些数据用于处理业务需求。即,令该分布式架构系统和该单元化架构系统保持并行一段时间后再下线该分布式架构系统。
81.将分布式架构系统中的全部流量切换至该单元化架构系统中时,该第一结构化数据库用于存储该分布式架构系统中的全部流量对应的业务数据。
82.综上,本实施例提供的流量切换方法,应用于单元化架构系统,该单元化架构系统包括渠道单元、分区单元和公共单元,该渠道单元用于接入流量,该分区单元用于处理流量对应的业务数据,该公共单元用于存储业务数据。该流量切换方法包括:基于该渠道单元,接收从分布式架构系统中调用的流量,并基于调用的流量验证该渠道单元的流量回切功能和流量接入功能;当该渠道单元的流量回切功能和流量接入功能均验证通过时,从该公共单元调用业务数据,并基于调用的业务数据和该渠道单元发送的业务处理请求,验证该分区单元的流量回切功能和数据处理功能;当该分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至该单元化架构系统中。
83.即,在进行切流之前,提前验证单元化架构系统的回流功能和正常业务处理能力,只有在回流功能通过验证时才执行切流过程。如此,如果分布式架构系统向单元化架构系
统切流的过程中出现了突发状况,可以及时回流到分布式架构系统,避免影响原始的分布式架构系统的正常运行,提高切流的安全性和系统运行的稳定性。
84.请参见图4,该分布式架构系统还包括数据库(例如oracle数据库),在一个可选的实施例中,该第二结构化数据库和该分布式架构系统中的数据库之间维持协议实时同步。
85.具体的,该第二结构化数据库中的协议发生更新时,与该数据库之间维持协议实时同步,以保持该数据库中的协议也发生更新。例如该第二结构化数据库中新增第一协议时,该数据库中也增加该第一协议。可选的,该第二结构化数据库和该数据之间通过kafka实现协议的实时同步。
86.除此之外,该数据库和该第二结构化数据库之间维持协议日终同步,即该数据库每天上传一次数据库中的所有协议,该第二结构化数据库根据上传的该所有协议更新自身包含的协议,以维持和该数据库中的协议同步。
87.请参见图4,在一个可选的实施例中,在将该分布式架构系统中的流量切换至该单元化架构系统中时,该数据库和该第一结构化数据库之间,以及该数据库和该第二结构化数据库之间,都会进行存量协议的迁移。除此之外,该数据库和该第一结构化数据库之间还会实现客编映射信息的迁移,该客编映射信息可以理解为客户信息,该客户信息包括所有客户自身信息和与客户关联的信息等。
88.在以上实施例提供的流量切换方法中,通过维持该分布式架构系统和单元化架构系统的协议同步,避免了切流引起的协议不同步问题,提高了切流的成功率。
89.在一个可选的实施例中,该单元化架构系统还包括监控节点、统计节点和报警节点,在该单元化架构系统接入流量的过程中,该流量切换方法还会记录异常数据和报警。具体的,当基于该监控节点监控到该渠道单元接入流量时出现异常时,基于该统计节点记录该渠道单元接入流量时的第一异常数据。当基于该监控节点监控到该分区单元处理流量对应的业务数据时出现异常时,基于该统计节点记录该分区单元处理流量对应的业务数据时的第二异常数据。当基于该监控节点监控到该公共单元存储业务数据时出现异常时,基于该统计节点记录该公共单元存储业务数据时的第三异常数据。当该统计节点记录到该第一异常数据,或该第二异常数据,或该第三异常数据时,基于该报警节点告警。
90.即,在验证该单元化架构系统的回流能力和业务处理能力时,及时记录出现的异常数据以及及时报警,使得工作人员可以根据出现的异常数据改善、提升该单元化架构系统的回流能力和业务处理能力。
91.请参见图5,本技术的一个实施例还提供一种单元化架构系统10,该单元化架构系统10包括渠道单元、分区单元和公共单元,还包括:
92.第一验证模块11,用于接收从分布式架构系统中调用的流量,并基于调用的流量验证该渠道单元的流量回切功能和流量接入功能。
93.第二验证模块12,用于当该渠道单元的流量回切功能和流量接入功能均验证通过时,从该公共单元调用业务数据,并基于调用的业务数据和该渠道单元发送的业务处理请求,验证该分区单元的流量回切功能和数据处理功能。
94.流量切换模块13,用于当该分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至该单元化架构系统中。
95.该渠道单元包括处理层和多个负载均衡节点,该第一验证模块11具体用于:当该
调用的流量不支持切流,且确定每个该负载均衡节点均能够将该调用的流量回切至该分布式架构系统时,确定该渠道单元的流量回切功能验证通过;当该调用的流量支持切流,且确定该接入层能够成功接入任意一个该负载均衡节点基于该调用的流量生成并发送的该业务处理请求时,确定该渠道单元的流量接入功能验证通过。每个该负载均衡节点接收的该调用的流量为该分布式架构系统中全部流量中预设比例的流量;多个该负载均衡节点接收的总流量,等于该分布式架构系统中全部流量。
96.该公共单元包括第一结构化数据库,该第一验证模块11具体用于通过该第一结构化数据库,查询该调用的流量是否具有切流标识;当该调用的流量不具有切流标识时,确定该调用的流量不支持切流。该将分布式架构系统中的全部流量切换至该单元化架构系统中时,该第一结构化数据库用于存储该分布式架构系统中的全部流量对应的业务数据。
97.该分区单元包括处理层和第二结构化数据库,该调用的业务数据包括需要回切的第一业务数据和需要处理的第二业务数据。该第二验证模块12具体用于:基于该处理层接收该第一业务数据,并在确认该处理层能够将该第一业务数据回切至该分布式架构系统中时,确认该分区单元的流量回切功能验证通过;基于该处理层接收该第二业务数据和该业务处理请求,并在确认该处理层能够响应该业务处理请求后处理该第二业务数据,且能够将处理结果数据发送至该第二结构化数据库中进行存储时,确认该分区单元的数据处理功能验证通过。
98.该第二结构化数据库和该分布式架构系统中的数据库之间维持协议实时同步。
99.该分布式架构系统中设置有存量负载均衡节点,该分布式架构系统中的流量通过该存量负载均衡节点切换至该单元化架构系统中。
100.该单元化架构系统还包括监控节点、统计节点和报警节点,该流量切换装置10还包括监控模块14,该监控模块14用于当基于该监控节点监控到该渠道单元接入流量时出现异常时,基于该统计节点记录该渠道单元接入流量时的第一异常数据;当基于该监控节点监控到该分区单元处理流量对应的业务数据时出现异常时,基于该统计节点记录该分区单元处理流量对应的业务数据时的第二异常数据。当基于该监控节点监控到该公共单元存储业务数据时出现异常时,基于该统计节点记录该公共单元存储业务数据时的第三异常数据;当该统计节点记录到该第一异常数据,或该第二异常数据,或该第三异常数据时,基于该报警节点告警。
101.请参见图6,本技术的一个实施例还提供一种服务器20,包括处理器21,以及与该处理器21通信连接的存储器22。该存储器22存储计算机执行指令,该处理器21执行该存储器22存储的计算机执行指令,以实现如以上任一项实施例提供的流量切换方法。
102.本技术还提供一种计算机可读存储介质,该计算机可读存储介质中存储有计算机执行指令,当该指令被执行时,使得计算机执行指令被处理器执行时用于实现如上任一项实施例提供的该流量切换方法。
103.本技术还提供一种计算机程序产品,包括计算机程序,被计算机程序被处理器执行时用于实现如上任一项实施例提供的该流量切换方法。
104.需要说明的是,上述计算机可读存储介质可以是只读存储器(read only memory,rom)、可编程只读存储器(programmable read-only memory,prom)、可擦除可编程只读存储器(erasable programmable read-only memory,eprom)、电可擦除可编程只读存储器
(electrically erasable programmable read-only memory,eeprom)、磁性随机存取存储器(ferromagnetic random access memory,fram)、快闪存储器(flash memory)、磁表面存储器、光盘、或只读光盘(compact disc read-only memory,cd-rom)等存储器。也可以是包括上述存储器之一或任意组合的各种电子设备,如移动电话、计算机、平板设备、个人数字助理等。
105.需要说明的是,在本文中,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者装置不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者装置所固有的要素。在没有更多限制的情况下,由语句“包括一个
……”
限定的要素,并不排除在包括该要素的过程、方法、物品或者装置中还存在另外的相同要素。
106.上述本技术实施例序号仅仅为了描述,不代表实施例的优劣。
107.通过以上的实施方式的描述,本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现,当然也可以通过硬件,但很多情况下前者是更佳的实施方式。基于这样的理解,本技术的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质(如rom/ram、磁碟、光盘)中,包括若干指令用以使得一台终端设备(可以是手机,计算机,服务器,空调器,或者网络设备等)执行本技术各个实施例所描述的方法。
108.本技术是参照根据本技术实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
109.这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
110.这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
111.以上仅为本技术的优选实施例,并非因此限制本技术的专利范围,凡是利用本技术说明书及附图内容所作的等效结构或等效流程变换,或直接或间接运用在其他相关的技术领域,均同理包括在本技术的专利保护范围内。

技术特征:
1.一种流量切换方法,其特征在于,应用于单元化架构系统,所述单元化架构系统包括渠道单元、分区单元和公共单元;所述方法包括:基于所述渠道单元,接收从分布式架构系统中调用的流量,并基于调用的流量验证所述渠道单元的流量回切功能和流量接入功能;当所述渠道单元的流量回切功能和流量接入功能均验证通过时,从所述公共单元调用业务数据,并基于调用的业务数据和所述渠道单元发送的业务处理请求,验证所述分区单元的流量回切功能和数据处理功能;当所述分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至所述单元化架构系统中。2.根据权利要求1所述的方法,其特征在于,所述渠道单元包括处理层和多个负载均衡节点;所述基于调用的流量验证所述渠道单元的流量回切功能和流量接入功能包括:当所述调用的流量不支持切流,且确定每个所述负载均衡节点均能够将所述调用的流量回切至所述分布式架构系统时,确定所述渠道单元的流量回切功能验证通过;当所述调用的流量支持切流,且确定所述接入层能够成功接入任意一个所述负载均衡节点基于所述调用的流量生成并发送的所述业务处理请求时,确定所述渠道单元的流量接入功能验证通过。3.根据权利要求2所述的方法,其特征在于,每个所述负载均衡节点接收的所述调用的流量为所述分布式架构系统中全部流量中预设比例的流量;多个所述负载均衡节点接收的总流量,等于所述分布式架构系统中全部流量。4.根据权利要求2所述的方法,其特征在于,所述公共单元包括第一结构化数据库,所述方法还包括:通过所述第一结构化数据库,查询所述调用的流量是否具有切流标识;当所述调用的流量不具有切流标识时,确定所述调用的流量不支持切流。5.根据权利要求4所述的方法,其特征在于,所述将分布式架构系统中的全部流量切换至所述单元化架构系统中时,所述第一结构化数据库用于存储所述分布式架构系统中的全部流量对应的业务数据。6.根据权利要求1至5任一项所述的方法,其特征在于,所述分区单元包括处理层和第二结构化数据库,所述调用的业务数据包括需要回切的第一业务数据和需要处理的第二业务数据;所述基于调用的业务数据和所述渠道单元发送的业务处理请求,验证所述分区单元的流量回切功能和数据处理功能包括:基于所述处理层接收所述第一业务数据,并在确认所述处理层能够将所述第一业务数据回切至所述分布式架构系统中时,确认所述分区单元的流量回切功能验证通过;基于所述处理层接收所述第二业务数据和所述业务处理请求,并在确认所述处理层能够响应所述业务处理请求后处理所述第二业务数据,且能够将处理结果数据发送至所述第二结构化数据库中进行存储时,确认所述分区单元的数据处理功能验证通过。7.根据权利要求6所述的方法,其特征在于,所述第二结构化数据库和所述分布式架构系统中的数据库之间维持协议实时同步。8.根据权利要求1所述的方法,其特征在于,所述分布式架构系统中设置有存量负载均
衡节点,所述分布式架构系统中的流量通过所述存量负载均衡节点切换至所述单元化架构系统中。9.根据权利要求1所述的方法,其特征在于,所述单元化架构系统还包括监控节点、统计节点和报警节点,所述方法还包括:当基于所述监控节点监控到所述渠道单元接入流量时出现异常时,基于所述统计节点记录所述渠道单元接入流量时的第一异常数据;当基于所述监控节点监控到所述分区单元处理流量对应的业务数据时出现异常时,基于所述统计节点记录所述分区单元处理流量对应的业务数据时的第二异常数据;当基于所述监控节点监控到所述公共单元存储业务数据时出现异常时,基于所述统计节点记录所述公共单元存储业务数据时的第三异常数据;当所述统计节点记录到所述第一异常数据,或所述第二异常数据,或所述第三异常数据时,基于所述报警节点告警。10.一种单元化架构系统,其特征在于,所述单元化架构系统包括渠道单元、分区单元和公共单元,还包括:第一验证模块,用于接收从分布式架构系统中调用的流量,并基于调用的流量验证所述渠道单元的流量回切功能和流量接入功能;第二验证模块,用于当所述渠道单元的流量回切功能和流量接入功能均验证通过时,从所述公共单元调用业务数据,并基于调用的业务数据和所述渠道单元发送的业务处理请求,验证所述分区单元的流量回切功能和数据处理功能;流量切换模块,用于当所述分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至所述单元化架构系统中。11.一种服务器,其特征在于,包括:处理器,以及与所述处理器通信连接的存储器;所述存储器存储计算机执行指令;所述处理器执行所述存储器存储的计算机执行指令,以实现如权利要求1至9中任一项所述的流量切换方法。12.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质中存储有计算机执行指令,当所述指令被执行时,使得计算机执行如权利要求1-9中任一项所述的流量切换方法。

技术总结
本申请提供一种流量切换方法、装置及服务器、存储介质。该方法应用于单元化架构系统,单元化架构系统包括渠道单元、分区单元和公共单元。该方法包括:基于渠道单元,接收从分布式架构系统中调用的流量,并基于调用的流量验证渠道单元的流量回切功能和流量接入功能;当渠道单元的流量回切功能和流量接入功能均验证通过时,从公共单元调用业务数据,并基于调用的业务数据和渠道单元发送的业务处理请求,验证分区单元的流量回切功能和数据处理功能;当分区单元的流量回切功能和数据处理功能均验证通过时,将分布式架构系统中的全部流量切换至单元化架构系统中。本申请的方法可以解决如何提高切流的安全性和系统运行的稳定性的问题。提高切流的安全性和系统运行的稳定性的问题。提高切流的安全性和系统运行的稳定性的问题。


技术研发人员:蒋双双
受保护的技术使用者:中国工商银行股份有限公司
技术研发日:2023.05.24
技术公布日:2023/8/24
版权声明

本文仅代表作者观点,不代表航家之家立场。
本文系作者授权航家号发表,未经原创作者书面授权,任何单位或个人不得引用、复制、转载、摘编、链接或以其他任何方式复制发表。任何单位或个人在获得书面授权使用航空之家内容时,须注明作者及来源 “航空之家”。如非法使用航空之家的部分或全部内容的,航空之家将依法追究其法律责任。(航空之家官方QQ:2926969996)

航空之家 https://www.aerohome.com.cn/

飞机超市 https://mall.aerohome.com.cn/

航空资讯 https://news.aerohome.com.cn/

分享:

扫一扫在手机阅读、分享本文

相关推荐