微服务架构整理-(九springcloud实战之hystrix[2])

浦江之猿      2022-06-13     596

关键词:

SpringCloud实战之Hystrix [2]-自定义异常熔断处理

上文中,对异常处理是使用注解@HystrixCommand完成的,当然也可以不使用此注解来完成,我们可以自定义一个机制处理超时,抛出异常等情况。整个流程可以分为如下几步:

  • 定义一个类继承HystrixCommand,传入的泛型为目标函数返回的类型
  • 在自定义的类里覆盖getFallback方法实现熔断逻辑
  • 在自定义在run方法中调用远程服务
  • 在getFallback方法中调用getExecutionException方法获取服务抛出的异常

自定义熔断机制

这里给出一个案例,按照以上4个步骤,自定义一个类,如下所示:

//1,继承HystrixCommand,泛型为目标函数返回的类型
public class OrderHystrixCommand extends HystrixCommand<Product> 
    private RestTemplate restTemplate;
    private String url;
    public OrderHystrixCommand(Setter setter, RestTemplate restTemplate, String url) 
        super(setter);
        this.restTemplate = restTemplate;
        this.url = url;
    
    /**
     * 调用远程服务
     */
    @Override
    protected Product run() throws Exception 
    	//3,调用远程服务
        Product product = restTemplate.getForObject(url, Product.class);
        // 这里故意弄一个超时,强迫其服务降级,真正用的时候可以去掉
        try 
            Thread.sleep(4000);
         catch (InterruptedException e) 
            e.printStackTrace();
        
        return product;
    

    /**
     *2,覆盖getFallback方法,实现熔断逻辑,这里定义一个fake product 并返回
     * 降级方法:超时,异常,不可用等情况时调用
     */
    @Override
    public Product getFallback() 
    //4,如果服务断有异常,可以在此方法中拿到服务端抛出的异常。
        /* Throwable serviceException = super.getExecutionException();
        System.out.println("Exception from service provider : " + serviceException.getMessage());*/
        Product product = new Product();
        product.setId(0L);
        product.setName("A fake product");
        product.setPrice(new BigDecimal(0));
        return product;
    


测试

在目标方法中使用自定义的类实例调用execute/queue方法,其中execute是同步调用,而queue是异步调用。继续使用之前findById的例子,去掉@HystrixCommand 注解,当超出1.5秒(默认1秒)没有响应时,执行服务降级。这里设置超时时间用的是HystrixCommandProperties.Setter, 其原理同注解中的属性commandProperties一样。

同步调用

  @GetMapping(value = "/buy/id")
    public Product findById(@PathVariable Long id) 
        Product product = null;
        String url = "http://service-product/product/" + id;
        // 默认超时为1000,可能设成1500
        HystrixCommandProperties.Setter commandProperty = HystrixCommandProperties.Setter();
        commandProperty.withExecutionTimeoutInMilliseconds(1500);

        setter = com.netflix.hystrix.HystrixCommand.Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey(""));
        setter.andCommandPropertiesDefaults(commandProperty);
        OrderHystrixCommand orderHystrixCommand = new OrderHystrixCommand(
                setter,
                restTemplate, url);
        //同步调用        
        product = orderHystrixCommand.execute();
        System.out.println("success");
        return product;
    

异步调用

@GetMapping(value = "/buy/id")
    public Product findById(@PathVariable Long id) 
        Product product = null;
        String url = "http://service-product/product/" + id;
        // 默认超时为1000,可能设成1500
        HystrixCommandProperties.Setter commandProperty = HystrixCommandProperties.Setter();
        commandProperty.withExecutionTimeoutInMilliseconds(1500);

        setter = com.netflix.hystrix.HystrixCommand.Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey(""));
        setter.andCommandPropertiesDefaults(commandProperty);
        OrderHystrixCommand orderHystrixCommand = new OrderHystrixCommand(
                setter,
                restTemplate, url);
        //异步调用
        Future<Product> queue = orderHystrixCommand.queue();
        /**
         * 这里可以根据具体的需求加一些业务处理,将处理结果再与返程服务返回的结果进行整合
         */
        try 
            //阻塞式方法,一直等到拿到返回值为止
            product = queue.get();
         catch (Exception e) 
            e.printStackTrace();
         
        
        System.out.println("success");
        return product;
    

总结

使用自定义熔断处理机制没法处理消费者断的异常,例如findById函数中的业务逻辑有异常,是不会进入降级方法的,这里有别于使用注解的方法。关于Hystrix自定义异常熔断处理机制就介绍到这,大家根据项目的具体需求来衡量是否需要进行自定义。下一篇将介绍Hystrix的监控表盘。最后,希望本文能帮助大家,祝大家在IT之路上少走弯路,一路绿灯不堵车,测试一性通过,bug秒解!
源码下载

微服务架构整理-(七springcloud实战之resttemplate)(代码片段)

SpringCloud实战之RestTemplateGET请求getForEntitygetForObjectPOST请求postForEntitypostForObjectpostForLocationPUT请求DELETE请求总结RestTemplate不仅在SpringCloud中会使用,一般在服务之间相互调用的时候会使用此类。上一篇介绍Ribbon的时候通过在此类... 查看详情

微服务架构整理-(十springcloud实战之hystrix[3])(代码片段)

SpringCloud实战之Hystrix[3]-看版监控前言搭建Dashboard服务创建springboot工程添加依赖配置启动类添加配置文件引用Dashboard服务添加Hystrix依赖添加springboot服务监控依赖配置springboot监控接口的访问权限结果总结前言当需要查看服务的状... 查看详情

微服务架构整理-(十springcloud实战之hystrix[3])(代码片段)

SpringCloud实战之Hystrix[3]-看版监控前言搭建Dashboard服务创建springboot工程添加依赖配置启动类添加配置文件引用Dashboard服务添加Hystrix依赖添加springboot服务监控依赖配置springboot监控接口的访问权限结果总结前言当需要查看服务的状... 查看详情

微服务架构整理-(六springcloud实战之ribbon)

SpringCloud实战之Ribbon负责均衡介绍Ribbon概念Ribbon中的负载均衡算法Ribbon使用添加一个服务提供者添加Ribbon区别服务提供者访问服务提供者运行结果总结负责均衡介绍负载均衡分为硬件负载均衡和软件负载均衡。常用见的如下:... 查看详情

微服务架构整理-(八springcloud实战之hystrix[1])(代码片段)

SpringCloud实战之Hystrix[1]-基本用法前言Hystrix概念Hystrix使用添加依赖配置启动类添加熔断机制服务降级超时异常总结前言我们知道,在微服务架构中,每个服务都是独立运行,服务与服务之间通过注册中心彼此发现和消... 查看详情

微服务架构整理-(八springcloud实战之hystrix[1])(代码片段)

SpringCloud实战之Hystrix[1]-基本用法前言Hystrix概念Hystrix使用添加依赖配置启动类添加熔断机制服务降级超时异常总结前言我们知道,在微服务架构中,每个服务都是独立运行,服务与服务之间通过注册中心彼此发现和消... 查看详情

微服务架构整理-(十二springcloud实战之zuul网关)(代码片段)

SpringCloud实战之Zuul网关Zuul概念Zuul构建网关创建SpringBoot工程添加依赖添加注解添加配置文件基础配置注册Eureka添加路由规则Zuul请求过滤定义过虑逻辑请求结果Zuul路由规则总结Zuul概念Zuul是Netflix旗下的又一重要成员,是一个... 查看详情

微服务架构整理-(六springcloud实战之ribbon)(代码片段)

SpringCloud实战之Ribbon负责均衡介绍Ribbon概念Ribbon中的负载均衡算法Ribbon使用添加一个服务提供者添加Ribbon区别服务提供者访问服务提供者运行结果总结负责均衡介绍负载均衡分为硬件负载均衡和软件负载均衡。常用见的如下:... 查看详情

微服务架构整理-(十springcloud实战之hystrix[3])(代码片段)

SpringCloud实战之Hystrix[3]-看版监控前言搭建Dashboard服务创建springboot工程添加依赖配置启动类添加配置文件引用Dashboard服务添加Hystrix依赖添加springboot服务监控依赖配置springboot监控接口的访问权限结果总结前言当需要查看服务的状... 查看详情

微服务架构整理-(十一springcloud实战之openfeign)(代码片段)

SpringCloud实战之OpenFeignOpenFeign介绍实现消费者功能创建SpringBoot工程添加依赖添加注解声明服务在Controller中调用服务添加配置文件结果实现负载均衡功能实现熔断功能配置熔断开关实现回调函数获取异常信息总结OpenFeign介绍OpenFeig... 查看详情

微服务架构整理-(十二springcloud实战之zuul网关)(代码片段)

SpringCloud实战之Zuul网关Zuul概念Zuul构建网关创建SpringBoot工程添加依赖添加注解添加配置文件基础配置注册Eureka添加路由规则Zuul请求过滤定义过虑逻辑请求结果Zuul路由规则总结Zuul概念Zuul是Netflix旗下的又一重要成员,是一个... 查看详情

springcloud实战微服务之——微服务简介以及入门使用(代码片段)

微服务概述微服务是什么?微服务解决了什么问题?微服务有什么特点?单体架构是什么?一个归档包包含了应用所有功能的应用程序,我们通常称之为单体应用。架构单体应用的架构风格,我们称之为单... 查看详情

springcloud微服务安全实战_6-1_微服务之间的通讯安全之概述

   到目前为止已经实现了一个基于微服务的,前后端分离(这里我用的jquery做的,并不是真的前后端分离,因为我不会vue和angular所以没用)的架构。在网关上做了限流、认证、审计、授权等安全机制,在前端应用上... 查看详情

springcloud实战微服务之——微服务简介以及入门使用(代码片段)

微服务概述微服务是什么?微服务解决了什么问题?微服务有什么特点?单体架构是什么?一个归档包包含了应用所有功能的应用程序,我们通常称之为单体应用。架构单体应用的架构风格,我们称之为单... 查看详情

微服务之springcloud实战:springcloudeureka服务治理

服务治理  SpringCloudEureka是SpringCloudNetflix微服务套件的一部分,它基于NetflixEureka做了二次封装,主要完成微服务的服务治理功能,SpringCloud通过为Eureka增加了SpringBoot自动化配置,只需要简单的依赖和配置就可完成Eureka整合搭建... 查看详情

微服务springcloud+docker入门到高级实战

第一章课程介绍和学习路线1、微服务架构SpringCloud课程介绍简介:课程介绍和课程大纲讲解,讲课风格和重点内容理解技巧2、技术选型和学后水平简介:课程所需基础和技术选型讲解,学完课程可以到达怎样的程度,第二章架... 查看详情

微服务springcloud+docker入门到高级实战(目录)

 第一章课程介绍和学习路线1、微服务架构SpringCloud课程介绍 简介:课程介绍和课程大纲讲解,讲课风格和重点内容理解技巧2、技术选型和学后水平 简介:课程所需基础和技术选型讲解,学完课程可以到达怎样的程度,第二... 查看详情

推荐7个牛哄哄springcloud实战项目(代码片段)

把一个大型的单个应用程序和服务拆分为数个甚至数十个的支持微服务,这就是微服务架构的架构概念,通过将功能分解到各个离散的服务中以实现对解决方案的解耦。关于微服务相关的学习资料不多,而GitHub上的开源项目可以... 查看详情