Spring cloud(4)-熔斷(Hystrix)

時間 2019-11-10

標籤 spring cloud 熔斷 hystrix 欄目 Spring 简体版

原文原文鏈接

Spring Cloud Hystrix（熔斷）

因爲網絡緣由或者自身的緣由，服務並不能保證100%可用，若是單個服務出現問題，調用這個服務就會出現線程阻塞，此時如有大量的請求涌入，Servlet容器的線程資源會被消耗完畢，致使服務癱瘓。服務與服務之間的依賴性，故障會傳播，會對整個微服務系統形成災難性的嚴重後果，這就是服務故障的「雪崩」效應。
雪崩應對策略：java

流量控制：控制的方式有不少種，相似隊列,令牌,漏桶等等。
網關限流: 由於Nginx的高性能, 目前一線互聯網公司大量採用Nginx+Lua的網關進行流量控制, 由此而來的OpenResty也愈來愈熱門. 使用OpenResty，其是由Nginx核心加不少第三方模塊組成，其最大的亮點是默認集成了Lua開發環境，使得Nginx能夠做爲一個Web Server使用。藉助於Nginx的事件驅動模型和非阻塞IO，能夠實現高性能的Web應用程序。
並且OpenResty提供了大量組件如Mysql、Redis、Memcached等等，使在Nginx上開發Web應用更方便更簡單。目前在京東如實時價格、秒殺、動態服務、單品頁、列表頁等都在使用Nginx+Lua架構，其餘公司如淘寶、去哪兒網等。
用戶交互限流：友好的提示，從源端限制流量流入。

基於Netflix的開源框架 Hystrix實現的 框架目標在於經過控制那些訪問遠程系統、服務和第三方庫的節點，從而對延遲和故障提供更強大的容錯能力。Hystrix具有了服務降級、服務熔斷、線程隔離、請求緩存、請求合併以及服務監控等強大功能。 git

添加依賴

<!-- hystrix 斷路器 -->
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
複製代碼

restTempate集成hystrixgithub

@EnableHystrix
@EnableDiscoveryClient
@SpringBootApplication
public class RibbonConsumerApplication {

    @LoadBalanced
    @Bean
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

	public static void main(String[] args) {
		SpringApplication.run(RibbonConsumerApplication.class, args);
	}
}
複製代碼

Feign是自帶斷路器的，若是在Dalston版本的，默認是沒有打開的，經過配置打開spring

feign:
  hystrix:
    enabled: true
複製代碼

@HystrixCommand 代表該方法爲hystrix包裹，能夠對依賴服務進行隔離、降級、快速失敗、快速重試等等sql

fallbackMethod降級方法
commandProperties 普通配置屬性，能夠配置HystrixCommand對應屬性，例如採用線程池仍是信號量隔離、熔斷器熔斷規則等等
ignoreExceptions 忽略的異常，默認HystrixBadRequestException不計入失敗
groupKey() 組名稱，默認使用類名稱
commandKey 命令名稱，默認使用方法名

消費者提供方法（defaultStores）

restTemplate配置使用緩存

@RestController
public class ConsumerController {

    @Autowired
    private RestTemplate restTemplate;

    @HystrixCommand(fallbackMethod = "defaultStores")
    @GetMapping(value = "/hello")
    public String hello() {
        return restTemplate.getForEntity("http://eureka-provider/", String.class).getBody();
    }

    public String defaultStores() {
        return "Ribbon + hystrix ,提供者服務掛了";
    }

}
複製代碼

feign配置使用網絡

@EnableHystrix
@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication
public class FeignConsumerApplication {

	public static void main(String[] args) {
		SpringApplication.run(FeignConsumerApplication.class, args);
	}
}
複製代碼

@FeignClient(value ="eureka-provider",fallbackFactory = HystrixClientFallbackFactory.class)
public interface HomeClient {

    @GetMapping("/")
    String consumer();
}
複製代碼

@Component
public class HystrixClientFallbackFactory implements FallbackFactory<HomeClient> {

    @Override
    public HomeClient create(Throwable throwable) {
        return () -> "feign + hystrix ,提供者服務掛了";
    }
}
複製代碼

Hystrix Dashboard是做爲斷路器狀態的一個組件，提供了數據監控和友好的圖形化界面。架構

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
</dependency>
複製代碼