Sentinel与OpenFeign整合实现熔断降级源码分析

本篇文章写于2020年07月15日，从公众号｜掘金｜CSDN手工同步过来（博客搬家），本篇为原创文章。

Sentinel源码分析可以看笔者出版的书：《实战Alibaba Sentinel》

Sentinel无论是实现限流还是熔断降级，其实都是通过适配模块去实现拦截方法的执行，在方法执行之前调用所有ProcessorSlot的entry方法，在方法执行之后所有ProcessorSlot的exit方法，使用责任链模式调用。由StatisticSlot这个ProcessorSlot统计请求信息，由DegradeSlot检查当前请求是否需要熔断，由FlowSlot检查当前请求是否需要限流。

StatisticSlot的entry方法将资源当前时间窗口的Bucket的请求数自增1，如果需要限流或熔断，则将Bucket的限流总数自增1；exit方法负责更新Bucket的成功总数或者异常总数、总耗时、最大耗时，以及将并发使用的线程总数减1。

Sentinel提供各种适配模块让我们更方便的使用Sentinel，这些适配模块只不过是帮我们完成调用ProcessorSlot的entry方法以及调用ProcessorSlot的exit方法。在前面学习使用Sentinel与OpenFeign整合实现熔断降级时，我们使用spring-cloud-start-alibaba-sentinel，由它实现Sentinel与OpenFeign整合。

Sentinel与OpenFeign整合源码分析

当Sentinel与OpenFeign、Ribbon整合时，客户端向服务端发起一次请求的过程如下图所示。

• 1、当调用@FeignClient注解注释的接口的方法时，由Sentinel提供的SentinelInvocationHandler方法调用拦截器拦截方法的执行，根据调用的方法的url生成资源名称，然后调用Sentinel的SphU的entry方法（完成所有ProcessorSlot的entry方法的调用），判断当前发起的请求是否需要限流或者熔断降级；
• 2、非限流、熔断降级情况下，继续将请求交给OpenFeign的MethodHandler处理；
• 3、OpenFeign从Ribbon那里获取一个服务提供者节点；
• 4、OpenFeign使用HttpClient发起http请求；
• 5、OpenFeign请求成功或者异常（已经经过重试）时，调用Sentinel的Entry的exit方法（完成所有ProcessorSlot的exit方法的调用）更新当前时间窗口的请求成功总数、异常总数等；

可见，Sentinel处在接口调用的最前端，因此Sentinel的统计数据即不会受Ribbon的重试影响也不会受OpenFeign的重试影响。

Sentinel通过自己提供InvocationHandler替换OpenFeign的InvocationHandler实现请求拦截。SentinelInvocationHandler源码调试如下图所示。

InvocationHandler是OpenFeign为接口生成的JDK动态代理类时所需要的，是接口的方法拦截处理器，Sentinel通过替换OpenFeign的InvocationHandler拦截方法的执行，在OpenFeign处理接口调用之前实现限流、熔断降级的逻辑，以及之后的接口调用成功或异常时的数据统计。那么，Sentinel是如何将原本的FeignInvocationHandler替换为SentinelInvocationHandler的呢？

OpenFeign是通过Feign.Builder类创建接口的代理类的，所以Sentinel直接将Feign.Builder也替换成了SentinelFeign.Builder，由SentinelFeignAutoConfiguration自动配置类向Spring的Bean容器注入SentinelFeign，代码如下。

@Configuration(proxyBeanMethods = false)
@ConditionalOnClass({ SphU.class, Feign.class })
public class SentinelFeignAutoConfiguration {

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

}

SentinelFeign.Builder继承Feign.Builder并重写build方法，只是替换了InvocationHandlerFactory，所以OpenFeign调用InvocationHandlerFactory的create方法创建的InvocationHandler就变成了SentinelInvocationHandler。SentinelFeign.Builder的build方法源码如下。

public final class SentinelFeign {

	public static Builder builder() {
		return new Builder();
	}

	public static final class Builder extends Feign.Builder
			implements ApplicationContextAware {

	   // .....

		@Override
		public Feign build() {
			super.invocationHandlerFactory(new InvocationHandlerFactory() {
				@Override
				public InvocationHandler create(Target target,
						Map<Method, MethodHandler> dispatch) {
					// 创建SentinelInvocationHandler
				}
			});
			super.contract(new SentinelContractHolder(contract));
			return super.build();
		}
		// .....
	}

}

build方法中的匿名内部类InvocationHandlerFactory的create方法代码很长，所以去掉了。

create方法负责创建SentinelInvocationHandler，通过反射从FeignClientFactoryBean拿到@FeignClient注解上配置的fallback，当触发限流或熔断时，Sentinel就能根据fallback配置的类型从Bean工厂取得Fallback并调用。