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

见解分享

2023-10-16 10:47:35

Sentinel：守护微服务系统的安全屏障

在微服务架构中，系统稳定性和性能至关重要。Sentinel，一个强大的开源组件，应运而生，为分布式系统提供了全面的保护措施。它与OpenFeign无缝集成，共同打造了一个牢不可破的防御体系。

Sentinel：限流、熔断与降级的卫士

Sentinel通过一系列精密的适配模块，拦截方法执行，全面把控系统运行状态。在方法执行前，它调用处理器槽的入口方法，记录关键指标，如调用次数、执行时间和错误数。方法执行结束后，它再次调用出口方法，记录结果，为后续决策提供依据。

StatisticSlot：数据之眼，洞察系统脉搏

StatisticSlot是Sentinel的灵魂，负责收集和统计方法调用数据。它准确捕捉调用次数、执行时间和错误数，绘制出系统运行状况的清晰图景。这些数据为限流、熔断和降级决策提供了坚实的基础。

DegradeSlot：安全卫士，抵御系统过载

DegradeSlot是Sentinel的另一根支柱，负责实施熔断和降级策略。当指标超出预设阈值时，它勇敢地触发熔断，暂停方法调用，直至系统恢复稳定。降级则将调用重定向到备用方法，确保系统在逆境中仍能正常运转。

Sentinel与OpenFeign的无缝联姻

Sentinel与OpenFeign的集成通过一个适配器类实现。这个适配器继承了Feign的Client，并实现了Sentinel的Processor接口。在OpenFeign调用微服务时，这个适配器首先介入，检查方法指标，及时触发熔断或降级，保障系统的平稳运行。

Sentinel：微服务安全的坚强后盾

Sentinel与OpenFeign的联手，为微服务系统筑起了一道坚固的防线，抵御过载、请求激增和其他潜在威胁。其限流、熔断和降级机制，为系统提供了主动保护，确保关键服务始终在线，满足业务需求。

代码示例：集成Sentinel与OpenFeign

import com.alibaba.csp.sentinel.adapter.spring.web.callback.WebCallbackManager;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.Rule;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import com.alibaba.csp.sentinel.util.StringUtil;
import feign.Feign;
import feign.Request;
import feign.Retryer;
import feign.hystrix.FallbackFactory;
import java.util.ArrayList;
import java.util.List;

public class SentinelOpenFeignConfiguration {

    private static final int TIMEOUT = 5000;

    // 配置限流规则
    static {
        List<Rule> flowRules = new ArrayList<>();
        Rule rule = new FlowRule("myService");
        // 限流阈值
        rule.setCount(10);
        flowRules.add(rule);
        FlowRuleManager.loadRules(flowRules);
    }

    // 配置熔断规则
    static {
        List<Rule> degradeRules = new ArrayList<>();
        DegradeRule rule = new DegradeRule("myService");
        // 熔断阈值
        rule.setCount(10);
        degradeRules.add(rule);
        DegradeRuleManager.loadRules(degradeRules);
    }

    // 注册自定义的Web回调
    public static void registerWebCallback() {
        WebCallbackManager.setUrlBlockHandler(new CustomUrlBlockHandler());
    }

    // Feign配置，注入Sentinel的注解和降级工厂
    public static Feign.Builder feignBuilder() {
        return Feign.builder().options(new Request.Options(TIMEOUT, TIMEOUT))
            .retryer(new Retryer.Default(100, 1000, 3))
            .target(interfaceClass, targetUrl);
    }

    // Sentinel 注解的示例
    @SentinelResource("myService")
    public interface MyService {

        String get();
    }

    // 降级工厂的示例
    public static class MyServiceFallbackFactory implements FallbackFactory<MyService> {

        @Override
        public MyService create(Throwable cause) {
            return () -> "服务降级";
        }
    }
}