• Hystrix 部署

    参考

    Java版本实现: github地址

    PHP版本实现: github地址

    实现

    Hystrix支持两种方式实现熔断降级功能：

    • 编程式

    • 声明式

    编程式

    在编程式实现中，基于Hystrix丰富的API，通过编码的方式实现断路器的设置。API要求用户将不同的外部交互封装成命令模式对象。在调用过程中，形成一层代理，Hystrix框架对命令对象执行周期接管，并根据窗口内获取到的状态报告决定断路器状态。

    • 添加核心依赖 hystrix-core 到pom.xml文件

    1. <dependency>
    2.  
    3. <groupId>com.netflix.hystrix</groupId>
    4.  
    5. <artifactId>hystrix-core</artifactId>
    6.  
    7. <version>1.5.18</version>
    8.  
    9. </dependency>

    • 包裹需要熔断处理的代码逻辑到Command类中

    1. static class CommandHello extends HystrixCommand<String> {
    2.  
    3. private final String name;
    4.  
    5. public CommandHello(String name) {
    6.  
    7. super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"))
    8.  
    9. .andCommandPropertiesDefaults(HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(3000)));
    10.  
    11. this.name = name;
    12.  
    13. }
    14.  
    15. @Override
    16.  
    17. protected String runTest() {
    18.  
    19. return "Hello " + name + "!";
    20.  
    21. }
    22.  
    23. // Default fallback method
    24.  
    25. public String getFallback() {
    26.  
    27. return "Fallback of Hello was triggered";
    28.  
    29. }
    30.  
    31. }

    • 初始化Command对象，并执行 execute() 方法。

    声明式

    顾名思义，通过配置声明的方式以达到以上方式同样的效果，这种方式对业务侵入小，无需编码自动植入代码功能，业务接受程度高。此方案需要引入依赖，并在main class中使用注释 EnableHystrix 激活该功能。

    • 添加核心依赖 hystrix-javanica 到pom.xml文件

    1. <dependency>
    2.  
    3. <groupId>com.netflix.hystrix</groupId>
    4.  
    5. <artifactId>hystrix-javanica</artifactId>
    6.  
    7. <version>x.y.z</version>
    8.  
    9. </dependency>

    • 使用@HystrixCommand修饰被监控方法，并提供兜底逻辑：

     

    •  
      在环境中引入 HystrixCommandAspect 注入切面，拦截所有带有HystrixCommand注释的方法，并生成其代理对象。业务调用无需调整，我
       
    

    spring-cloud-netflix-hystrix 依赖于 hystrix-javanica ，使能Hystrix开箱即用。自动配置代码见  
     

     
 
    1.  
    2. @HystrixCommand(fallbackMethod = "fallback_hello", commandProperties = {
    3.  
    4. @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1000")})
    5.  
    6. public String hello() throws InterruptedException {
    7.  
    8. System.out.println("Hello");
    9.  
    10. Thread.sleep(3000);
    11.  
    12. return "Welcome Hystrix";
    13.  
    14. }
    15.  
    16. private String fallback_hello() {
    17.  
    18. return "Request fails. It takes long time to response";
    19.  
    20. }
     

     

    Metrics桥接
     

    在Hystrix设计支持以plugin的方式桥接metrics到外部系统，该插件要求继承 com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisher 。
     

    样例地址 
     

    桥接后的metrics可统一导出到actuator端点，随后被Prometheus拉取到。
    
                
    
                    
    
                
    • 

                
  • 

                    相关阅读:
    
                    
【Matlab】数据插值                            
    
大数据Flink（七十三）：SQL的滚动窗口（TUMBLE）                            
    
strcpy常见的错误                            
    
IDEA设置背景为自定义照片                            
    
kube-ovn 固定（静态)地址                            
    
using 语句 - 确保正确使用可释放对象                            
    
【C#】数组string类型输出                            
    
DEJA_VU3D - Cesium功能集 之 059-腾讯地图纠偏                            
    
图片转world文档 Excel excel                            
    
目标检测算法实战综述                            
    
                        
                
    • 
                
  • 
                    原文地址：https://blog.csdn.net/qq_27229113/article/details/125405301
                
    •