【最小demo】 分布式系统的流量防卫兵 Sentinel 服务限流 熔断降级

参照 超详细的Sentinel入门

重头戏在Sentinel的管理控制台，管理控制台提供了很多实用的功能

            com.alibaba.csp
            sentinel-core
            1.8.1
        

package com.example.sentinel;

import com.alibaba.csp.sentinel.Entry;
import com.alibaba.csp.sentinel.SphU;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

public class SentinelTest {

    public static void main(String[] args) {
        initFlowRules();
        //首先需要定义一个资源entry，
        // 然后用SphU.entry("HelloWorld")和entry.exit()把需要流量控制的代码包围起来
        while (true) {
            Entry entry = null;
            try {
                entry = SphU.entry("HelloWorld");
                //10ms的时候 会block 如果qps不超过10次，可以一直正常运行
                TimeUnit.MILLISECONDS.sleep(10);
                
                System.out.println("hello world");
                
            } catch (BlockException | InterruptedException e1) {
                
                System.out.println("block!");
                
            } finally {
                if (entry != null) {
                    entry.exit();
                }
            }
        }

    }

    

    private static void initFlowRules(){
        List rules = new ArrayList<>();
        FlowRule rule = new FlowRule();
        rule.setResource("HelloWorld");
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        // Set limit QPS to 20.
        rule.setCount(20);
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
    }
}

1.资源的定义，可以是一段代码片段

从 SphU.entry(“HelloWorld”); 开始，标注资源的名称是HelloWorld
从 entry.exit(); 结束

2.initFlowRules()就是对这个资源方法问限流，比如说1秒钟限制最大的请求数不超过10，如果超过，抛出异常 BlockException

定义规则 FlowRule
指定 限流的资源 rule.setResource(“HelloWorld”);
指定降级规则 setGrade
FlowRuleManager 启动这个rule规则