自定义feignClient 常见坑
自定义feignClient 踩过的坑,因为spring cloud 需要spring 4 以上的版本,所以对于低版本工程想要使用feign就需要自定义,在定义过程中遇到了很多问题,整理总结一下。(有需要的结合github请慢慢看,真的是手写的,但是有些东西不能全部粘贴出来抱歉了,全部的代码放在 第四点里面)
整体的过程分为两个部分:一、从eureka上拉取服务地址,二、feignClient 发送请求到目标服务器(其实feignClient 最终是使用httpClient 发送一个rest的请求,这就是官网给出httpclient和feign-okhttp的原因,这里使用okthhp 因为需要支持path请求)。
一、从eureka上拉取相关服务的配置信息。
这里使用的是加载eureka的默认配置,初始化时使用单例。代码如下
1,2的目的是加载项目中的配置,常量定义如下
private static final String CLIENT_CONFIG_FILE_NAME = "eureka"; private static final String CLIENT_RIBBON_CONFIG_FILE_NAME = "ribbon";
resource下定义两个文件:eureka.properties和ribbon.properties (名称可以需要改动),内容是声明服务必要的配置,具体配置如下:
ribbon.properties
aa.ribbon.DeploymentContextBasedVipAddresses=aa //aa 为feign中使用的服务名称 aa.ribbon.NIWSServerListClassName=com.netflix.niws.loadbalancer.DiscoveryEnabledNIWSServerList //服务调用策略,轮询等 aa.ribbon.ServerListRefreshInterval=60000 //客户端请求eureka 刷新aa 服务节点列表时间 ribbon.ConnectTimeout=50000000 //服务的超时时间 ribbon.ReadTimeout=50000000
eureka.properties
eureka.registration.enabled=false //服务是否注册到eureka上 eureka.serviceUrl.default=http://discovery.ingageapp.com:9401/eureka //eureka地址 #eureka.preferSameZone=true(其余可以百度下cans参数太多不一一列举 #eureka.shouldUseDns=false
具体代码如下,看下代码的具体解释:
1,2两步分别shi是加载ribbon和eureka配置,
3 通过DiscoveryManager加载配置信息。
private XsyServiceLocator() { try { ConfigurationManager.loadCascadedPropertiesFromResources(CLIENT_RIBBON_CONFIG_FILE_NAME); //1 ConfigurationManager.loadCascadedPropertiesFromResources(CLIENT_CONFIG_FILE_NAME); //2 } catch (IOException e) { throw new IllegalStateException("Xsy client config load error! Please check your client.properties"); } DiscoveryManager.getInstance().initComponent(new MyDataCenterInstanceConfig(), new DefaultEurekaClientConfig()); //3 }
二、feignClient 发送请求到目标服务器。
1,2两步是自定义了一个@FeignClient 注解,通过传经来的class拿去请求的服务名称即serviceId(如果你不会这个我也没办法了,略有尴尬)
3 Feign.builder() .client(new RibbonClient(new OkhttpClient())) (其实feign的负载均衡,发送请求都是通过ribbon完成的)
这里是初始化ribbonClient,最后的restclient 用的是okhttpclient。
4,5是用来编码和解码 (不要用goson的那个有坑)
6 是用来记录log的 关于log这个 ,feign默认打印的是debug级别的这个是因为他在代码里面写死的可以重写feign的Slf4jLogger类修改。
7 是设置log级别(具体哪些级别打印什么东西,自己搜下吧)
8 FeignInterceptor 是将一些请求header向下传递的(实现RequestInterceptor 接口重写即可)
9 拼接参数发送信息 拼接完 请求是 "http://aa(服务名称)/info (最后会根据eureka上的服务名称拼接成对应的ip+端口号,他自己底层实现的)
public <T> T lookup(Class<T> clazz) { FeignClient feignClient = clazz.getAnnotation(FeignClient.class);// 1 String serviceId = feignClient.value();//2 T service = Feign.builder() .client(new RibbonClient(new OkhttpClient()))//3 .encoder(new JacksonEncoder)//4 .decoder(new JacksonDecoder)//5 .logger(logger)//6 .logLevel(Logger.Level.HEADERS)//7 .requestInterceptor(new FeignInterceptor())//8 .target(clazz, "http://" + serviceId);//9 return service; }
三,一些坑:
1.源码的坑,实现过程中发现ribbon的配置并未生效,是因为feign-core源码问题,他总是会new一个 config 然后传进去,所以你得配置是无效的,这里重写(整个ribbonClient包copy下来改掉然后引用自己的)
2 这个类好像也是有问题的(忘记了)
四 、以下是现有全部的代码粘贴出来看一下:
public class XsyServiceLocator { private static final String CLIENT_CONFIG_FILE_NAME = "eureka"; private static final Object synRoot = new Object(); private static final String CLIENT_CONFIG_CUSTOM_FILED_NAME = "eureka.name"; private static final String CLIENT_RIBBON_CONFIG_FILE_NAME = "ribbon"; private static final JacksonEncoder jacksonEncoder = new JacksonEncoder(); private static final JacksonDecoder jacksonDecoder = new JacksonDecoder(); private static final RibbonClient ribbonClient = new RibbonClient(new OkHttpClient()); private static String ipAddress = null; private static boolean isLoadEureka = true;//为true表示需要加载默认eureka 配置文件如 crm,false则加载自定义eureka配置文件如paas-aggregator-service private static XsyFeignLogger logger = null; private XsyServiceLocator() { try { ConfigurationManager.loadCascadedPropertiesFromResources(CLIENT_RIBBON_CONFIG_FILE_NAME); ConfigurationManager.loadCascadedPropertiesFromResources(CLIENT_CONFIG_FILE_NAME); Object eurekaName = ConfigurationManager.getConfigInstance().getProperty(CLIENT_CONFIG_CUSTOM_FILED_NAME); if (eurekaName != null) { isLoadEureka = false; } } catch (IOException e) { throw new IllegalStateException("Xsy client config load error! Please check your client.properties"); } while (isLoadEureka && ipAddress == null) { DiscoveryManager.getInstance().initComponent(new MyDataCenterInstanceConfig(), new DefaultEurekaClientConfig()); ipAddress = DiscoveryManager.getInstance().getEurekaInstanceConfig().getIpAddress(); } } public <T> T lookup(Class<T> clazz) { if (isLoadEureka && ipAddress == null) { DiscoveryManager.getInstance().initComponent(new MyDataCenterInstanceConfig(), new DefaultEurekaClientConfig()); ipAddress = DiscoveryManager.getInstance().getEurekaInstanceConfig().getIpAddress(); } FeignClient feignClient = clazz.getAnnotation(FeignClient.class); String serviceId = feignClient.value(); if(logger == null){ synchronized (synRoot){ if(logger == null){ logger = new XsyFeignLogger(clazz); } } } T service = Feign.builder() .client(ribbonClient) .encoder(jacksonEncoder) .decoder(jacksonDecoder) .logger(logger) .logLevel(Logger.Level.HEADERS) .requestInterceptor(new FeignInterceptor()) .target(clazz, "http://" + serviceId); return service; }
更多推荐
所有评论(0)