一种服务处理方法及装置与流程

    专利2025-03-04  8


    本发明涉及分布式数据处理,具体涉及一种服务处理方法及装置。


    背景技术:

    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中任一项所述方法的步骤。


    技术总结
    本发明提供一种服务处理方法及装置,涉及分布式数据处理技术领域,可用于金融领域或其他技术领域。所述方法包括:在启动服务注册之前接收各Zookeeper客户端分别发送的服务名和参数;根据预配置服务信息,对服务名和对应参数进行整理归纳,得到第一整合序列;从Zookeeper集群中获取连接数最少的Zookeeper服务端作为待推送信息的目标Zookeeper服务端,并向所述目标Zookeeper服务端推送所述第一整合序列。所述装置执行上述方法。本发明实施例提供的服务处理方法及装置,能够降低服务处理过程中的时延,提高系统可用性。

    技术研发人员:饶志岗,李剑,韩越,李翠芳
    受保护的技术使用者:中国工商银行股份有限公司
    技术研发日:
    技术公布日:2024/4/29
    转载请注明原文地址:https://wp.8miu.com/read-83741.html

    最新回复(0)