目錄：Spring Cloud Alibaba系列教程
上一篇：6.Spring Cloud Alibaba 創(chuàng)建服務(wù)消費者(Feign)
下一篇：8.Spring Cloud Alibaba 熔斷器儀表盤監(jiān)控
概述
在微服務(wù)架構(gòu)中，根據(jù)業(yè)務(wù)來拆分成一個個的服務(wù)，服務(wù)與服務(wù)之間可以通過 RPC 相互調(diào)用，在 Spring Cloud 中可以用 RestTemplate + LoadBalanceClient 和 Feign 來調(diào)用。為了保證其高可用，單個服務(wù)通常會集群部署。由于網(wǎng)絡(luò)原因或者自身的原因，服務(wù)并不能保證 100% 可用，如果單個服務(wù)出現(xiàn)問題，調(diào)用這個服務(wù)就會出現(xiàn)線程阻塞，此時若有大量的請求涌入，Servlet 容器的線程資源會被消耗完畢，導(dǎo)致服務(wù)癱瘓。服務(wù)與服務(wù)之間的依賴性，故障會傳播，會對整個微服務(wù)系統(tǒng)造成災(zāi)難性的嚴(yán)重后果，這就是服務(wù)故障的 “雪崩” 效應(yīng)。
為了解決這個問題，業(yè)界提出了熔斷器模型。
阿里巴巴開源了 Sentinel 組件，實現(xiàn)了熔斷器模式，Spring Cloud 對這一組件進(jìn)行了整合。在微服務(wù)架構(gòu)中，一個請求需要調(diào)用多個服務(wù)是非常常見的，如下圖：
較底層的服務(wù)如果出現(xiàn)故障，會導(dǎo)致連鎖故障。當(dāng)對特定的服務(wù)的調(diào)用的不可用達(dá)到一個閥值熔斷器將會被打開。
熔斷器打開后，為了避免連鎖故障，通過 fallback 方法可以直接返回一個固定值。
什么是 Sentinel
隨著微服務(wù)的流行，服務(wù)和服務(wù)之間的穩(wěn)定性變得越來越重要。 Sentinel 以流量為切入點，從流量控制、熔斷降級、系統(tǒng)負(fù)載保護(hù)等多個維度保護(hù)服務(wù)的穩(wěn)定性。
Sentinel 的特征
- 豐富的應(yīng)用場景： Sentinel 承接了阿里巴巴近 10 年的 雙十一大促流量 的核心場景，例如秒殺（即突發(fā)流量控制在系統(tǒng)容量可以承受的范圍）、消息削峰填谷、實時熔斷下游不可用應(yīng)用等。
- 完備的實時監(jiān)控： Sentinel 同時提供實時的監(jiān)控功能。您可以在控制臺中看到接入應(yīng)用的單臺機器秒級數(shù)據(jù)，甚至 500 臺以下規(guī)模的集群的匯總運行情況。
- 廣泛的開源生態(tài)： Sentinel 提供開箱即用的與其它開源框架/庫的整合模塊，例如與 Spring Cloud、Dubbo、gRPC 的整合。您只需要引入相應(yīng)的依賴并進(jìn)行簡單的配置即可快速地接入 Sentinel。
- 完善的 SPI 擴展點： Sentinel 提供簡單易用、完善的 SPI 擴展點。您可以通過實現(xiàn)擴展點，快速的定制邏輯。例如定制規(guī)則管理、適配數(shù)據(jù)源等。
Feign 中使用 Sentinel
如果要在您的項目中引入 Sentinel，使用 group ID 為 org.springframework.cloud 和 artifact ID 為 spring-cloud-starter-alibaba-sentinel 的 starter。
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
Sentinel 適配了 Feign 組件。但默認(rèn)是關(guān)閉的。需要在配置文件中配置打開它，在配置文件增加以下代碼：
feign:
sentinel:
enabled: true
在 Service 中@FeignClient注解增加 fallback屬性用來指定類
package com.wsl.hello.consumer.feign.service;
import com.wsl.hello.consumer.feign.service.fallback.FallbackServiceImpl;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
@FeignClient(value = "nacos-provider", fallback = FallbackServiceImpl.class)
public interface FeignService {
@GetMapping(value = "/test/{message}")
String test(@PathVariable("message") String message);
}
創(chuàng)建熔斷器類并實現(xiàn)對應(yīng)的 Feign 接口
package com.wsl.hello.consumer.feign.service.fallback;
import com.wsl.hello.consumer.feign.service.FeignService;
@Component
public class FallbackServiceImpl implements FeignService {
@Override
public String test(String message) {
return "test fallback";
}
}
目錄結(jié)構(gòu)：
測試熔斷器
此時我們關(guān)閉服務(wù)提供者，再次請求 http://localhost:9092/test/hi 瀏覽器會顯示：
test fallback
目錄：Spring Cloud Alibaba系列教程
上一篇：6.Spring Cloud Alibaba 創(chuàng)建服務(wù)消費者(Feign)
下一篇：8.Spring Cloud Alibaba 熔斷器儀表盤監(jiān)控
