在微服务架构的实际开发中，限流熔断是避免服务雪崩、保障系统稳定性的核心手段。Sentinel和Hystrix作为主流的熔断限流组件，都提供了基础的原生注解支持，但原生注解的参数多为固定配置，难以应对多环境、多接口的动态规则需求。通过自定义注解配合反射机制，可以灵活读取注解上的配置参数，动态适配Sentinel或Hystrix的规则配置，实现更通用的限流熔断保护逻辑。
自定义注解的定义
首先需要定义限流熔断相关的自定义注解，注解中可以包含限流阈值、熔断时间窗口、最小请求数等核心参数，同时可以添加一个标识字段用于区分是适配Sentinel还是Hystrix。
以下是限流熔断自定义注解的示例代码：
import java.lang.annotation.*;
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface FlowFuseProtect {
// 限流阈值，默认10
int limitCount() default 10;
// 熔断触发的最小请求数，默认5
int minRequestCount() default 5;
// 熔断时间窗口，单位秒，默认10
int fuseTimeWindow() default 10;
// 适配组件类型，1代表Sentinel，2代表Hystrix
int componentType() default 1;
}
反射读取注解参数的核心逻辑
自定义注解定义完成后，需要通过反射在运行时获取方法上的注解属性，提取出配置的参数值，再根据componentType的不同，分别适配Sentinel或Hystrix的规则配置逻辑。
反射读取注解的通用工具类代码如下：
import java.lang.reflect.Method;
public class AnnotationParser {
public static FlowFuseProtect parseAnnotation(Class<?> targetClass, String methodName, Class<?>... parameterTypes) throws Exception {
Method method = targetClass.getMethod(methodName, parameterTypes);
if (method.isAnnotationPresent(FlowFuseProtect.class)) {
return method.getAnnotation(FlowFuseProtect.class);
}
return null;
}
}
适配Sentinel的参数配置
当componentType为1时，需要将注解参数转换为Sentinel的流控规则和熔断规则。Sentinel的规则配置支持通过FlowRule和DegradeRule类动态设置。
Sentinel规则适配的代码如下：
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;
import java.util.ArrayList;
import java.util.List;
public class SentinelConfigAdapter {
public static void adaptRule(String resourceName, FlowFuseProtect annotation) {
// 配置流控规则
List<FlowRule> flowRules = new ArrayList<>();
FlowRule flowRule = new FlowRule();
flowRule.setResource(resourceName);
flowRule.setCount(annotation.limitCount());
flowRule.setGrade(1); // 1代表QPS限流
flowRules.add(flowRule);
FlowRuleManager.loadRules(flowRules);
// 配置熔断规则
List<DegradeRule> degradeRules = new ArrayList<>();
DegradeRule degradeRule = new DegradeRule();
degradeRule.setResource(resourceName);
degradeRule.setGrade(0); // 0代表异常比例熔断
degradeRule.setCount(0.5); // 异常比例阈值
degradeRule.setTimeWindow(annotation.fuseTimeWindow());
degradeRule.setMinRequestAmount(annotation.minRequestCount());
degradeRules.add(degradeRule);
DegradeRuleManager.loadRules(degradeRules);
}
}
适配Hystrix的参数配置
当componentType为2时，需要将注解参数转换为Hystrix的命令属性配置，Hystrix通过HystrixCommandProperties类设置熔断和限流相关参数。
Hystrix规则适配的代码如下：
import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import com.netflix.hystrix.HystrixCommandProperties;
import com.netflix.hystrix.HystrixThreadPoolProperties;
public class HystrixConfigAdapter {
public static HystrixCommand.Setter adaptSetter(String groupKey, FlowFuseProtect annotation) {
return HystrixCommand.Setter
.withGroupKey(HystrixCommandGroupKey.Factory.asKey(groupKey))
.andCommandPropertiesDefaults(HystrixCommandProperties.Setter()
.withExecutionTimeoutInMilliseconds(annotation.fuseTimeWindow() * 1000)
.withCircuitBreakerRequestVolumeThreshold(annotation.minRequestCount())
.withCircuitBreakerSleepWindowInMilliseconds(annotation.fuseTimeWindow() * 1000)
.withCircuitBreakerErrorThresholdPercentage(50))
.andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter()
.withCoreSize(annotation.limitCount()));
}
}
完整使用示例
最后在业务方法上添加自定义注解，在方法调用前通过反射读取注解参数，再调用对应的适配方法完成规则配置即可。
使用示例代码如下：
public class OrderService {
@FlowFuseProtect(limitCount = 20, minRequestCount = 10, fuseTimeWindow = 15, componentType = 1)
public String createOrder(String orderId) {
try {
// 反射读取注解参数
FlowFuseProtect annotation = AnnotationParser.parseAnnotation(this.getClass(), "createOrder", String.class);
if (annotation != null) {
// 适配Sentinel规则
SentinelConfigAdapter.adaptRule("createOrder", annotation);
}
} catch (Exception e) {
e.printStackTrace();
}
// 业务逻辑
return "订单创建成功，订单号：" + orderId;
}
}
注意事项
- 反射操作会有一定的性能开销，建议将读取到的注解参数做缓存处理，避免每次方法调用都重复反射解析。
- Sentinel和Hystrix的参数含义存在差异，适配时需要做好参数映射，避免配置错误导致限流熔断逻辑不符合预期。
- 自定义注解的参数默认值需要设置合理，避免未配置参数时出现规则异常。