摘要：得到得到類得到類得到調(diào)用的服務(wù)名稱檢查和屬性省略部分代碼中的方法里面進(jìn)行熔斷限流的處理。在的方法中進(jìn)行的包裝。

Spring Cloud Alibaba Sentinel 除了對(duì) RestTemplate 做了支持，同樣對(duì)于 Feign 也做了支持，如果我們要從 Hystrix 切換到 Sentinel 是非常方便的，下面來(lái)介紹下如何對(duì) Feign 的支持以及實(shí)現(xiàn)原理。

spring-cloud-starter-alibaba-sentinel 的依賴還是要加的，如下：

    org.springframework.cloud
    spring-cloud-starter-alibaba-sentinel
    0.2.1.RELEASE

需要在配置文件中開啟 sentinel 對(duì) feign 的支持：

feign.sentinel.enabled=true

然后我們定義自己需要調(diào)用的 Feign Client：

@FeignClient(name = "user-service", fallback = UserFeignClientFallback.class)
public interface UserFeignClient {
    
    @GetMapping("/user/get")
    public String getUser(@RequestParam("id") Long id);
    
}

定義 fallback 類 UserFeignClientFallback：

@Component
public class UserFeignClientFallback implements UserFeignClient {

    @Override
    public String getUser(Long id) {
        return "fallback";
    }

}

測(cè)試代碼：

@Autowired
private UserFeignClient userFeignClient;

@GetMapping("/testFeign")
public String testFeign() {
    return userFeignClient.getUser(1L);
}

你可以將這個(gè) Client 對(duì)應(yīng)的 user-service 停掉，然后就可以看到輸出的內(nèi)容是 "fallback"

如果要對(duì) Feign 調(diào)用做限流，資源名稱的規(guī)則是精確到接口的，以我們上面定義的接口來(lái)分析，資源名稱就是GET:http://user-service/user/get，至于資源名稱怎么定義的，接下面的源碼分析你就知道了。

首先看SentinelFeignAutoConfiguration中如何自動(dòng)配置：

@Bean
@Scope("prototype")
@ConditionalOnMissingBean
@ConditionalOnProperty(name = "feign.sentinel.enabled")
public Feign.Builder feignSentinelBuilder() {
    return SentinelFeign.builder();
}

@ConditionalOnProperty 中 feign.sentinel.enabled 起了決定性作用，這也就是為什么我們需要在配置文件中指定 feign.sentinel.enabled=true。

接下來(lái)看 SentinelFeign.builder 里面的實(shí)現(xiàn)：

build方法中重新實(shí)現(xiàn)了super.invocationHandlerFactory方法，也就是動(dòng)態(tài)代理工廠，構(gòu)建的是InvocationHandler對(duì)象。

build中會(huì)獲取Feign Client中的信息，比如fallback,fallbackFactory等，然后創(chuàng)建一個(gè)SentinelInvocationHandler，SentinelInvocationHandler繼承了InvocationHandler。

@Override
public Feign build() {
    super.invocationHandlerFactory(new InvocationHandlerFactory() {
        @Override
        public InvocationHandler create(Target target,
                Map dispatch) {
            // 得到Feign Client Bean
            Object feignClientFactoryBean = Builder.this.applicationContext
                    .getBean("&" + target.type().getName());
            // 得到fallback類
            Class fallback = (Class) getFieldValue(feignClientFactoryBean,
                    "fallback");
            // 得到fallbackFactory類
            Class fallbackFactory = (Class) getFieldValue(feignClientFactoryBean,
                    "fallbackFactory");
            // 得到調(diào)用的服務(wù)名稱
            String name = (String) getFieldValue(feignClientFactoryBean, "name");

            Object fallbackInstance;
            FallbackFactory fallbackFactoryInstance;
            // 檢查 fallback 和 fallbackFactory 屬性
            if (void.class != fallback) {
                fallbackInstance = getFromContext(name, "fallback", fallback,
                                target.type());
                return new SentinelInvocationHandler(target, dispatch,
                                new FallbackFactory.Default(fallbackInstance));
            }
            if (void.class != fallbackFactory) {
                fallbackFactoryInstance = (FallbackFactory) getFromContext(name,
                        "fallbackFactory", fallbackFactory,
                                FallbackFactory.class);
                return new SentinelInvocationHandler(target, dispatch,
                                fallbackFactoryInstance);
            }
            return new SentinelInvocationHandler(target, dispatch);
        }
  
        // 省略部分代碼                
    });
        
    super.contract(new SentinelContractHolder(contract));
    return super.build();
}

SentinelInvocationHandler中的invoke方法里面進(jìn)行熔斷限流的處理。

// 得到資源名稱（GET:http://user-service/user/get）
String resourceName = methodMetadata.template().method().toUpperCase() + ":"
                    + hardCodedTarget.url() + methodMetadata.template().url();
Entry entry = null;
try {
    ContextUtil.enter(resourceName);
    entry = SphU.entry(resourceName, EntryType.OUT, 1, args);
    result = methodHandler.invoke(args);
}
catch (Throwable ex) {
    // fallback handle
    if (!BlockException.isBlockException(ex)) {
        Tracer.trace(ex);
    }
    if (fallbackFactory != null) {
        try {
            // 回退處理
            Object fallbackResult = fallbackMethodMap.get(method)
                    .invoke(fallbackFactory.create(ex), args);
            return fallbackResult;
        }
        catch (IllegalAccessException e) {
            // shouldn"t happen as method is public due to being an interface
            throw new AssertionError(e);
        }
        catch (InvocationTargetException e) {
            throw new AssertionError(e.getCause());
        }
    }
    // 省略.....
}

總的來(lái)說，這些框架的整合都有相似之處，前面講RestTemplate的整合其實(shí)和Ribbon中的@LoadBalanced原理差不多，這次的Feign的整合其實(shí)我們從其他框架的整合也是可以參考出來(lái)的，最典型的就是Hystrix了。

我們想下Hystrix要對(duì)Feign的調(diào)用進(jìn)行熔斷處理，那么肯定是將Feign的請(qǐng)求包裝了HystrixCommand。同樣的道理，我們只要找到Hystrix是如何包裝的，無(wú)非就是將Hystrix的代碼換成Sentinel的代碼而已。

InvocationHandlerFactory是用于創(chuàng)建動(dòng)態(tài)代理的工廠，有默認(rèn)的實(shí)現(xiàn)，也有Hystrix的實(shí)現(xiàn)feign.hystrix.HystrixFeign。

Feign build(final FallbackFactory nullableFallbackFactory) {
      super.invocationHandlerFactory(new InvocationHandlerFactory() {
        @Override public InvocationHandler create(Target target,
            Map dispatch) {
          return new HystrixInvocationHandler(target, dispatch, setterFactory, nullableFallbackFactory);
        }
      });
      super.contract(new HystrixDelegatingContract(contract));
      return super.build();
}

上面這段代碼是不是跟Sentinel包裝的類似，不同的是Sentinel構(gòu)造的是SentinelInvocationHandler ，Hystrix構(gòu)造的是HystrixInvocationHandle。在HystrixInvocationHandler的invoke方法中進(jìn)行HystrixCommand的包裝。