如何使用Hystrix實現容錯處理

這篇文章將為大家詳細講解有關如何使用Hystrix實現容錯處理，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。

創(chuàng)建一個新的 Maven 項目 hystrix-feign-demo，增加 Hystrix 的依賴，代碼如下所示。

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

在啟動類上添加 @EnableHystrix 或者 @EnableCircuitBreaker。注意，@EnableHystrix 中包含了 @EnableCircuitBreaker。

然后編寫一個調用接口的方法，在上面增加一個 @HystrixCommand 注解，用于指定依賴服務調用延遲或失敗時調用的方法，代碼如下所示。

@GetMapping("/callHello")@HystrixCommand(fallbackMethod = "defaultCallHello")public String callHello() {
    String result = restTemplate.getForObject("http://localhost:8088/house/hello", String.class);return result;
}

當調用失敗觸發(fā)熔斷時會用 defaultCallHello 方法來回退具體的內容，定義 default-CallHello 方法的代碼如下所示。

public String defaultCallHello() {
    return "fail";
}

只要不啟動 8088 端口所在的服務，調用 /callHello 接口，就可以看到返回的內容是“fail”，如圖 1 所示。

將啟動類上的 @EnableHystrix 去掉，重啟服務，再次調用 /callHello 接口可以看到返回的是 500 錯誤信息，這個時候就沒有用到回退功能了。

{
  code: 500,
  message: "I/O error on GET request for
    "http://localhost:8088/house/hello": Connection refused; nested  exception is java.net.ConnectException: Connection refused", data:
        null
}

配置詳解

HystrixCommand 中除了 fallbackMethod 還有很多的配置，下面我們來看看這些配置，如下表所示：

HystrixCommand 配置詳解

官方的配置信息文檔請參考：https://github.com/Netflix/Hystrix/wiki/Configuration。

上面列出來的都是 Hystrix 的配置信息，那么在 Spring Cloud 中該如何使用呢？只需要在接口的方法上面使用 HystrixCommand 注解（如下代碼所示），指定對應的屬性即可。

@HystrixCommand(fallbackMethod = "defaultCallHello",commandProperties = {
        @HystrixProperty(name="execution.isolation.strategy", value = "THREAD")}
)@GetMapping("/callHello")public String callHello() {
    String result = restTemplate.getForObject("http://localhost:8088/house/hello", String.class);return result;
}

關于如何使用Hystrix實現容錯處理就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。