研发提速：nacos+openfeign环境下的本地链接服务

项目研发过程中，经常会遇到与测试人员工作重叠的情况，十分影响效率。

做了一个修改，可以在本地环境启动项目后和测试环境交互，并且不影响测试环境，理论上也可以用于线上环境的异常的快速处理。

准备事项如下：

一：搭建本地的nacos服务。

二：导入测试环境相应项目的nacos配置文件。

三：新增代码：

修改LoadBalancerFactory获取服务host的方式，由于是本地启动的项目，并且连接的还是本地的nacos，所以项目启动后，肯定不会注册到测试环境，相对的也获取不到测试环境的其他服务。

由于本人使用的时候是基于CachingSpringLoadBalancerFactory ，如果直接使用时不生效或者异常，可以DEBUG跟踪一下自己框架调用服务时使用的具体LoadBalancerFactory类。

import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.netflix.client.config.IClientConfig;
import com.netflix.loadbalancer.ILoadBalancer;
import com.netflix.loadbalancer.Server;
import org.springframework.cloud.client.loadbalancer.LoadBalancedRetryFactory;
import org.springframework.cloud.netflix.ribbon.ServerIntrospector;
import org.springframework.cloud.netflix.ribbon.SpringClientFactory;
import org.springframework.cloud.openfeign.ribbon.CachingSpringLoadBalancerFactory;
import org.springframework.cloud.openfeign.ribbon.FeignLoadBalancer;
import org.springframework.cloud.openfeign.ribbon.RetryableFeignLoadBalancer;
import org.springframework.util.ConcurrentReferenceHashMap;
import org.springframework.util.ObjectUtils;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

public class DevCachingSpringLoadBalancerFactory extends CachingSpringLoadBalancerFactory {

    private volatile Map cache = new ConcurrentReferenceHashMap<>();
    private volatile Map> server = new ConcurrentReferenceHashMap<>();
    private volatile String ip;
    private volatile String port;
    private volatile String namespaceid;

    public DevCachingSpringLoadBalancerFactory(SpringClientFactory factory) {
        super(factory);
    }

    public DevCachingSpringLoadBalancerFactory(SpringClientFactory factory, LoadBalancedRetryFactory loadBalancedRetryPolicyFactory) {
        super(factory, loadBalancedRetryPolicyFactory);
    }

    public boolean initialize(String ip,String port,String namespaceid) {
        this.ip = ip;
        this.port = port;
        this.namespaceid = namespaceid;
        return null != ip ? null != port ?  null != namespaceid ? true : false :false :false;
    }

    @Override
    public FeignLoadBalancer create(String clientName) {
        FeignLoadBalancer client = this.cache.get(clientName);
        if (client != null) {
            return client;
        }
        IClientConfig config = this.factory.getClientConfig(clientName);
        ILoadBalancer lb = this.factory.getLoadBalancer(clientName);

        //修改部分
        List list = lb.getAllServers();
        if (null == list || ObjectUtils.isEmpty(list)) list = new ArrayList<>();
        list.addAll(Servers(clientName));
        lb.addServers(list);

        ServerIntrospector serverIntrospector = this.factory.getInstance(clientName,
                ServerIntrospector.class);
        client = this.loadBalancedRetryFactory != null
                ? new RetryableFeignLoadBalancer(lb, config, serverIntrospector,
                this.loadBalancedRetryFactory)
                : new FeignLoadBalancer(lb, config, serverIntrospector);
        this.cache.put(clientName, client);
        return client;
    }

    /**
     * 获取server
     * 返回数组，重试机制交由原框架
     * http://ip:port/nacos/v1/ns/instance/list?namespaceId=namespaceid&serviceName=client
     */
    public List Servers(String client) {
        if(server.containsKey(client)) return server.get(client);
        else synchronized (server) {
            if(server.containsKey(client)) return server.get(client);
            else {
                server.put(client,new ArrayList());
                String url = new StringBuilder("http://")
                        .append(ip)
                        .append(":")
                        .append(port)
                        .append("/nacos/v1/ns/instance/list?")
                        .append("namespaceId=")
                        .append(namespaceid)
                        .append("&serviceName=")
                        .append(client).toString();
                JSONObject jsonObject = JSON.parseObject(HttpUtil.get(url));
                JSONArray hosts = jsonObject.getJSONArray("hosts");
                for (int i = 0; i < hosts.size(); i++) {
                    server.get(client).add(new Server(hosts.getJSONObject(i).getString("ip"),hosts.getJSONObject(i).getInteger("port")));
                }
                return server.get(client);
            }
        }
    }

}

这个文件可以不用添加，主要是用来做一些其他的扩展。

import feign.Client;
import feign.Request;
import feign.Response;
import org.springframework.cloud.netflix.ribbon.SpringClientFactory;
import org.springframework.cloud.openfeign.ribbon.CachingSpringLoadBalancerFactory;
import org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient;

import java.io.IOException;

public class DevFeignClient extends LoadBalancerFeignClient{

    public DevFeignClient(Client delegate, CachingSpringLoadBalancerFactory lbClientFactory, SpringClientFactory clientFactory) {
        super(delegate, lbClientFactory, clientFactory);
    }

    @Override
    public Response execute(Request request, Request.Options options) throws IOException {
        return super.execute(request, options);
    }
}

配置文件用来替换原来IOC中的BEAN，另外用于获取后面yml文件中的自定义配置。

import feign.Client;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.cloud.netflix.ribbon.SpringClientFactory;
import org.springframework.cloud.openfeign.ribbon.CachingSpringLoadBalancerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class DevFeignConfig {

    @ConditionalOnProperty("feign.dev.enabled")
    @Configuration(proxyBeanMethods = false)
    class DefaultFeignLoadBalancedConfiguration {
        @Value("${feign.dev.ip}")
        String ip;
        @Value("${feign.dev.port}")
        String port;
        @Value("${feign.dev.namespaceid}")
        String namespaceid;


        @Bean
        public Client feignClient(CachingSpringLoadBalancerFactory cachingFactory, DevCachingSpringLoadBalancerFactory devFactory,
                                  SpringClientFactory clientFactory) {
            System.out.println("#####################################进入本地调试模式#####################################");
            return new DevFeignClient(new Client.Default(null, null),null == devFactory?cachingFactory:devFactory,
                    clientFactory);
        }

        @Bean
        public DevCachingSpringLoadBalancerFactory devFactory(SpringClientFactory factory) {
            DevCachingSpringLoadBalancerFactory devFactory = new DevCachingSpringLoadBalancerFactory(factory);
            if(devFactory.initialize(ip,port,namespaceid)) return devFactory;
            System.out.println("#####################################本地调试模式异常#####################################");
            System.out.println("feign.dev.ip " + ip);
            System.out.println("feign.dev.port " + port);
            System.out.println("feign.dev.namespaceid " + namespaceid);
            System.out.println("#####################################本地调试模式异常#####################################");
            return null;
        }
    }


}

修改yml文件，主要是用来配置新增的自定义属性和小插件的开启和关闭。

建议手动在本地项目的yml文件添加属性，yml文件的配置，直接复制容易出现问题。

新增属性如下：

feign.dev.enabled

feign.dev.ip

feign.dev.port

feign.dev.namespaceid

server:
  port: 服务端口号
spring:
  application:
    name: 服务名称
  profiles:
    active: dev
  cloud:
    nacos:
      config:
        file-extension: yml
        namespace: 本地Nacos的命名空间
      username: 本地Nacos的账号
      password: 本地Nacos的密码
      server-addr: 本地Nacos的IP:本地Nacos的端口号
      discovery:
        namespace: 本地Nacos的命名空间
        group: DEFAULT_GROUP
        enabled: true
        register-enabled: true
feign:
  dev:
    #true为开启本地调式，false为关闭
    enabled: false
    ip: 测试环境Nacos的IP
    port: 测试环境Nacos的端口号
    namespaceid:  测试环境Nacos的命名空间
  client:
    config:
      default:
        #不设置connectTimeout会导致readTimeout设置不生效
        connectTimeout: 5000
        readTimeout: 5000