如何基于 Nacos 和 Sentinel ，實現灰度路由和流量防護一體化

• 封裝遠程配置中心和本地規則文件的讀取邏輯，即優先讀取遠程配置，如果不存在或者規則錯誤，則讀取本地規則文件。動態實現遠程配置中心對于規則的熱刷新
• 封裝NacosDataSource和ApolloDataSource，支持Nacos和Apollo兩個遠程配置中心，零代碼實現Sentinel功能。更多的遠程配置中心，請參照Sentinel官方的DataSource并自行集成
• 支持原生的流控規則、降級規則、授權規則、系統規則、熱點參數流控規則
• 支持擴展LimitApp的機制，通過動態的Http Header方式實現組合式防護機制，包括基于服務名、基于灰度組、基于灰度版本、基于灰度區域、基于機器地址和端口等防護機制，支持自定義任意的業務參數組合實現該功能，例如，根據傳入的微服務灰度版本號+用戶名，組合在一起進行熔斷
• 支持微服務側Actuator、Swagger和Rest三種方式的規則寫入
• 支持控制臺側基于微服務名的Actuator、Swagger和Rest三種方式的批量規則寫入
• 支持開關關閉上述功能spring.application.strategy.sentinel.enabled=true，默認是關閉的

環境搭建及依賴引入

<dependency>
    <groupId>com.nepxion</groupId>
    <artifactId>discovery-plugin-strategy-starter-service-sentinel</artifactId>
    <version>${discovery.version}</version>
</dependency>
<dependency>
    <groupId>com.nepxion</groupId>
    <artifactId>discovery-plugin-strategy-sentinel-starter-nacos</artifactId>
    <!-- <artifactId>discovery-plugin-strategy-sentinel-starter-apollo</artifactId> -->
    <version>${discovery.version}</version>
</dependency>

原生Sentinel注解

@RestController
@ConditionalOnProperty(name = DiscoveryConstant.SPRING_APPLICATION_NAME, havingValue = "discovery-guide-service-b")
public class BFeignImpl extends AbstractFeignImpl implements BFeign {
    private static final Logger LOG = LoggerFactory.getLogger(BFeignImpl.class);
    @Override
    @SentinelResource(value = "sentinel-resource", blockHandler = "handleBlock", fallback = "handleFallback")
    public String invoke(@PathVariable(value = "value") String value) {
        value = doInvoke(value);
        LOG.info("調用路徑：{}", value);
        return value;
    }
    public String handleBlock(String value, BlockException e) {
        return value + "-> B server sentinel block, cause=" + e.getClass().getName() + ", rule=" + e.getRule() + ", limitApp=" + e.getRuleLimitApp();
    }
    public String handleFallback(String value) {
        return value + "-> B server sentinel fallback";
    }
}

原生Sentinel規則

1. Nacos的Key格式：Group為元數據中配置的[組名]，Data Id為[服務名]-[規則類型]
2. Apollo的Key格式：[組名]-[服務名]-[規則類型]

流控規則

[
    {
        "resource": "sentinel-resource",
        "limitApp": "default",
        "grade": 1,
        "count": 1,
        "strategy": 0,
        "refResource": null,
        "controlBehavior": 0,
        "warmUpPeriodSec": 10,
        "maxQueueingTimeMs": 500,
        "clusterMode": false,
        "clusterConfig": null
    }
]

降級規則

[
    {
        "resource": "sentinel-resource",
        "limitApp": "default",
        "count": 2,
        "timeWindow": 10,
        "grade": 0,
        "passCount": 0
    }
]

授權規則

[
    {
        "resource": "sentinel-resource",
        "limitApp": "discovery-guide-service-a",
        "strategy": 0
    }
]

系統規則

[
    {
        "resource": null,
        "limitApp": null,
        "highestSystemLoad": -1.0,
        "highestCpuUsage": -1.0,
        "qps": 200.0,
        "avgRt": -1,
        "maxThread": -1
    }
]

熱點參數流控規則

[
    {
        "resource": "sentinel-resource",
        "limitApp": "default",
        "grade": 1,
        "paramIdx": 0,
        "count": 1,
        "controlBehavior": 0,
        "maxQueueingTimeMs": 0,
        "burstCount": 0,
        "durationInSec": 1,
        "paramFlowItemList": [],
        "clusterMode": false
    }
]

基于灰度路由和Sentinel-LimitApp擴展的防護機制

基于服務名的防護機制

spring.application.strategy.service.sentinel.request.origin.key=n-d-service-id

[
    {
        "resource": "sentinel-resource",
        "limitApp": "discovery-guide-service-a",
        "strategy": 0
    }
]

基于灰度組的防護機制

spring.application.strategy.service.sentinel.request.origin.key=n-d-service-group

[
    {
        "resource": "sentinel-resource",
        "limitApp": "my-group",
        "strategy": 0
    }
]

基于灰度版本的防護機制

spring.application.strategy.service.sentinel.request.origin.key=n-d-service-version

[
    {
        "resource": "sentinel-resource",
        "limitApp": "1.0",
        "strategy": 0
    }
]

基于灰度區域的防護機制

spring.application.strategy.service.sentinel.request.origin.key=n-d-service-region

[
    {
        "resource": "sentinel-resource",
        "limitApp": "dev",
        "strategy": 0
    }
]

基于機器地址和端口的防護機制

spring.application.strategy.service.sentinel.request.origin.key=n-d-service-address

[
    {
        "resource": "sentinel-resource",
        "limitApp": "192.168.0.88:8081,192.168.0.88:8082",
        "strategy": 0
    }
]

自定義業務參數的組合式防護機制

// 版本號+用戶名，實現組合式熔斷
public class MyServiceSentinelRequestOriginAdapter extends DefaultServiceSentinelRequestOriginAdapter {
    @Override
    public String parseOrigin(HttpServletRequest request) {
        String version = request.getHeader(DiscoveryConstant.N_D_SERVICE_VERSION);
        String user = request.getHeader("user");
        return version + "&" + user;
    }
}

@Bean
public ServiceSentinelRequestOriginAdapter ServiceSentinelRequestOriginAdapter() {
    return new MyServiceSentinelRequestOriginAdapter();
}

[
    {
        "resource": "sentinel-resource",
        "limitApp": "1.0&zhangsan",
        "strategy": 0
    }
]

• 當傳遞的Http Header中user=zhangsan，當全鏈路調用中，API網關負載均衡discovery-guide-service-a服務到1.0版本后再去調用discovery-guide-service-b服務，最終調用成功

• 當傳遞的Http Header中user=lisi，不滿足條件，最終調用在discovery-guide-service-b服務端被拒絕掉

• 當傳遞的Http Header中user=zhangsan，滿足條件之一，當全鏈路調用中，API網關負載均衡discovery-guide-service-a服務到1.1版本后再去調用discovery-guide-service-b服務，不滿足version=1.0的條件，最終調用在discovery-guide-service-b服務端被拒絕掉

基于Swagger的Sentinel規則推送

基于單個服務實例的Sentinel規則推送

基于服務名對應的多個服務實例的Sentinel規則推送