本发明涉及分布式数据处理,具体涉及一种服务处理方法及装置。
背景技术:
1、随着数字化转型不断深入,云原生理念的推广和普及,金融分布式微服务规模也随之不断扩大,在超大规模微服务高并发场景下,服务节点在重新部署过程中存在注册中心客户端和服务端大量交互,导致服务部署时间非常漫长,并且耗时随着规模增加而成倍增加,降低了系统可用性。
2、如图1所示,在以zookeeper为注册中心的分布式微服务系统中,提供方与消费方均通过zkclient与注册中心服务端zkserver交互从而实现服务的注册和发现。
3、1、提供方启动后将自身的服务信息通过zkclient注册至注册中心服务端zkserver;
4、2、消费者依赖注册中心客户端zkclient从注册中心服务端zkserver订阅服务的提供方信息;
5、3、消费方从注册中心集群服务端获取到提供方信息后,通过rpc协议与提供方建立连接发起调用。
6、在现有技术中,微服务系统提供方和消费方在注册订阅服务时向注册中心服务端zkserver正式注册和订阅服务前,会主动式探寻待注册订阅的微服务的服务名是否存在,在这个过程中,存在注册中心集群zookeeper的同步机制和往返网络时延,在小规模微服务场景中时延较小,但在大规模微超敏应用的微服务场景尤其是金融领域中,时延随着规模的扩增而急剧增加,导致微服务系统对外提供服务需要较长的准备时间,每次更新系统都需要较长等待时间,降低了系统可用性。
技术实现思路
1、针对现有技术中的问题,本发明实施例提供一种服务处理方法及装置,能够至少部分地解决现有技术中存在的问题。
2、一方面,本发明提出一种服务处理方法,包括:
3、在启动服务注册之前接收各zookeeper客户端分别发送的服务名和参数;
4、根据预配置服务信息,对服务名和对应参数进行整理归纳,得到第一整合序列;
5、从zookeeper集群中获取连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端,并向所述目标zookeeper服务端推送所述第一整合序列,以供所述目标zookeeper服务端根据所述第一整合序列和用于服务注册的第一服务名,匹配到待进行服务注册的第一目标服务名和对应第一目标参数,以供待进行服务注册的服务提供方完成服务注册;根据所述第一整合序列和用于服务订阅的第二服务名,匹配到待进行服务订阅的第二目标服务名和对应第二目标参数,以供待进行服务订阅的服务消费方完成服务订阅。
6、其中,所述在启动服务注册之前接收各zookeeper客户端分别发送的服务名和参数,包括:
7、在启动服务注册之前通过服务配置中心接收各zookeeper客户端分别发送的服务名和参数。
8、其中,所述根据预配置服务信息,对服务名和对应参数进行整理归纳,得到第一整合序列,包括:
9、控制所述服务配置中心根据预配置服务信息,对服务名和对应参数进行整理归纳,得到第一整合序列;
10、控制所述服务配置中心将所述第一整合序列发送至推送中心。
11、其中,所述从zookeeper集群中获取连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端,包括:
12、通过所述推送中心检测所述zookeeper集群中各zookeeper服务端分别对应的连接数;
13、通过所述推送中心将连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端。
14、其中,所述向所述目标zookeeper服务端推送所述第一整合序列,包括:
15、通过所述推送中心以批量数据推送方式向所述目标zookeeper服务端推送所述整合序列。
16、其中,所述服务处理方法还包括:
17、在启动服务注册之前接收各zookeeper客户端分别发送的服务名、方法名和参数;
18、根据预配置服务信息,对服务名、对应方法名和对应参数进行整理归纳,得到第二整合序列;
19、从zookeeper集群中获取连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端,并向所述目标zookeeper服务端推送所述第二整合序列,以供所述目标zookeeper服务端根据所述第二整合序列和用于服务注册的第一服务名,匹配到待进行服务注册的第一目标服务名、对应第一目标方法名和对应第一目标参数,以供待进行服务注册的服务提供方完成服务注册;根据所述第二整合序列和用于服务订阅的第二服务名,匹配到待进行服务订阅的第二目标服务名、对应第二目标方法名和对应第二目标参数,以供待进行服务订阅的服务消费方完成服务订阅。
20、其中,所述服务处理方法还包括:
21、在启动服务注册之前通过服务配置中心接收各zookeeper客户端分别发送的服务名、方法名和参数;
22、控制所述服务配置中心根据预配置服务信息,对服务名、对应方法名和对应参数进行整理归纳,得到第二整合序列;控制所述服务配置中心将所述第二整合序列发送至推送中心;
23、通过所述推送中心从zookeeper集群中获取连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端,并向所述目标zookeeper服务端推送所述第二整合序列,以供所述目标zookeeper服务端根据所述第二整合序列和用于服务注册的第一服务名,匹配到待进行服务注册的第一目标服务名、对应第一目标方法名和对应第一目标参数,以供待进行服务注册的服务提供方完成服务注册;根据所述第二整合序列和用于服务订阅的第二服务名,匹配到待进行服务订阅的第二目标服务名、对应第二目标方法名和对应第二目标参数,以供待进行服务订阅的服务消费方完成服务订阅。
24、一方面,本发明提出一种服务处理装置,包括:
25、接收单元,用于在启动服务注册之前接收各zookeeper客户端分别发送的服务名和参数;
26、整理单元,用于根据预配置服务信息,对服务名和对应参数进行整理归纳,得到第一整合序列;
27、处理单元,用于从zookeeper集群中获取连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端,并向所述目标zookeeper服务端推送所述第一整合序列,以供所述目标zookeeper服务端根据所述第一整合序列和用于服务注册的第一服务名,匹配到待进行服务注册的第一目标服务名和对应第一目标参数,以供待进行服务注册的服务提供方完成服务注册;根据所述第一整合序列和用于服务订阅的第二服务名,匹配到待进行服务订阅的第二目标服务名和对应第二目标参数,以供待进行服务订阅的服务消费方完成服务订阅。
28、再一方面,本发明实施例提供一种电子设备,包括:处理器、存储器和总线,其中,
29、所述处理器和所述存储器通过所述总线完成相互间的通信;
30、所述存储器存储有可被所述处理器执行的程序指令,所述处理器调用所述程序指令能够执行如下方法:
31、在启动服务注册之前接收各zookeeper客户端分别发送的服务名和参数;
32、根据预配置服务信息,对服务名和对应参数进行整理归纳,得到第一整合序列;
33、从zookeeper集群中获取连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端,并向所述目标zookeeper服务端推送所述第一整合序列,以供所述目标zookeeper服务端根据所述第一整合序列和用于服务注册的第一服务名,匹配到待进行服务注册的第一目标服务名和对应第一目标参数,以供待进行服务注册的服务提供方完成服务注册;根据所述第一整合序列和用于服务订阅的第二服务名,匹配到待进行服务订阅的第二目标服务名和对应第二目标参数,以供待进行服务订阅的服务消费方完成服务订阅。
34、本发明实施例提供一种非暂态计算机可读存储介质,包括:
35、所述非暂态计算机可读存储介质存储计算机指令,所述计算机指令使所述计算机执行如下方法:
36、在启动服务注册之前接收各zookeeper客户端分别发送的服务名和参数;
37、根据预配置服务信息,对服务名和对应参数进行整理归纳,得到第一整合序列;
38、从zookeeper集群中获取连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端,并向所述目标zookeeper服务端推送所述第一整合序列,以供所述目标zookeeper服务端根据所述第一整合序列和用于服务注册的第一服务名,匹配到待进行服务注册的第一目标服务名和对应第一目标参数,以供待进行服务注册的服务提供方完成服务注册;根据所述第一整合序列和用于服务订阅的第二服务名,匹配到待进行服务订阅的第二目标服务名和对应第二目标参数,以供待进行服务订阅的服务消费方完成服务订阅。
39、本发明实施例提供的服务处理方法及装置,在启动服务注册之前接收各zookeeper客户端分别发送的服务名和参数;根据预配置服务信息,对服务名和对应参数进行整理归纳,得到第一整合序列;从zookeeper集群中获取连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端,并向所述目标zookeeper服务端推送所述第一整合序列,以供所述目标zookeeper服务端根据所述第一整合序列和用于服务注册的第一服务名,匹配到待进行服务注册的第一目标服务名和对应第一目标参数,以供待进行服务注册的服务提供方完成服务注册;根据所述第一整合序列和用于服务订阅的第二服务名,匹配到待进行服务订阅的第二目标服务名和对应第二目标参数,以供待进行服务订阅的服务消费方完成服务订阅,能够降低服务处理过程中的时延,提高系统可用性。
1.一种服务处理方法,其特征在于,包括:
2.根据权利要求1所述的服务处理方法,其特征在于,所述在启动服务注册之前接收各zookeeper客户端分别发送的服务名和参数,包括:
3.根据权利要求2所述的服务处理方法,其特征在于,所述根据预配置服务信息,对服务名和对应参数进行整理归纳,得到第一整合序列,包括:
4.根据权利要求3所述的服务处理方法,其特征在于,所述从zookeeper集群中获取连接数最少的zookeeper服务端作为待推送信息的目标zookeeper服务端,包括:
5.根据权利要求4所述的服务处理方法,其特征在于,所述向所述目标zookeeper服务端推送所述第一整合序列,包括:
6.根据权利要求1至5任一所述的服务处理方法,其特征在于,所述服务处理方法还包括:
7.根据权利要求6所述的服务处理方法,其特征在于,所述服务处理方法还包括:
8.一种服务处理装置,其特征在于,包括:
9.一种电子设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,其特征在于,所述处理器执行所述计算机程序时实现权利要求1至7中任一项所述方法的步骤。
10.一种计算机可读存储介质,其上存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现权利要求1至7中任一项所述方法的步骤。