Spring Cloud Sentinel工作原理分析

ゞ浴缸里的玫瑰 2022-11-16 15:20 295阅读 0赞

### 文章目录 ###

*   *   *   *  （1）介绍
             *  （2）SentinelWebAutoConfiguration自动装配
             *  （3）CommonFilter分析

#### （1）介绍 ####

在Spring Cloud中使用Sentinel实现限流的场景中，我们并不需要任何配置，Sentinel会自动保护所有的HTTP服务，  
在Spring-Cloud-Starter-Alibaba-Sentinel包中，我们知道Starter组件会用到自动装配，所以直接找到META-INF/spring.factories文件。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L09jdG9wdXMyMQ_size_16_color_FFFFFF_t_70]  
这里EnableAutoConfiguration自动装配了5个配置类。  
1、SentinelWebAutoConfiguration是对Web Servlet环境的支持。  
2、SentinelWebFluxAutoConfiguration是对Spring WebFlux的支持。  
3、SentinelEndpointAutoConfiguration暴露Endpoint信息。  
4、SentinelFeignAutoConfiguration用于适配Feign组件。  
5、 SentinelAutoConfiguration支持对RestTemplate的服务调用使用Sentinel进行保护。

#### （2）SentinelWebAutoConfiguration自动装配 ####

类路径：com.alibaba.cloud.sentinel.SentinelWebAutoConfiguration

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L09jdG9wdXMyMQ_size_16_color_FFFFFF_t_70 1]  
在SentinelWebAutoConfiguration配置类中，自动装配了一个FilterRegistrationBean，该类支持构建有优先级的过滤器，主要作用是注册一个CommonFilter，并且默认情况下通过“/\*”规则拦截所有的请求

private int order = Ordered.HIGHEST_PRECEDENCE; // -2147483648;
    registration.setOrder(filterConfig.getOrder());

上面设置了过滤器的优先级，是一个极小值，即Sentinel默认开启的是最高优先级拦截/\*请求

#### （3）CommonFilter分析 ####

该类是一个实现了Filter接口的自定义过滤器，现在假设我们请求http://localhost:8888/test

public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)  { 
            HttpServletRequest sRequest = (HttpServletRequest)request;
            Entry urlEntry = null;
    
            try { 
    			//获取请求端点，即/test
                String target = FilterUtil.filterTarget(sRequest);
                UrlCleaner urlCleaner = WebCallbackManager.getUrlCleaner();
                if (urlCleaner != null) { 
    				//获取URLcleaner，如果存在，则说明配置过URL清洗策略，调用UrlCleaner.clean替换Target请求
                    target = urlCleaner.clean(target);
                }
    			
                if (!StringUtil.isEmpty(target)) { 
                    String origin = this.parseOrigin(sRequest);
                    String contextName = this.webContextUnify ? "sentinel_web_servlet_context" : target;
                    ContextUtil.enter(contextName, origin);
    				//下面的俩个SphU.entry就是在对当前URL添加限流埋点
                    if (this.httpMethodSpecify) { 
                        String pathWithHttpMethod = sRequest.getMethod().toUpperCase() + ":" + target;
                        urlEntry = SphU.entry(pathWithHttpMethod, 1, EntryType.IN);
                    } else { 
                        urlEntry = SphU.entry(target, 1, EntryType.IN);
                    }
                }
                //进入下一个Filter
                chain.doFilter(request, response);
    
    
        }

对于WebServlet环境，只是通过Filter的方式将所有请求自动设置为Sentinel的资源，从而达到限流的目的。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L09jdG9wdXMyMQ_size_16_color_FFFFFF_t_70]: /images/20221022/bc2cbd9a098546efae751c99d65cd689.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L09jdG9wdXMyMQ_size_16_color_FFFFFF_t_70 1]: /images/20221022/5f8f937a494744dd96b27558b4ef96ce.png