概述
在微服務(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)用的單臺機(jī)器秒級數(shù)據(jù)寝蹈，甚至 500 臺以下規(guī)模的集群的匯總運行情況李命。
- 廣泛的開源生態(tài)： Sentinel 提供開箱即用的與其它開源框架/庫的整合模塊，例如與 Spring Cloud躺盛、Dubbo项戴、gRPC 的整合形帮。您只需要引入相應(yīng)的依賴并進(jìn)行簡單的配置即可快速地接入 Sentinel槽惫。
- 完善的 SPI 擴(kuò)展點： Sentinel 提供簡單易用、完善的 SPI 擴(kuò)展點辩撑。您可以通過實現(xiàn)擴(kuò)展點界斜，快速的定制邏輯。例如定制規(guī)則管理合冀、適配數(shù)據(jù)源等各薇。
Feign 中使用 Sentinel
如果要在您的項目中引入 Sentinel，使用 group ID 為 org.springframework.cloud 和 artifact ID 為 spring-cloud-starter-alibaba-sentinel 的 starter君躺。
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
Sentinel 適配了 Feign 組件峭判。但默認(rèn)是關(guān)閉的。需要在配置文件中配置打開它棕叫，在配置文件增加以下代碼：
feign:
sentinel:
enabled: true
在 Service 中增加 fallback 指定類
package com.wj.hello.spring.cloud.alibaba.nacos.consumer.feign.service;
import com.wj.hello.spring.cloud.alibaba.nacos.consumer.feign.fallback.EchoServiceFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
// 根據(jù)名稱來查找生產(chǎn)者
@FeignClient(value = "nacos-provider", fallback = EchoServiceFallback.class)
public interface NacosProviderServise {
// 生產(chǎn)者中對應(yīng)的接口
@GetMapping(value = "/echo/{message}")
String echo(@PathVariable("message") String message);
}
如果出現(xiàn)錯誤如：
是因為Spring找不到這個Bean林螃，只需要在NacosProviderServise添加@Component即可：
package com.wj.hello.spring.cloud.alibaba.nacos.consumer.feign.service;
import com.wj.hello.spring.cloud.alibaba.nacos.consumer.feign.fallback.EchoServiceFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
@Component
// 根據(jù)名稱來查找生產(chǎn)者
@FeignClient(value = "nacos-provider", fallback = EchoServiceFallback.class)
public interface NacosProviderServise {
// 生產(chǎn)者中對應(yīng)的接口
@GetMapping(value = "/echo/{message}")
String echo(@PathVariable("message") String message);
}
創(chuàng)建熔斷器類并實現(xiàn)對應(yīng)的 Feign 接口
package com.wj.hello.spring.cloud.alibaba.nacos.consumer.feign.service.fallback;
import com.wj.hello.spring.cloud.alibaba.nacos.consumer.feign.service.EchoService;
import org.springframework.stereotype.Component;
@Component
public class EchoServiceFallback implements EchoService {
@Override
public String echo(String message) {
return "使用Sentinel熔斷處理";
}
}
測試熔斷器
此時我們關(guān)閉服務(wù)提供者，再次請求 http://localhost:9092/echo/hi 瀏覽器會顯示：
echo fallback
