關(guān)于feign接口動態(tài)代理源碼解析

更新時(shí)間：2022年03月09日 08:55:50 作者：keygod1

這篇文章主要介紹了關(guān)于feign接口動態(tài)代理源碼解析，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

feign接口動態(tài)代理源碼解析

@FeignClinet 代理類注冊

@FeignClinet 通過動態(tài)代理實(shí)現(xiàn)的底層http調(diào)用，既然是動態(tài)代理，必然存在創(chuàng)建代理類的過程。如Proxy.newProxyInstance或者 CGlib org.springframework.cloud.openfeign 的代理類注冊實(shí)現(xiàn)如下。

首先，org.springframework.cloud.openfeign.FeignClientsRegistrar 注冊FeignClientFactoryBean到Singleton緩存中. 一個(gè)接口對應(yīng)FeignClientFactoryBean。

spring 初始化容器過程中執(zhí)行

org.springframework.cloud.openfeign.FeignClientFactoryBean.getObject()

@Override
? ?public Object getObject() throws Exception {
? ??? ?return getTarget();
? ?}
? ?/**
? ? * @param <T> the target type of the Feign client
? ? * @return a {@link Feign} client created with the specified data and the context information
? ? */
? ?<T> T getTarget() {
? ??? ?FeignContext context = applicationContext.getBean(FeignContext.class);
? ??? ?Feign.Builder builder = feign(context);
? ??? ?if (!StringUtils.hasText(this.url)) {
? ??? ??? ?if (!this.name.startsWith("http")) {
? ??? ??? ??? ?url = "http://" + this.name;
? ??? ??? ?}
? ??? ??? ?else {
? ??? ??? ??? ?url = this.name;
? ??? ??? ?}
? ??? ??? ?url += cleanPath();
? ??? ??? ?return (T) loadBalance(builder, context, new HardCodedTarget<>(this.type,
? ??? ??? ??? ??? ?this.name, url));
? ??? ?}
? ??? ?if (StringUtils.hasText(this.url) && !this.url.startsWith("http")) {
? ??? ??? ?this.url = "http://" + this.url;
? ??? ?}
? ??? ?String url = this.url + cleanPath();
? ??? ?Client client = getOptional(context, Client.class);
? ??? ?if (client != null) {
? ??? ??? ?if (client instanceof LoadBalancerFeignClient) {
? ??? ??? ??? ?// not load balancing because we have a url,
? ??? ??? ??? ?// but ribbon is on the classpath, so unwrap
? ??? ??? ??? ?client = ((LoadBalancerFeignClient)client).getDelegate();
? ??? ??? ?}
? ??? ??? ?builder.client(client);
? ??? ?}
? ??? ?Targeter targeter = get(context, Targeter.class);
? ??? ?return (T) targeter.target(this, builder, context, new HardCodedTarget<>(
? ??? ??? ??? ?this.type, this.name, url));
? ?}

其中 getObject() 實(shí)現(xiàn)了 FactoryBean 的 getObject()，

作用是在springContext初始化時(shí)創(chuàng)建Bean實(shí)例，如果isSingleton()返回true,則該實(shí)例會放到Spring容器的單實(shí)例緩存池中。

然后是targeter.target() 如果啟用了Hystrix調(diào)用的就是

org.springframework.cloud.openfeign.HystrixTargeter.target()

org.springframework.cloud.openfeign.HystrixTargeter

/**
* @param factory bean工廠
* @param feign ?feign對象的構(gòu)造類
* @param context feign接口上下文，
* @param target 保存了feign接口的name，url和FeignClient的Class對象
*
**/
@Override
? ?public <T> T target(FeignClientFactoryBean factory, Feign.Builder feign, FeignContext context,
? ??? ??? ??? ??? ??? ?Target.HardCodedTarget<T> target) {
? ??? ?if (!(feign instanceof feign.hystrix.HystrixFeign.Builder)) {
? ??? ??? ?return feign.target(target);
? ??? ?}
? ??? ?feign.hystrix.HystrixFeign.Builder builder = (feign.hystrix.HystrixFeign.Builder) feign;
? ??? ?SetterFactory setterFactory = getOptional(factory.getName(), context,
? ??? ??? ?SetterFactory.class);
? ??? ?if (setterFactory != null) {
? ??? ??? ?builder.setterFactory(setterFactory);
? ??? ?}
? ??? ?Class<?> fallback = factory.getFallback();
? ??? ?if (fallback != void.class) {
? ??? ??? ?return targetWithFallback(factory.getName(), context, target, builder, fallback);
? ??? ?}
? ??? ?Class<?> fallbackFactory = factory.getFallbackFactory();
? ??? ?if (fallbackFactory != void.class) {
? ??? ??? ?return targetWithFallbackFactory(factory.getName(), context, target, builder, fallbackFactory);
? ??? ?}
? ??? ?return feign.target(target);
? ?}

再看下去 feign.target(target)

feign.Feign.Builder

? ? public <T> T target(Target<T> target) {
? ? ? return build().newInstance(target);
? ? }
? ? public Feign build() {
? ? ? SynchronousMethodHandler.Factory synchronousMethodHandlerFactory =
? ? ? ? ? new SynchronousMethodHandler.Factory(client, retryer, requestInterceptors, logger,
? ? ? ? ? ? ? logLevel, decode404, closeAfterDecode, propagationPolicy);
? ? ? ParseHandlersByName handlersByName =
? ? ? ? ? new ParseHandlersByName(contract, options, encoder, decoder, queryMapEncoder,
? ? ? ? ? ? ? errorDecoder, synchronousMethodHandlerFactory);
? ? ? return new ReflectiveFeign(handlersByName, invocationHandlerFactory, queryMapEncoder);
? ? }

build() 返回一個(gè)ReflectiveFeign對象。

往下看，ReflectiveFeign的newInstance方法。

feign.ReflectiveFeign

@Override
? public <T> T newInstance(Target<T> target) {
? ? //關(guān)鍵方法： 解析target對象，返回key 為 feign接口的url ，value 為請求執(zhí)行類：SynchronousMethodHandler
? ? Map<String, MethodHandler> nameToHandler = targetToHandlersByName.apply(target);
? ? Map<Method, MethodHandler> methodToHandler = new LinkedHashMap<Method, MethodHandler>();
? ? List<DefaultMethodHandler> defaultMethodHandlers = new LinkedList<DefaultMethodHandler>();
? ? for (Method method : target.type().getMethods()) {
? ? ? if (method.getDeclaringClass() == Object.class) {
? ? ? ? continue;
? ? ? } else if (Util.isDefault(method)) {
? ? ? ? DefaultMethodHandler handler = new DefaultMethodHandler(method);
? ? ? ? defaultMethodHandlers.add(handler);
? ? ? ? methodToHandler.put(method, handler);
? ? ? } else {
? ? ? ? methodToHandler.put(method, nameToHandler.get(Feign.configKey(target.type(), method)));
? ? ? }
? ? }
? ? //創(chuàng)建代理類 handler ，返回對象 ?feign.ReflectiveFeign.FeignInvocationHandler
? ? InvocationHandler handler = factory.create(target, methodToHandler);
? ? T proxy = (T) Proxy.newProxyInstance(target.type().getClassLoader(),
? ? ? ? new Class<?>[] {target.type()}, handler);
? ? for (DefaultMethodHandler defaultMethodHandler : defaultMethodHandlers) {
? ? ? defaultMethodHandler.bindTo(proxy);
? ? }
? ? return proxy;
? }

至此，代理類注冊完成。

當(dāng)調(diào)用feign接口時(shí)，其實(shí)執(zhí)行的是 feign.ReflectiveFeign.FeignInvocationHandler的invoke 方法

@Override
? ? public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
? ? ? if ("equals".equals(method.getName())) {
? ? ? ? try {
? ? ? ? ? Object otherHandler =
? ? ? ? ? ? ? args.length > 0 && args[0] != null ? Proxy.getInvocationHandler(args[0]) : null;
? ? ? ? ? return equals(otherHandler);
? ? ? ? } catch (IllegalArgumentException e) {
? ? ? ? ? return false;
? ? ? ? }
? ? ? } else if ("hashCode".equals(method.getName())) {
? ? ? ? return hashCode();
? ? ? } else if ("toString".equals(method.getName())) {
? ? ? ? return toString();
? ? ? }
? ? ? ? //dispatch.get(method)返回的是 SynchronousMethodHandler 對象
? ? ? return dispatch.get(method).invoke(args);
? ? }

調(diào)用的 SynchronousMethodHandler invoke 方法。

feign.SynchronousMethodHandler

?@Override
? public Object invoke(Object[] argv) throws Throwable {
? ? RequestTemplate template = buildTemplateFromArgs.create(argv);
? ? Retryer retryer = this.retryer.clone();
? ? while (true) {
? ? ? try {
? ? ? ? return executeAndDecode(template);
? ? ? } catch (RetryableException e) {
? ? ? ? try {
? ? ? ? ? retryer.continueOrPropagate(e);
? ? ? ? } catch (RetryableException th) {
? ? ? ? ? Throwable cause = th.getCause();
? ? ? ? ? if (propagationPolicy == UNWRAP && cause != null) {
? ? ? ? ? ? throw cause;
? ? ? ? ? } else {
? ? ? ? ? ? throw th;
? ? ? ? ? }
? ? ? ? }
? ? ? ? if (logLevel != Logger.Level.NONE) {
? ? ? ? ? logger.logRetry(metadata.configKey(), logLevel);
? ? ? ? }
? ? ? ? continue;
? ? ? }
? ? }
? }

executeAndDecode 方法執(zhí)行RPC調(diào)用的邏輯。

小結(jié)一下：FeignClientsRegistrar 解析@FeignClient注解，注冊對應(yīng)的FeignClientFactoryBean–》通過FeignClientFactoryBean的getObject()方法返回代理對象 feign.ReflectiveFeign.FeignInvocationHandler

feign源碼解析

首先我要說的是springcloud沒有rpc，這就涉及rpc和微服務(wù)的區(qū)別。springcloud的模塊通信工具feign跟httpclient和okhttp是一樣的東西，都是對http請求封裝的工具，其實(shí)feign可以選擇httpclient或者okhttp作為底層實(shí)現(xiàn)（修改配置即可）。