Hystrix实现Timeout降级

短命女 2023-01-01 03:49 141阅读 0赞

本篇配置类及其他代码可参考[《Hystrix使用fallback完成消费降级》][Hystrix_fallback]

*  Feign中添加测试方法  
    传入秒数，线程会等待传入秒数的时间，然后返回端口号

@Override
    public String retry(@RequestParam(name = "timeout") int timeout) { 
        while (--timeout >= 0) { 
            try { 
                Thread.sleep(1000);
            } catch (InterruptedException e) { 
            }
        }
        log.info("retry " + port);
        return port;
    }

*  Fallback

@Override
    public String retry(@RequestParam(name = "timeout") int timeout) { 
        return "You are late !";
    }

*  修改配置文件

hystrix:
      command:
        default:
          execution:
            isolation:
              thread:
                interruptOnFutureCancel: true # 取消的时候终止线程
                interruptOnTimeout: true # 超时以后终止线程
                timeoutInMilliseconds: 2000 # 超时时间
            timeout:
              enabled: true # 开启全局超时
          fallback:
            enabled: true

然后我们启动测试类，先传入1s，调用`localhost:50000/timeout?timeout=1`，能看到正常返回了Feign的端口号  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70]

然后传入2s，调用`localhost:50000/timeout?timeout=2`  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70 1]  
会看到触发了Timeout降级！

*  拓展1

demo中我们是配置的全局Timeout的降级，如果我们只想配置部分方法，将配置文件中的`default`修改为对应函数名即可，例如：

hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=2000

修改为：

hystrix.command.MyService#retry(Integer).execution.isolation.thread.timeoutInMilliseconds=2000

*  拓展2  
    我们还可以通过注解的形式，完成配置

@GetMapping("/timeout")
    @HystrixCommand(
            fallbackMethod = "timeoutFallback",
            commandProperties = { 
               @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value="3000")
            }
    )
    public String timeout2(Integer timeout) { 
        return myService.retry(timeout);
    }
    
    ublic String timeoutFallback(Integer timeout) { 
        return "success";
    }

[Hystrix_fallback]: https://jiandansuifeng.blog.csdn.net/article/details/112003533
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70]: /images/20221120/90dde2c02c2548f09f15a933ef3d1642.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70 1]: /images/20221120/64f1dc92f8f147e28df8acae6bb9df2c.png