本文主要是介绍Hystrix-熔断测试代码-通过测试，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
Hystrix-熔断测试代码-通过测试package test;import com.netflix.hystrix.*;import java.util.Random;public class GetOrderCircuitBreakerCommand extends HystrixCommand<String> {public GetOrderCircuitBreakerCommand(String name) {super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ThreadPoolTestGroup")).andCommandKey(HystrixCommandKey.Factory.asKey("testCommandKey")).andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey(name)).andCommandPropertiesDefaults(HystrixCommandProperties.Setter().withCircuitBreakerEnabled(true)//默认是true，本例中为了展现该参数.withCircuitBreakerForceOpen(false)//默认是false，本例中为了展现该参数.withCircuitBreakerForceClosed(false)//默认是false，本例中为了展现该参数.withCircuitBreakerErrorThresholdPercentage(5)//(1)错误百分比超过5%.withCircuitBreakerRequestVolumeThreshold(10)//(2)10s以内调用次数10次，同时满足(1)(2)熔断器打开.withCircuitBreakerSleepWindowInMilliseconds(5000)//隔5s之后，熔断器会尝试半开(关闭)，重新放进来请求
// .withExecutionTimeoutInMilliseconds(1000)).andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter().withMaxQueueSize(10) //配置队列大小.withCoreSize(2) // 配置线程池里的线程数));}@Overrideprotected String run() throws Exception {Random rand = new Random();//模拟错误百分比(方式比较粗鲁但可以证明问题)if (1 == rand.nextInt(2)) {
// System.out.println("make exception");throw new Exception("make exception");}return "running: ";}@Overrideprotected String getFallback() {
// System.out.println("FAILBACK");return "fallback: ";}public static void testCircuitBreaker() throws Exception {for (int i = 0; i < 25; i++) {Thread.sleep(500);HystrixCommand<String> command = new GetOrderCircuitBreakerCommand("testCircuitBreaker");String result = command.execute();//本例子中从第11次，熔断器开始打开System.out.println("call times:" + (i + 1) + " result:" + result + " isCircuitBreakerOpen: " + command.isCircuitBreakerOpen());//本例子中5s以后，熔断器尝试关闭，放开新的请求进来}}public static void main(String[] args) throws Exception {testCircuitBreaker();}}
这篇关于Hystrix-熔断测试代码-通过测试的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
