# 《RPC手撸专栏》第56章:基于SPI扩展最少连接数负载均衡策略

作者:冰河
星球:http://m6z.cn/6aeFbs (opens new window)
博客:https://binghe.gitcode.host (opens new window)
文章汇总:https://binghe.gitcode.host/md/all/all.html (opens new window)

沉淀,成长,突破,帮助他人,成就自我。

大家好,我是冰河~~

在前面的章节中,我们基于SPI扩展了JDK、Json、Hessian2、FST、Kryo和Protostuff序列化与反序列化机制,在服务消费者端基于SPI扩展了JDK、CGLib、Javassist、ByteBuddy和ASM动态代理机制。在服务提供者端,基于SPI扩展了JDK、CGLib、Javassist、ByteBuddy和ASM反射机制调用真实方法的功能。

# 一、前言

实现增强型负载均衡策略,我们继续肝...

在前面的文章中,我们一起实现了基于SPI扩展随机算法、加权随机算法、轮询算法、加权轮询算法、Hash算法、加权Hash算法、基于源IP地址Hash算法、基于源IP地址加权Hash算法和基于Zookeeper的一致性Hash算法负载均衡策略,服务消费者可以根据这些算法实现的负载均衡策略,从多个服务提供者中选择一个,与其进行连接从而实现数据交互。

在增强型负载均衡策略中,我们一起实现了基于SPI扩展增强型加权随机算法、增强型加权轮询算法、增强型加权Hash算法、增强型权源IP地址Hash算法和增强型Zookeeper一致性Hash算法负载均衡策略,本章,我们继续往下肝,小伙伴们别掉队,一起加油!

# 二、目标

目标很明确:基于SPI扩展最少连接数负载均衡策略!

最少连接数负载均衡策略最核心的实现逻辑就是:从服务元数据列表中找出连接数最少的服务元数据并返回。具体的实现方式就是:当服务消费者与服务提供者建立连接时,会将服务元数据与连接数的对应关系保存到连接的上下文中。当服务消费者从注册中心获取到服务提供者的元数据列表时,首先从服务提供者元数据列表中获取没有连接过的元数据信息,如果没有获取到元数据信息,则从服务提供者列表中获取连接数最少的元数据信息。

这一章,我们就一起手撸实现基于SPI扩展最少连接数算法负载均衡策略。

# 三、设计

如果让你设计基于SPI扩展最少连接数算法的负载均衡策略,你会怎么设计呢?

基于SPI扩展最少连接数算法的负载均衡策略的流程如图56-1所示。

图56-1

由图56-1可以看出如下信息:

(1)服务提供者会通过自定义类扫描器整合注册中心,将服务注册到注册中心。

(2)服务注册到注册中心的元数据,例如服务的名称、服务的版本号、服务地址、服务端口和服务分组等信息,元数据会贯穿整个服务的注册与发现流程。

(3)服务注册与发现接口对外提供服务注册与发现的方法,服务提供者通过自定义扫描器会调用服务注册与发现接口的方法实现服务注册功能。

(4)基于服务注册与发现的接口,服务提供者会实现多个服务注册与发现的实现类,每个实现类对应着一种注册中心服务。

(5)服务消费者会通过服务注册与发现接口订阅注册中心的服务,会从注册中心获取到服务提供者发布的服务信息,实现服务发现的功能。

(7)服务消费者从注册中心获取到服务提供者发布的服务信息后,会基于SPI机制动态加载普通算法(我们将第42章~第50章实现的负载均衡算法统称为普通算法)、基于增强型加权随机算法、基于增强型加权轮询算法、基于增强型加权Hash算法、基于增强型加权源IP地址Hash算法、基于增强型Zookeeper一致性Hash算法和最少连接数算法的负载均衡策略,从多个服务中选择一个进行远程网络连接。

(8)服务消费者会直接与根据基于SPI机制动态加载的负载均衡策略选择出的服务提供者建立连接,实现数据交互。也就是说,后续服务消费者会与服务提供者直接实现数据交互。

# 四、实现

说了这么多,具体要怎么实现呢?

# 核心类实现关系

基于SPI扩展最少连接数算法负载均衡策略的核心类关系如图56-2所示。

图56-2

# 查看完整文章

加入冰河技术 (opens new window)知识星球,解锁完整技术文章与完整代码