public class CustomLoadBalancer : ILoadBalancer { private readonly Func<Task<List<Service>>> _services; private readonly object _lock = new object(); private int _last; public CustomLoadBalancer(Func<Task<List<Service>>> services) { _services = services; } public async Task<Response<ServiceHostAndPort>> Lease(HttpContext httpContext) { var services = await _services(); lock (_lock) { if (_last >= services.Count) { _last = 0; } var next = services[_last]; _last++; return new OkResponse<ServiceHostAndPort>(next.HostAndPort); } } public void Release(ServiceHostAndPort hostAndPort) { } }
在Ocelot中注册此类：
Func<IServiceProvider, DownstreamRoute, IServiceDiscoveryProvider, CustomLoadBalancer> loadBalancerFactoryFunc = (serviceProvider, Route, serviceDiscoveryProvider) => new CustomLoadBalancer(serviceDiscoveryProvider.Get); s.AddOcelot().AddCustomLoadBalancer(loadBalancerFactoryFunc);
最后在路由的LoadBalancerOptions配置选项上修改为CustomLoadBalancer自定义负载均衡类名：
"LoadBalancerOptions": { "Type": "CustomLoadBalancer" }
运行项目调试查看结果：
第一次请求时候分发到APIServicesA项目。
第二次请求时候分发到APIServicesB项目。
从上面结果来看，自定义负载均衡成功。
参考文献：
Ocelot官网
到此这篇关于ASP.NET Core3.1 Ocelot负载均衡的实现的文章就介绍到这了,更多相关ASP.NET Core3.1 Ocelot负载均衡内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
您可能感兴趣的文章: