SpringCloud微服务架构笔记（二）：使用Feign实现服务调用

需积分: 20 63 浏览量更新于2024-01-13 收藏 2.43MB PDF 举报

SpringCloud微服务架构是一种声明式、模板化的HTTP客户端，它可以帮助我们更加便捷、优雅地调用HTTP API。在前面的学习中，我们使用了RestTemplate来实现REST API的调用，但是当URL中含有多个参数时，使用拼接字符串的方式构造URL会非常痛苦。这时候，我们可以使用Feign来解决这个问题。 Feign是由Netﬂix开发的，灵感来自于Retroﬁt、JAXRS-2.0以及WebSocket。在SpringCloud中，使用Feign非常简单，我们只需要创建一个接口，并在接口上添加一些注解即可完成代码的编写。Feign支持多种注解，包括Feign自带的注解以及JAX-RS注解等。而SpringCloud对Feign进行了增强，使得Feign支持了SpringMVC注解，并整合了Ribbon和Eureka，从而让Feign的使用更加方便。要使用Feign进行服务调用，我们首先需要引入Feign的依赖。在服务消费者shop_service_order中添加Feign的依赖后，我们需要在启动类上添加@EnableFeignClients注解来启用Feign。在编写具体的服务调用代码时，我们只需要创建一个接口，并在接口上使用@FeignClient注解来指定要调用的服务的名称。接口中的方法就是要调用的具体服务接口的方法，Feign会根据接口定义自动进行服务的调用。同时，我们可以在接口上使用各种注解来对请求进行定义，例如@RequestMapping、@RequestParam等。使用Feign进行服务调用的好处是，我们不再需要手动拼接URL，Feign会根据接口定义自动构造URL。此外，Feign还可以自动将请求参数和请求头注入到HTTP请求中，使得我们不再需要手动处理这些内容。而且，Feign还支持负载均衡，它会将请求根据特定的负载均衡策略分发到多个服务实例上，以提高系统的可用性和性能。总之，使用Feign进行服务调用可以帮助我们更加便捷、优雅地调用HTTP API。通过创建接口并添加注解，Feign能够根据接口定义自动构造URL并将请求参数和请求头注入到HTTP请求中。此外，Feign还支持负载均衡，提高了系统的可用性和性能。使用Feign可以大大简化我们的代码，提高开发效率。

通过分析可知：我们最终是向

Spring中注册了一个bean，bean的名称就是类或接口的名称（也就是本

例中的FeignService），bean的实现类是FeignClientFactoryBean，其属性设置就是我们在

@FeignClient中定义的属性。那么下面我们在Controller中对FeignService的的引入，实际就是引入了

FeignClientFactoryBean

类

（4） FeignClientFactoryBean类

们对@EnableFeignClients注解的源码进行了分析，了解到其主要作用就是把带有@FeignClient注解的

类或接口用FeignClientFactoryBean类注册到Spring中。

 // 2.BeanDefinitionBuilder的主要作用就是构建一个AbstractBeanDefinition

 // AbstractBeanDefinition类最终被构建成一个BeanDefinitionHolder

 // 然后注册到Spring中

 // 注意：beanDefinition类为FeignClientFactoryBean，故在Spring获取类的时候实际返回

的是

 // FeignClientFactoryBean类

 BeanDefinitionBuilder definition = BeanDefinitionBuilder

   .genericBeanDefinition(FeignClientFactoryBean.class);

 validate(attributes);

 

 // 3.添加FeignClientFactoryBean的属性，

 // 这些属性也都是我们在@FeignClient中定义的属性

 definition.addPropertyValue("url", getUrl(attributes));

 definition.addPropertyValue("path", getPath(attributes));

 String name = getName(attributes);

 definition.addPropertyValue("name", name);

 definition.addPropertyValue("type", className);

 definition.addPropertyValue("decode404", attributes.get("decode404"));

 definition.addPropertyValue("fallback", attributes.get("fallback"));

 definition.addPropertyValue("fallbackFactory",

attributes.get("fallbackFactory"));

 definition.setAutowireMode(AbstractBeanDefinition.AUTOWIRE_BY_TYPE);

 // 4.设置别名 name就是我们在@FeignClient中定义的name属性

 String alias = name + "FeignClient";

 AbstractBeanDefinition beanDefinition = definition.getBeanDefinition();

 boolean primary = (Boolean)attributes.get("primary"); // has a default,

won't be null

 beanDefinition.setPrimary(primary);

 String qualifier = getQualifier(attributes);

 if (StringUtils.hasText(qualifier)) {

   alias = qualifier;

 }

 // 5.定义BeanDefinitionHolder，

 // 在本例中名称为FeignService，类为FeignClientFactoryBean

 BeanDefinitionHolder holder = new BeanDefinitionHolder(beanDefinition,

className,

                             new String[] { alias

});

 BeanDefinitionReaderUtils.registerBeanDefinition(holder, registry);

}

通过

FeignClientFactoryBean

类结构可以发现其实现了FactoryBean类，那么当从

ApplicationContext中获取该bean的时候，实际调用的是其getObject()方法。返回调用getTarget()方法

FeignClientFactoryBean

实现了FactoryBean的getObject、getObjectType、isSingleton方法；

实现了InitializingBean的afterPropertiesSet方法；实现了ApplicationContextAware的

setApplicationContext方法

getObject

调用的是getTarget方法，它从applicationContext取出FeignContext，然后构造

Feign.Builder并设置了logger、encoder、decoder、contract，之后通过conﬁgureFeign根据

FeignClientProperties来进一步配置Feign.Builder的retryer、errorDecoder、

request.Options、requestInterceptors、queryMapEncoder、decode404

class FeignClientFactoryBean implements FactoryBean<Object>, InitializingBean,

ApplicationContextAware {

 public Object getObject() throws Exception {

   return this.getTarget();

 }

 //略

}

 <T> T getTarget() {

   FeignContext context =

(FeignContext)this.applicationContext.getBean(FeignContext.class);

   Builder builder = this.feign(context);

   if (!StringUtils.hasText(this.url)) {

     if (!this.name.startsWith("http")) {

       this.url = "http://" + this.name;

     } else {

       this.url = this.name;

     }

     this.url = this.url + this.cleanPath();

     return this.loadBalance(builder, context, new

HardCodedTarget(this.type, this.name, this.url));

   } else {

     if (StringUtils.hasText(this.url) && !this.url.startsWith("http")) {

       this.url = "http://" + this.url;

     }

     String url = this.url + this.cleanPath();

     Client client = (Client)this.getOptional(context, Client.class);

     if (client != null) {

       if (client instanceof LoadBalancerFeignClient) {

         client = ((LoadBalancerFeignClient)client).getDelegate();

       }

       builder.client(client);

     }

     Targeter targeter = (Targeter)this.get(context, Targeter.class);

     return targeter.target(this, builder, context, new

HardCodedTarget(this.type, this.name, url));

   }

 }

剩余37页未读，继续阅读

gylinjinhai

粉丝: 9

SpringCloud微服务架构笔记（二）：使用Feign实现服务调用

"从单体到微服务：SpringCloud微服务架构笔记

"从单体应用到微服务架构演变：SpringCloud微服务架构笔记

SpringCloud微服务架构在广告系统设计与实现中的应用

SpringCloud微服务架构笔记（二）1

SpringCloud微服务架构笔记（四

SpringCloud微服务架构笔记（一）

SpringCloud微服务架构笔记（三）

SpringCloud微服务架构笔记（一）1

SpringCloud微服务架构笔记（三）1

SpringCloud微服务架构笔记（四）1

最新资源