使用分布式熔断器
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("test") //没有专门的阀值配置,默认使用 root 的值
@Controller
public class BreakerController {
@Mapping("/breaker")
public void breaker(){
}
}
4、手动模式埋点
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