Spring Cloud Nacos 2021使用LoadBalancer做负载均衡

package com.cd.loadbalancer; import com.alibaba.cloud.nacos.NacosDiscoveryProperties; import com.alibaba.nacos.api.annotation.NacosProperties; import com.alibaba.nacos.common.utils.ConvertUtils; import com.alibaba.nacos.common.utils.StringUtils; import org.springframework.beans.factory.ObjectProvider; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.loadbalancer.EmptyResponse; import org.springframework.cloud.client.loadbalancer.Request; import org.springframework.cloud.client.loadbalancer.Response; import org.springframework.cloud.loadbalancer.core.NoopServiceInstanceListSupplier; import org.springframework.cloud.loadbalancer.core.ReactorServiceInstanceLoadBalancer; import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier; import reactor.core.publisher.Mono; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; // 自定义权重负载均衡策略，参考RoundRobinLoadBalancer、RandomLoadBalancer、NacosLoadBalancer负载均衡策略来实现 public class WeightLoadBalancer{ } //public class WeightLoadBalancer implements ReactorServiceInstanceLoadBalancer { // // // 注入当前服务的nacos的配置信息 // @Autowired // private NacosDiscoveryProperties nacosDiscoveryProperties; // // // loadbalancer 提供的访问当前服务的名称 // private final String serviceId; // // // loadbalancer 提供的访问的服务列表 // private ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider; // // // public WeightLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider, // String serviceId) { // this.serviceId = serviceId; // this.serviceInstanceListSupplierProvider = serviceInstanceListSupplierProvider; // } // // @Override // public Mono<Response<ServiceInstance>> choose(Request request) { // // 获取服务实例列表 // ServiceInstanceListSupplier supplier = // serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new); // // // return supplier.get(request) // .next() // .map(this::weight); // } // // // private Response<ServiceInstance> weight(List<ServiceInstance> serviceInstances) { // // 服务实例列表为空 // if (serviceInstances.isEmpty()) { // System.out.println("No servers available for service: " + serviceId); // return new EmptyResponse(); // } // // String clusterName = nacosDiscoveryProperties.getClusterName(); // System.out.println("clusterName -> " + clusterName); // List<ServiceInstance> serviceInstanceList = serviceInstances.stream() // .filter(serviceInstance -> StringUtils.equals(serviceInstance.getMetadata().get("nacos.cluster"), clusterName)) // .collect(Collectors.toList()); // // // getHostByRandomWeight(serviceInstanceList); // // // // // // for(ServiceInstance instance : serviceInstances){ // String weight = instance.getMetadata().get("nacos.weight"); // int w = ConvertUtils.toInt(weight); // // } // // // } // // private ServiceInstance getHostByRandomWeight(List<ServiceInstance> serviceInstanceList) { // // // // // } //}