Hystrix（自定义的实现熔断，降级）

最新推荐文章于 2022-08-14 20:54:39 发布

sunRest

最新推荐文章于 2022-08-14 20:54:39 发布

阅读量1.3k

点赞数

分类专栏： java springcloud

本文链接：https://blog.csdn.net/sunRest/article/details/103985824

版权

java 同时被 2 个专栏收录

15 篇文章

订阅专栏

springcloud

2 篇文章

订阅专栏

本文介绍如何使用HystrixCommand类实现熔断器功能，通过泛型和反射调用不同类的方法，并配置熔断规则，包括线程池、熔断器启用条件及超时时间。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

创建类继承 HystrixCommand类实现里面的方法：

@Component
public class HystrixFallback<T> extends HystrixCommand<T>{
	private Object cla;// 方法对象
	private Object[]  args; //参数 
	private String mname;//方法名
	private Class[]  patms;// 参数类型
	
	public HystrixFallback() {
		 super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("FallbackGroup"))
			        .andCommandPropertiesDefaults(HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(5000)));
		 
	}
	public HystrixFallback(Object cla,String mname,Class[] patms ,Object ... args)  {
		 super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey(cla.getClass().getName()))
					 .andThreadPoolPropertiesDefaults(   // 配置线程池
		                        HystrixThreadPoolProperties.Setter()
		                        .withCoreSize(10)  // 配置线程池里的线程数，设置足够多线程，以防未熔断却打满threadpool
		                )
					 .andCommandPropertiesDefaults(  // 配置熔断器
		                        HystrixCommandProperties.Setter()
		                        .withCircuitBreakerEnabled(true)  //  熔断器在整个统计时间内是否开启的阀值
		                        .withCircuitBreakerRequestVolumeThreshold(3)    // 至少有3个请求才进行熔断错误比率计算
		                        .withCircuitBreakerErrorThresholdPercentage(50)   //当出错率超过50%后熔断器启动
		                         .withMetricsRollingStatisticalWindowInMilliseconds(5000)   // 统计滚动的时间窗口
		                         .withExecutionTimeoutInMilliseconds(3000)  //熔断超时时间
		                         .withCircuitBreakerSleepWindowInMilliseconds(2000)   // 熔断器工作时间，超过这个时间，先放一个请求进去，成功的话就关闭熔断，失败就再等一段时间
							 ));
		 this.cla = cla;
		 this.args=args;
		 this.mname=mname;
		 this.patms=patms;
	}

	@Override
	public T run() throws Exception {
		Class[] argsClass  = null;
		if(patms!=null && patms.length>0){
			argsClass=patms;
		}else{
			argsClass= new Class[args.length];  
			for (int i = 0, j = args.length; i < j; i++) {  
		         argsClass[i] = args[i].getClass();
		    } 
		}
		Class<? extends Object> cs = cla.getClass();
		Method menthod = cs.getMethod(mname,argsClass);
		Object temp = menthod.invoke(cla,args);
		return (T) temp;
	}
	@Override
	public T getFallback() {
		System.err.println("熔断");
		//throw new SessionMissAccountException();
		return null;
	}
}