使用分布式熔断器或限流
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
断路器注解,用于限流或融断控制
属性 | 描述 | 备注 |
---|---|---|
value | 断路器名字 | |
name | 断路器名字 | 两个属性互为别名,用一个即好 |
阀值不支持代码里写死,需要通过上面的配置实现。
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