@RestControllerpublic class SentinelController {
  @RequestMapping("/sentinel1")  public String sentinel1(){    //模拟一次网络延时    try {      TimeUnit.SECONDS.sleep(1);    } catch (InterruptedException e) {      e.printStackTrace();    }    return "sentinel1";  }  @RequestMapping("/sentinel2")  public String sentinel2(){    return "测试高并发下的问题";  }}  

  tomcat:    threads:      max: 10 #tomcat的最大并发值修改为10,

<dependency>  <groupId>com.alibaba.cloud</groupId>  <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>

@RestControllerpublic class SentinelController {
  @RequestMapping("/sentinel1")  public String sentinel1(){    //模拟一次网络延时    try {      TimeUnit.SECONDS.sleep(1);    } catch (InterruptedException e) {      e.printStackTrace();    }    return "sentinel1";  }  @RequestMapping("/sentinel2")  public String sentinel2(){    return "测试高并发下的问题";  }}

spring:  cloud:    sentinel:       transport:         port: 9999 #跟控制台交流的端口,随意指定一个未使用的端口即可         dashboard: localhost:8080 # 指定控制台服务的地址

# 直接使用jar命令启动项目(控制台本身是一个SpringBoot项目) java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard-1.8.0.jar

spring:  cloud:    sentinel:      web-context-unify: false

@Service@Slf4jpublic class TraceServiceImpl {    @SentinelResource(value = "tranceService")    public void tranceService(){        log.info("调用tranceService方法");    }}

@RestControllerpublic class TraceController {    @Autowired    private TraceServiceImpl traceService;    @RequestMapping("/trace1")    public String trace1(){        traceService.tranceService();        return "trace1";    }    @RequestMapping("/trace2")    public String trace2(){        traceService.tranceService();        return "trace2";    }}

@RestController@Slf4jpublic class FallBackController {    @RequestMapping("/fallBack1")    public String fallBack1(){        try {            log.info("fallBack1执行业务逻辑");            //模拟业务耗时            TimeUnit.SECONDS.sleep(1);        } catch (InterruptedException e) {            e.printStackTrace();        }        return "fallBack1";    }}

  @RequestMapping("/fallBack3")  public String fallBack3(String name){    log.info("fallBack3执行业务逻辑");    if("xiaolin".equals(name)){      throw new RuntimeException();    }    return "fallBack3";  }

@RestController@Slf4jpublic class HotSpotController {    @RequestMapping("/hotSpot1")    @SentinelResource(value = "hotSpot1")    public String hotSpot1(Long productId){        log.info("访问编号为:{}的商品",productId);        return "hotSpot1";    }}

@Componentpublic class RequestOriginParserDefinition implements RequestOriginParser {    @Override    public String parseOrigin(HttpServletRequest request) {        /**         *  定义从请求的什么地方获取来源信息         *  比如我们可以要求所有的客户端需要在请求头中携带来源信息         */        String serviceName = request.getParameter("serviceName");        return serviceName;    }}

@RestController@Slf4jpublic class AuthController {    @RequestMapping("/auth1")  public String auth1(String serviceName){    log.info("应用:{},访问接口",serviceName);    return "auth1";  }}

@Componentpublic class ExceptionHandlerPage implements BlockExceptionHandler {  @Override  public void handle(HttpServletRequest request, HttpServletResponse response, BlockException e) throws Exception {    response.setContentType("application/json;charset=utf-8");    ResultData data = null;    if (e instanceof FlowException) {      data = new ResultData(-1, "接口被限流了");    } else if (e instanceof DegradeException) {      data = new ResultData(-2, "接口被降级了");    }else if (e instanceof ParamFlowException) {      data = new ResultData(-3, "参数限流异常");    }else if (e instanceof AuthorityException) {      data = new ResultData(-4, "授权异常");    }else if (e instanceof SystemBlockException) {      data = new ResultData(-5, "接口被降级了...");    }    response.getWriter().write(JSON.toJSONString(data));  }}@Data@AllArgsConstructor//全参构造@NoArgsConstructor//无参构造class ResultData {  private int code;  private String message;}

public class FilePersistence implements InitFunc {    @Value("${spring.application.name}")    private String appcationName;
    @Override    public void init() throws Exception {        String ruleDir = System.getProperty("user.home") + "/sentinel-rules/" + appcationName;        String flowRulePath = ruleDir + "/flow-rule.json";        String degradeRulePath = ruleDir + "/degrade-rule.json";        String systemRulePath = ruleDir + "/system-rule.json";        String authorityRulePath = ruleDir + "/authority-rule.json";        String paramFlowRulePath = ruleDir + "/param-flow-rule.json";
        this.mkdirIfNotExits(ruleDir);        this.createFileIfNotExits(flowRulePath);        this.createFileIfNotExits(degradeRulePath);        this.createFileIfNotExits(systemRulePath);        this.createFileIfNotExits(authorityRulePath);        this.createFileIfNotExits(paramFlowRulePath);
        // 流控规则        ReadableDataSource<String, List<FlowRule>> flowRuleRDS = new FileRefreshableDataSource<>(                flowRulePath,                flowRuleListParser        );        FlowRuleManager.register2Property(flowRuleRDS.getProperty());        WritableDataSource<List<FlowRule>> flowRuleWDS = new FileWritableDataSource<>(                flowRulePath,                this::encodeJson        );        WritableDataSourceRegistry.registerFlowDataSource(flowRuleWDS);
        // 降级规则        ReadableDataSource<String, List<DegradeRule>> degradeRuleRDS = new FileRefreshableDataSource<>(                degradeRulePath,                degradeRuleListParser        );        DegradeRuleManager.register2Property(degradeRuleRDS.getProperty());        WritableDataSource<List<DegradeRule>> degradeRuleWDS = new FileWritableDataSource<>(                degradeRulePath,                this::encodeJson        );        WritableDataSourceRegistry.registerDegradeDataSource(degradeRuleWDS);
        // 系统规则        ReadableDataSource<String, List<SystemRule>> systemRuleRDS = new FileRefreshableDataSource<>(                systemRulePath,                systemRuleListParser        );        SystemRuleManager.register2Property(systemRuleRDS.getProperty());        WritableDataSource<List<SystemRule>> systemRuleWDS = new FileWritableDataSource<>(                systemRulePath,                this::encodeJson        );        WritableDataSourceRegistry.registerSystemDataSource(systemRuleWDS);
        // 授权规则        ReadableDataSource<String, List<AuthorityRule>> authorityRuleRDS = new FileRefreshableDataSource<>(                authorityRulePath,                authorityRuleListParser        );        AuthorityRuleManager.register2Property(authorityRuleRDS.getProperty());        WritableDataSource<List<AuthorityRule>> authorityRuleWDS = new FileWritableDataSource<>(                authorityRulePath,                this::encodeJson        );        WritableDataSourceRegistry.registerAuthorityDataSource(authorityRuleWDS);
        // 热点参数规则        ReadableDataSource<String, List<ParamFlowRule>> paramFlowRuleRDS = new FileRefreshableDataSource<>(                paramFlowRulePath,                paramFlowRuleListParser        );        ParamFlowRuleManager.register2Property(paramFlowRuleRDS.getProperty());        WritableDataSource<List<ParamFlowRule>> paramFlowRuleWDS = new FileWritableDataSource<>(                paramFlowRulePath,                this::encodeJson        );        ModifyParamFlowRulesCommandHandler.setWritableDataSource(paramFlowRuleWDS);    }
    private Converter<String, List<FlowRule>> flowRuleListParser = source -> JSON.parseObject(            source,            new TypeReference<List<FlowRule>>() {            }    );    private Converter<String, List<DegradeRule>> degradeRuleListParser = source -> JSON.parseObject(            source,            new TypeReference<List<DegradeRule>>() {            }    );    private Converter<String, List<SystemRule>> systemRuleListParser = source -> JSON.parseObject(            source,            new TypeReference<List<SystemRule>>() {            }    );
    private Converter<String, List<AuthorityRule>> authorityRuleListParser = source -> JSON.parseObject(            source,            new TypeReference<List<AuthorityRule>>() {            }    );
    private Converter<String, List<ParamFlowRule>> paramFlowRuleListParser = source -> JSON.parseObject(            source,            new TypeReference<List<ParamFlowRule>>() {            }    );
    private void mkdirIfNotExits(String filePath) throws IOException {        File file = new File(filePath);        if (!file.exists()) {            file.mkdirs();        }    }
    private void createFileIfNotExits(String filePath) throws IOException {        File file = new File(filePath);        if (!file.exists()) {            file.createNewFile();        }    }    private <T> String encodeJson(T t) {        return JSON.toJSONString(t);    }}