Solon

使用分布式熔断器

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

1、添加配置(此配置可通过配置服务,动态更新)

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

2、通过注解,添加埋点

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

3、手动模式埋点

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