博客

一、引入依赖

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

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

二、在nacos中创建限流配置，Data ID和Group都可以自己随便写，配置格式我使用json

各配置项含义如下：

https://github.com/alibaba/Sentinel/wiki/%E5%A6%82%E4%BD%95%E4%BD%BF%E7%94%A8

三、在nacos中创建熔断降级配置，和限流的一样Data ID和Group都可以自己随便写，配置格式使用json

但是配置参数是不一样的，具体含义如下：

四、在application.yml中配置读取nacos信息，配置详细可以看注释

server:
  port: 8083  #服务端口
spring:
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848  #nacos服务地址
    sentinel:
      transport:
        dashboard: 127.0.0.1:8949 #sentinel dashboard地址
      datasource:
        flowDB:      #名称随意取
          nacos:
            server-addr: 127.0.0.1:8848   #nacos地址
            data-id : sentinel            #nacos配置中设置的data-id
            group-id: DEFAULT_GROUP       #nacos配置中设置的group-id
            data-type: json               #nacos配置中设置的数据类型
            rule-type: flow               #指定为限流规则
        degradeDB:
          nacos:
            server-addr: 127.0.0.1:8848
            data-id: sentinel-degrade
            group-id: DEFAULT_GROUP
            data-type: json
            rule-type: degrade            #指定为熔断降级规则
  application:
    name: stock-server #服务命称

五、全局流控异常返回处理

@Component
public class SentinelConfig implements BlockExceptionHandler {
    @Override
    public void handle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, BlockException e) throws Exception {
        Map map = new HashMap();
        if(e instanceof FlowException){
            map.put("code","900");
            map.put("msg","你被流控了！");
        }else if(e instanceof DegradeException){
            map.put("code","901");
            map.put("msg","你被降级了！");
        }else{
            map.put("code","902");
            map.put("msg",e.getMessage());
        }
        httpServletResponse.setHeader("content-type","application/json;charset=UTF-8");
        PrintWriter writer = httpServletResponse.getWriter();
        writer.print(map);
        writer.flush();
        writer.close();
    }
}

六、逻辑代码

  
    @RequestMapping("reduce")
    public String reduce(){
        return "库存减一 "+dateFormat.format(new Date());
    }

 
    @RequestMapping("reduce1")
    public String reduce1(@RequestParam("orderId")String orderId){
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "orderId="+orderId+",库存减一 "+dateFormat.format(new Date());
    }

七、访问访问后，可以在sentinel控制台看到我们在nacos中配置的流控、熔断规则已经配置好了，但是存在的一个问题就是，在sentinel控制台修改规则后，nacos不会更新，即下次启动sentinel还是读取nacos中的配置，而不是修改后的。要解决这个问题，就需要修改源码了。