使用分布式熔断器

生态 / Solon Cloud Breaker [传送]

1、情况简介

使用分布式熔断器进行限流控制（目前适配有：sentinel, guava, semaphore 三个插件）

2、添加配置（此配置可通过配置服务，动态更新）

solon.cloud.local:
  breaker:
    root: 100 #默认100 (Qps100 或 信号量为100；视插件而定)
    main: 150 
    
#此配置可以放到配置中心，例：
#solon.cloud.water:
#    server: "waterapi:9371"
#    config.load: "breaker.yml"

3、认识注解及属性

@CloudBreaker 断路器注解，用于限流或融断控制

阀值不支持代码里写死，需要通过上面的配置实现。

4、通过注解，添加埋点

//此处的注解埋点，名称与配置的断路器名称须一一对应
@CloudBreaker("test") //test 如果没有专门的阀值配置，默认会使用 root 的配置的阀值
@Controller
public class BreakerController {
    @Mapping("/breaker")
    public void breaker(){
        
    }
}

5、手动模式埋点

public class BreakerFilter implements Filter {
    @Override
    public void doFilter(Context ctx, FilterChain chain) throws Throwable {
        if (CloudClient.breaker() == null) {
            chain.doFilter(ctx);
        } else {
            //此处的埋点，名称与配置的断路器名称须一一对应
            try (AutoCloseable entry = CloudClient.breaker().entry("main")) {
                chain.doFilter(ctx);
            } catch (BreakerException ex) {
                throw new IllegalStateException("Request capacity exceeds limit");
            }
        }
    }
}

代码演示：

https://gitee.com/noear/solon-examples/tree/main/9.Solon-Cloud