Ribbon集成Nacos实现权重配置(本篇暂未支持spring gateway)

news2024/11/15 23:28:34

1场景：本篇，是师范 ribbon 与nacos 的权重测试，ribbon读取 nacos内权重设置。

在调用端增加配置文件

代码如下：

（1）本次测试nacos 1.4.1；

（2） spring cloud 版本：

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-dependencies</artifactId>

<version>Hoxton.SR1</version>

<scope>import</scope>

（3）ribbon版本：

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-openfeign</artifactId>

<version>2.2.1.RELEASE</version>

package com.pooj.messager.fileHandel.config;


import com.alibaba.cloud.nacos.NacosDiscoveryProperties;
import com.alibaba.cloud.nacos.NacosServiceManager;
import com.alibaba.cloud.nacos.ribbon.NacosServer;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.netflix.client.config.IClientConfig;
import com.netflix.loadbalancer.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.List;

@Slf4j
@Component
public class ArtisanWeightedRule extends AbstractLoadBalancerRule{

    @Resource
    private NacosDiscoveryProperties discoveryProperties;
     @Override
    public void initWithNiwsConfig(IClientConfig iClientConfig) {
        //读取配置文件并且初始化,ribbon内部的, 几乎用不上
    }
    @Autowired
    private NacosServiceManager nacosServiceManager;
    @Override
    public Server choose(Object key) {
        // 1.获取服务的名称
        BaseLoadBalancer loadBalancer = (BaseLoadBalancer) this.getLoadBalancer();
        String serverName = loadBalancer.getName();
        // 2.获取NameService
        NamingService namingService = nacosServiceManager.getNamingService(discoveryProperties.getNacosProperties());
        try {
            //3.此时Nacos Client会自动实现基于权重的负载均衡算法,获取健康实例
            Instance instance = namingService.selectOneHealthyInstance(serverName);
            return new NacosServer(instance);
        } catch (NacosException e) {
            log.error("获取healthy服务失败,原因是:{}", e.getErrMsg(), e);
        }
        return null;

    }
        //本地版本    discoveryProperties.namingServiceInstance() ，这个方法找不到。
        //这里的方法，网上比较通用，预估是版本问题。换成以上版本。
        /*try {
            log.info("key:{}", key);
            BaseLoadBalancer baseLoadBalancer = (BaseLoadBalancer) this.getLoadBalancer();
            log.info("baseLoadBalancer--->:{}", baseLoadBalancer);

            //获取微服务的名称
            String serviceName = baseLoadBalancer.getName();

            //获取Nacos服务发现的相关组件API，网上用这个比较多，但是这个版本内没有这个方法
            NamingService namingService = discoveryProperties.namingServiceInstance();

            //获取 一个基于nacos client 实现权重的负载均衡算法
            Instance instance = namingService.selectOneHealthyInstance(serviceName);

            //返回一个server
            return new NacosServer(instance);
        } catch (NacosException e) {
            log.error("自定义负载均衡算法错误");
        }*/


}