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

Posted 浦江之猿

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了微服务架构整理-(九SpringCloud实战之Hystrix [2])相关的知识,希望对你有一定的参考价值。

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实战之Hystrix [2])的主要内容,如果未能解决你的问题,请参考以下文章

微服务架构整理-(七SpringCloud实战之RestTemplate)

微服务架构整理-(七SpringCloud实战之RestTemplate)

微服务架构整理-(八SpringCloud实战之Hystrix [1])

微服务架构整理-(八SpringCloud实战之Hystrix [1])

微服务架构整理-(十一SpringCloud实战之OpenFeign)

微服务架构整理-(十一SpringCloud实战之OpenFeign)