熔断器简介

在微服务架构中，服务被拆分成一个个的服务，服务与服务之间可以通过RPC相互调用，在SpringCloud中可以用RestTemplate + Ribbon和 Feign来调用，为保证其高可用，单个服务通常会集群部署。由于网络或自身原因，服务并不能保证100%可用，如果单个服务出现问题， 调用这个服务就会出现线程阻塞，此时若有大量请求涌入，Servlet容器的线程资源会被消耗完毕，导致服务瘫痪。服务与服务的依赖性，故障会传播， 会对整个微服务系统造成灾难性的严重后果，这就是服务故障的雪崩效应。

如果下图所示：A作为服务提供者，B为A的服务消费者，C和D是B的服务消费者。A不可用引起了B的不可用，并将不可用像滚雪球一样放大到C和D时，雪崩效应就形成了。

较底层的的服务如果出现故障，会导致连锁故障。当对特定的服务的调用不可用达到一个阀值(Hystrix是5秒20次)，熔断器将会被打开。

熔断器打开后，通过fallback方法可以直接返回一个固定值。

Ribbon中使用熔断器

添加依赖

打开之前的eureka-consumer-ribbon项目，在pom.xml中添加依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    <version>2.1.3.RELEASE</version>
</dependency>

在Application中增加@EnableHystrix注解

package com.springcloud.bh;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;

@EnableHystrix
@SpringBootApplication
@EnableDiscoveryClient
public class EurekaConsumerRibbonApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaConsumerRibbonApplication.class, args);
    }
}

在Service中增加@HystrixCommand注解

在Ribbon调用方法上增加@HystrixCommand注解，并指定fallbackMethod熔断方法。

package com.springcloud.bh.service;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class AdminService {

   @Autowired
   private RestTemplate restTemplate;

   @HystrixCommand(fallbackMethod ="hiError" )
   public String sayHi(String message)
   {
       return restTemplate.getForObject("http://eureka-client/hi?message="+message,String.class);
   }

   public String hiError(String message)
   {
      return String.format("你的消息是：%s ，但是请求连接失败！",message);
   }

}

测试熔断器 此时我们关闭服务提供者，再次请求http://localhost:8764/hi?message=hi,Ribbon浏览器会显示

你的消息是:hi,Ribbon，但是请求连接失败！

说明在Ribbon中成功实现了使用Hystrix熔断器成功熔断服务请求。

Feign中使用熔断器

Feign是自带熔断器的，但是默认是关闭的。需要在配置文件中打开它。打开之前的eureka-consumer-feign项目，在配置文件中增加以下代码

feign:
  hystrix:
    enabled: true  #feign自带熔断器，开启服务熔断

在Service中增加fallback指定类

package com.springcloud.bh.service;

import com.springcloud.bh.service.hystrix.AdminServiceHystrix;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

/**
 *  @FeignClient 注解中value为服务提供者的名字,fallback为服务熔断类
 */
@FeignClient(value = "eureka-client",fallback = AdminServiceHystrix.class)
public interface AdminService {
    @GetMapping("hi")
    public String sayHi(@RequestParam("message")String message);  //需使用@RequestParam，否则报405错误
}

创建熔断器类并实现对应的Feign接口

package com.springcloud.bh.service.hystrix;

import com.springcloud.bh.service.AdminService;
import org.springframework.stereotype.Component;

/**
 * 熔断器
 */
@Component
public class AdminServiceHystrix implements AdminService {
    @Override
    public String sayHi(String message) {
        return String.format("你的消息是：%s ，但是请求连接失败！",message);
    }
}

测试熔断器

此时我们关闭服务提供者，再次请求http://localhost:8765/hi?message=hi,Feign浏览器会显示

你的消息是:hi,Feign，但是请求连接失败！

说明在Feign中成功实现了使用Hystrix熔断器成功熔断服务请求。

赞 赏