整合營銷服務商
電腦端+手機端+微信端=數據同步管理
免費咨詢熱線：
電腦端+手機端+微信端=數據同步管理
免費咨詢熱線：
光鬧鐘app開發者，請關注我，后續分享更精彩！
堅持原創，共同進步！
阿里開源Sentinel框架功能強大，實現了對服務的流控、熔斷降級，并支持通過管理頁面進行配置和監控。Client集成支持Java、Go等語言。但管理后臺Dashboard，默認只適合開發和演示，要生產環境使用需要做相應源代碼級改造。本文將介紹具體改造步驟，幫助大家更快實現在生產環境的部署應用。當然，如果預算充足，也可以直接使用阿里云開箱即用的Sentinel Dashboard服務。
Sentinel Dashboard規則默認存儲在內存中，一旦服務重啟，規則將丟失。要實現生產環境的大規模應用，需要把規則做持久化存儲，Sentinel支持把nacos/zookeeper/apollo/redis等中間件作為存儲介質。本文以Nacos作為規則存儲端進行介紹。
整體架構如上圖，Sentinel Dashboard通過界面操作，添加資源的規則，保存時將信息推送到nacos中。nacos收到數據變更，并實時推送到應用中的Sentinel SDK客戶端，Sentinel SDK應用規則實現對服務資源的流控/熔斷/降級管控。
Sentinel 使用nacos作為存儲端，需要修改源代碼。
1.源代碼下載
git clone git@github.com:hcq0514/Sentinel.gitIDE工具打開sentinel-dashboard項目模塊
注意：將項目切換到使用的sentinel tag穩定版本，這里為1.8.6版本
2.pom.xml添加依賴
sentinel-dashboard模塊pom.xml文件中，把sentinel-datasource-nacos依賴的注釋掉。
<!-- for Nacos rule publisher sample -->
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-datasource-nacos</artifactId>
<!--<scope>test</scope>-->
</dependency>3.前端頁面修改
resources/app/scripts/directives/sidebar/sidebar.html文件，將dashboard.flowV1改成dashboard.flow
<li ui-sref-active="active" ng-if="!entry.isGateway">
<!--<a ui-sref="dashboard.flowV1({app: entry.app})">-->
<a ui-sref="dashboard.flow({app: entry.app})">
<i class="glyphicon glyphicon-filter"></i> 流控規則</a>
</li>4.Java代碼修改
com.alibaba.csp.sentinel.dashboard.rule包中創建一個nacos包，用來存放Nacos相關代碼類。
nacos包下創建NacosPropertiesConfiguration類，用于nacos server配置屬性封裝
package com.alibaba.csp.sentinel.dashboard.rule.nacos;
import org.springframework.boot.context.properties.ConfigurationProperties;
@ConfigurationProperties(prefix = "sentinel.nacos")
public class NacosPropertiesConfiguration {
private String namespace;
private String serverAddr;
private String username;
private String password;
//省略 屬性 set/get 方法......
}nacos包下創建NacosConfigUtil工具類
public final class NacosConfigUtil {
public static final String GROUP_ID = "SENTINEL_GROUP";
public static final String FLOW_DATA_ID_POSTFIX = "-flow-rules";
public static final String DEGRADE_DATA_ID_POSTFIX = "-degrade-rules";
public static final String PARAM_FLOW_DATA_ID_POSTFIX = "-param-rules";
public static final String CLUSTER_MAP_DATA_ID_POSTFIX = "-cluster-map";
/**
* cc for `cluster-client`
*/
public static final String CLIENT_CONFIG_DATA_ID_POSTFIX = "-cc-config";
/**
* cs for `cluster-server`
*/
public static final String SERVER_TRANSPORT_CONFIG_DATA_ID_POSTFIX = "-cs-transport-config";
public static final String SERVER_FLOW_CONFIG_DATA_ID_POSTFIX = "-cs-flow-config";
public static final String SERVER_NAMESPACE_SET_DATA_ID_POSTFIX = "-cs-namespace-set";
private NacosConfigUtil() {}
}nacos包創建NacosConfiguration bean配置類
@EnableConfigurationProperties(NacosPropertiesConfiguration.class)
@Configuration
public class NacosConfiguration {
@Bean
@Qualifier("degradeRuleEntityEncoder")
public Converter<List<DegradeRuleEntity>, String> degradeRuleEntityEncoder() {
return JSON::toJSONString;
}
@Bean
@Qualifier("degradeRuleEntityDecoder")
public Converter<String, List<DegradeRuleEntity>> degradeRuleEntityDecoder() {
return s -> JSON.parseArray(s, DegradeRuleEntity.class);
}
@Bean
@Qualifier("flowRuleEntityEncoder")
public Converter<List<FlowRuleEntity>, String> flowRuleEntityEncoder() {
return JSON::toJSONString;
}
@Bean
@Qualifier("flowRuleEntityDecoder")
public Converter<String, List<FlowRuleEntity>> flowRuleEntityDecoder() {
return s -> JSON.parseArray(s, FlowRuleEntity.class);
}
@Bean
public ConfigService nacosConfigService(NacosPropertiesConfiguration nacosPropertiesConfiguration) throws NacosException {
Properties properties = new Properties();
properties.put(PropertyKeyConst.SERVER_ADDR, nacosPropertiesConfiguration.getServerAddr());
if(StringUtils.isNotBlank(nacosPropertiesConfiguration.getNamespace())){
properties.put(PropertyKeyConst.NAMESPACE, nacosPropertiesConfiguration.getNamespace());
}
if(StringUtils.isNotBlank(nacosPropertiesConfiguration.getUsername())){
properties.put(PropertyKeyConst.USERNAME, nacosPropertiesConfiguration.getUsername());
}
if(StringUtils.isNotBlank(nacosPropertiesConfiguration.getPassword())){
properties.put(PropertyKeyConst.PASSWORD, nacosPropertiesConfiguration.getPassword());
}
return ConfigFactory.createConfigService(properties);
}
}nacos包下創建流控的provider和publisher實現類
@Component("flowRuleNacosProvider")
public class FlowRuleNacosProvider implements DynamicRuleProvider<List<FlowRuleEntity>> {
@Autowired
private ConfigService configService;
@Autowired
@Qualifier("flowRuleEntityDecoder")
private Converter<String, List<FlowRuleEntity>> converter;
@Override
public List<FlowRuleEntity> getRules(String appName) throws Exception {
String rules = configService.getConfig(appName + NacosConfigUtil.FLOW_DATA_ID_POSTFIX,
NacosConfigUtil.GROUP_ID, 3000);
if (StringUtil.isEmpty(rules)) {
return new ArrayList<>();
}
return converter.convert(rules);
}
}@Component("flowRuleNacosPublisher")
public class FlowRuleNacosPublisher implements DynamicRulePublisher<List<FlowRuleEntity>> {
@Autowired
private ConfigService configService;
@Autowired
@Qualifier("flowRuleEntityEncoder")
private Converter<List<FlowRuleEntity>, String> converter;
@Override
public void publish(String app, List<FlowRuleEntity> rules) throws Exception {
AssertUtil.notEmpty(app, "app name cannot be empty");
if (rules == null) {
return;
}
configService.publishConfig(app + NacosConfigUtil.FLOW_DATA_ID_POSTFIX,
NacosConfigUtil.GROUP_ID, converter.convert(rules));
}
}nacos包下創建熔斷/降級的provider和publisher實現類
@Component("degradeRuleNacosProvider")
public class DegradeRuleNacosProvider implements DynamicRuleProvider<List<DegradeRuleEntity>> {
@Autowired
private ConfigService configService;
@Autowired
@Qualifier("degradeRuleEntityDecoder")
private Converter<String, List<DegradeRuleEntity>> converter;
@Override
public List<DegradeRuleEntity> getRules(String appName) throws Exception {
String rules = configService.getConfig(appName + NacosConfigUtil.DEGRADE_DATA_ID_POSTFIX,
NacosConfigUtil.GROUP_ID, 3000);
if (StringUtil.isEmpty(rules)) {
return new ArrayList<>();
}
return converter.convert(rules);
}
}@Component("degradeRuleNacosPublisher")
public class DegradeRuleNacosPublisher implements DynamicRulePublisher<List<DegradeRuleEntity>> {
@Autowired
private ConfigService configService;
@Autowired
@Qualifier("degradeRuleEntityEncoder")
private Converter<List<DegradeRuleEntity>, String> converter;
@Override
public void publish(String app, List<DegradeRuleEntity> rules) throws Exception {
AssertUtil.notEmpty(app, "app name cannot be empty");
if (rules == null) {
return;
}
configService.publishConfig(app + NacosConfigUtil.DEGRADE_DATA_ID_POSTFIX,
NacosConfigUtil.GROUP_ID, converter.convert(rules));
}
}修改com.alibaba.csp.sentinel.dashboard.controller.v2.FlowControllerV2類。將注入的bean標識由下圖右邊替換左邊的值。將原有的服務引用基于內存存儲，替換為nacos存儲的服務引用。
# 上面截圖紅框替換值
flowRuleDefaultProvider 替換為 flowRuleNacosProvider
flowRuleDefaultPublisher 替換為 flowRuleNacosPublisher刪除com.alibaba.csp.sentinel.dashboard.controller.DegradeController類， com.alibaba.csp.sentinel.dashboard.controller.v2包下新增DegradeControllerV2類
@RestController
@RequestMapping("/degrade")
public class DegradeControllerV2 {
private final Logger logger = LoggerFactory.getLogger(DegradeControllerV2.class);
@Autowired
private RuleRepository<DegradeRuleEntity, Long> repository;
@Autowired
@Qualifier("degradeRuleNacosProvider")
private DynamicRuleProvider<List<DegradeRuleEntity>> ruleProvider;
@Autowired
@Qualifier("degradeRuleNacosPublisher")
private DynamicRulePublisher<List<DegradeRuleEntity>> rulePublisher;
@GetMapping("/rules.json")
@AuthAction(PrivilegeType.READ_RULE)
public Result<List<DegradeRuleEntity>> apiQueryMachineRules(String app, String ip, Integer port) {
if (StringUtil.isEmpty(app)) {
return Result.ofFail(-1, "app can't be null or empty");
}
if (StringUtil.isEmpty(ip)) {
return Result.ofFail(-1, "ip can't be null or empty");
}
if (port == null) {
return Result.ofFail(-1, "port can't be null");
}
try {
// List<DegradeRuleEntity> rules = sentinelApiClient.fetchDegradeRuleOfMachine(app, ip, port);
List<DegradeRuleEntity> rules = ruleProvider.getRules(app);
if (rules != null && !rules.isEmpty()) {
for (DegradeRuleEntity entity : rules) {
entity.setApp(app);
}
}
rules = repository.saveAll(rules);
return Result.ofSuccess(rules);
} catch (Throwable throwable) {
logger.error("queryApps error:", throwable);
return Result.ofThrowable(-1, throwable);
}
}
@PostMapping("/rule")
@AuthAction(PrivilegeType.WRITE_RULE)
public Result<DegradeRuleEntity> apiAddRule(@RequestBody DegradeRuleEntity entity) {
Result<DegradeRuleEntity> checkResult = checkEntityInternal(entity);
if (checkResult != null) {
return checkResult;
}
Date date = new Date();
entity.setGmtCreate(date);
entity.setGmtModified(date);
try {
entity = repository.save(entity);
} catch (Throwable t) {
logger.error("Failed to add new degrade rule, app={}, ip={}", entity.getApp(), entity.getIp(), t);
return Result.ofThrowable(-1, t);
}
if (!publishRules(entity.getApp(), entity.getIp(), entity.getPort())) {
logger.warn("Publish degrade rules failed, app={}", entity.getApp());
}
return Result.ofSuccess(entity);
}
@PutMapping("/rule/{id}")
@AuthAction(PrivilegeType.WRITE_RULE)
public Result<DegradeRuleEntity> apiUpdateRule(@PathVariable("id") Long id,
@RequestBody DegradeRuleEntity entity) {
if (id == null || id <= 0) {
return Result.ofFail(-1, "id can't be null or negative");
}
DegradeRuleEntity oldEntity = repository.findById(id);
if (oldEntity == null) {
return Result.ofFail(-1, "Degrade rule does not exist, id=" + id);
}
entity.setApp(oldEntity.getApp());
entity.setIp(oldEntity.getIp());
entity.setPort(oldEntity.getPort());
entity.setId(oldEntity.getId());
Result<DegradeRuleEntity> checkResult = checkEntityInternal(entity);
if (checkResult != null) {
return checkResult;
}
entity.setGmtCreate(oldEntity.getGmtCreate());
entity.setGmtModified(new Date());
try {
entity = repository.save(entity);
} catch (Throwable t) {
logger.error("Failed to save degrade rule, id={}, rule={}", id, entity, t);
return Result.ofThrowable(-1, t);
}
if (!publishRules(entity.getApp(), entity.getIp(), entity.getPort())) {
logger.warn("Publish degrade rules failed, app={}", entity.getApp());
}
return Result.ofSuccess(entity);
}
@DeleteMapping("/rule/{id}")
@AuthAction(PrivilegeType.DELETE_RULE)
public Result<Long> delete(@PathVariable("id") Long id) {
if (id == null) {
return Result.ofFail(-1, "id can't be null");
}
DegradeRuleEntity oldEntity = repository.findById(id);
if (oldEntity == null) {
return Result.ofSuccess(null);
}
try {
repository.delete(id);
} catch (Throwable throwable) {
logger.error("Failed to delete degrade rule, id={}", id, throwable);
return Result.ofThrowable(-1, throwable);
}
if (!publishRules(oldEntity.getApp(), oldEntity.getIp(), oldEntity.getPort())) {
logger.warn("Publish degrade rules failed, app={}", oldEntity.getApp());
}
return Result.ofSuccess(id);
}
private boolean publishRules(String app, String ip, Integer port) {
/*List<DegradeRuleEntity> rules = repository.findAllByMachine(MachineInfo.of(app, ip, port));
return sentinelApiClient.setDegradeRuleOfMachine(app, ip, port, rules);*/
List<DegradeRuleEntity> rules = repository.findAllByApp(app);
try {
rulePublisher.publish(app, rules);
} catch (Exception e) {
logger.error("Failed to publish nacos, app={}", app);
logger.error("error is : ",e);
}
return true;
}
private <R> Result<R> checkEntityInternal(DegradeRuleEntity entity) {
if (StringUtil.isBlank(entity.getApp())) {
return Result.ofFail(-1, "app can't be blank");
}
if (StringUtil.isBlank(entity.getIp())) {
return Result.ofFail(-1, "ip can't be null or empty");
}
if (entity.getPort() == null || entity.getPort() <= 0) {
return Result.ofFail(-1, "invalid port: " + entity.getPort());
}
if (StringUtil.isBlank(entity.getLimitApp())) {
return Result.ofFail(-1, "limitApp can't be null or empty");
}
if (StringUtil.isBlank(entity.getResource())) {
return Result.ofFail(-1, "resource can't be null or empty");
}
Double threshold = entity.getCount();
if (threshold == null || threshold < 0) {
return Result.ofFail(-1, "invalid threshold: " + threshold);
}
Integer recoveryTimeoutSec = entity.getTimeWindow();
if (recoveryTimeoutSec == null || recoveryTimeoutSec <= 0) {
return Result.ofFail(-1, "recoveryTimeout should be positive");
}
Integer strategy = entity.getGrade();
if (strategy == null) {
return Result.ofFail(-1, "circuit breaker strategy cannot be null");
}
if (strategy < CircuitBreakerStrategy.SLOW_REQUEST_RATIO.getType()
|| strategy > RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT) {
return Result.ofFail(-1, "Invalid circuit breaker strategy: " + strategy);
}
if (entity.getMinRequestAmount() == null || entity.getMinRequestAmount() <= 0) {
return Result.ofFail(-1, "Invalid minRequestAmount");
}
if (entity.getStatIntervalMs() == null || entity.getStatIntervalMs() <= 0) {
return Result.ofFail(-1, "Invalid statInterval");
}
if (strategy == RuleConstant.DEGRADE_GRADE_RT) {
Double slowRatio = entity.getSlowRatioThreshold();
if (slowRatio == null) {
return Result.ofFail(-1, "SlowRatioThreshold is required for slow request ratio strategy");
} else if (slowRatio < 0 || slowRatio > 1) {
return Result.ofFail(-1, "SlowRatioThreshold should be in range: [0.0, 1.0]");
}
} else if (strategy == RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO) {
if (threshold > 1) {
return Result.ofFail(-1, "Ratio threshold should be in range: [0.0, 1.0]");
}
}
return null;
}
}5.maven打包
重新打包sentinel-dashboard模塊
mvn clean package6.配置文件修改
application.properties添加nacos配置項
#nacos服務地址
sentinel.nacos.serverAddr=127.0.0.1:8848
#nacos命名空間
sentinel.nacos.namespacec=
#sentinel.nacos.username=
#sentinel.nacos.password=1.引入依賴
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>如果是maven多模塊工程，父pom中添加alibaba的父pom依賴
<dependencyManagement>
<dependencies>
<!-- https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>2.2.6.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement> 2.注解支持
Sentinel 提供了 @SentinelResource 注解用于定義資源，實現資源的流控/熔斷降級處理。
注意：注解方式埋點不支持 private 方法。
@Service
@Slf4j
public class TestService {
/**
* 定義sayHello資源的方法，流控/熔斷降級處理邏輯
* @param name
* @return
*/
@SentinelResource(value = "sayHello",blockHandler = "sayHelloBlockHandler",fallback = "sayHelloFallback")
public String sayHello(String name) {
if("fallback".equalsIgnoreCase(name)){
throw new RuntimeException("fallback");
}
return "Hello, " + name;
}
/**
* 被流控后處理方法。
* 1. @SentinelResource 注解blockHandler設置，值為函數方法名
* 2. blockHandler 函數訪問范圍需要是 public，返回類型需要與原方法相匹配，參數類型需要和原方法相匹配并且最后加一個額外的參數，類型為 BlockException。
* 3. blockHandler 函數默認需要和原方法在同一個類中。若希望使用其他類的函數，則可以指定 blockHandlerClass 為對應的類的 Class 對象，注意對應的函數必需為 static 函數，否則無法解析。
* @param name
* @param blockException
* @return
*/
public String sayHelloBlockHandler(String name, BlockException blockException){
log.warn("已開啟流控",blockException);
return "流控后的返回值";
}
/**
* 被降級后處理方法
* 注意！！！：如果blockHandler和fallback都配置，熔斷降級規則生效，觸發熔斷,在熔斷時長定義時間內，只有blockHandler生效
* 1. @SentinelResource 注解fallback設置，值為函數方法名
* 2. 用于在拋出異常的時候提供 fallback 處理邏輯。fallback 函數可以針對所有類型的異常（除了 exceptionsToIgnore 里面排除掉的異常類型）進行處理
* 3. 返回值類型必須與原函數返回值類型一致；
* 4. 方法參數列表需要和原函數一致，或者可以額外多一個 Throwable 類型的參數用于接收對應的異常。
* 5. allback 函數默認需要和原方法在同一個類中。若希望使用其他類的函數，則可以指定 fallbackClass 為對應的類的 Class 對象，注意對應的函數必需為 static 函數，否則無法解析。
* @param name
* @param throwable
* @return
*/
public String sayHelloFallback(String name, Throwable throwable){
log.warn("已降級",throwable);
return "降級后的返回值";
}
}流控和降級處理邏輯定義詳見代碼注釋。
@SentinelResource還包含其他可能使用的屬性：
3.添加配置
application.yml文件添加以下配置
spring:
application:
name: demo-sentinel
cloud:
sentinel: #阿里sentinel配置項
transport:
# spring.cloud.sentinel.transport.port 端口配置會在應用對應的機器上啟動一個 Http Server，
# 該 Server 會與 Sentinel 控制臺做交互。比如 Sentinel 控制臺添加了一個限流規則，會把規則數據 push 給這個 Http Server 接收，
# Http Server 再將規則注冊到 Sentinel 中。
# port: 8719
dashboard: localhost:8080
datasource:
ds1: # 數據源標識key，可以隨意命名，保證唯一即可
nacos: #nacos 數據源-流控規則配置
server-addr: localhost:8848
# username: nacos
# password: nacos
data-id: ${spring.application.name}-flow-rules
group-id: SENTINEL_GROUP
data-type: json
#flow、degrade、param-flow
rule-type: flow
ds2:
nacos: #nacos 數據源-熔斷降級規則配置
server-addr: localhost:8848
# username: nacos
# password: nacos
data-id: ${spring.application.name}-degrade-rules
group-id: SENTINEL_GROUP
data-type: json
#flow、degrade、param-flow
rule-type: degrade啟動sentinel-dashboard。
應用端集成Sentinel SDK，訪問添加了降級邏輯處理的接口地址。
訪問sentinel-dashboard web頁面: http://localhost:8080/ 。在界面，添加相應流控和熔斷規則。
Nacos管理界面查看：http://localhost:8848/nacos 。 可以看到自動生成了兩個配置界面，分別對應流控和熔斷配置
點擊規則詳情，查看規則信息
規則json對象信息如下：
entinel Dashboard（控制臺）默認情況下，只能將配置規則保存到內存中，這樣就會導致 Sentinel Dashboard 重啟后配置規則丟失的情況，因此我們需要將規則保存到某種數據源中，Sentinel 支持的數據源有以下這些：
然而，默認情況下，Sentinel 和數據源之間的關系是單向數據通訊的，也就是只能先在數據源中配置規則，然后數據源會被規則推送至 Sentinel Dashboard 和 Sentinel 客戶端，但是在 Sentinel Dashboard 中修改規則或新增規則是不能反向同步到數據源中的，這就是單向通訊。
所以，今天我們就該修改一下 Sentinel 的源碼，讓其可以同步規則至數據源，改造之后的交互流程如下圖所示：
Sentinel 同步規則至數據源，例如將 Sentinel 的規則，同步規則至 Nacos 數據源的改造步驟很多，但整體實現難度不大，下面我們一起來看吧。
下載地址：https://github.com/alibaba/Sentinel
PS：本文 Sentinel 使用的版本是 1.8.6。
下載源碼之后，使用 idea 打開里面的 sentinel-dashboard 項目，如下圖所示：
將 sentinel-datasource-nacos 底下的 scope 注釋掉，如下圖所示：
PS：因為官方提供的 Nacos 持久化實例，是在 test 目錄下進行單元測試的，而我們是用于生產環境，所以需要將 scope 中的 test 去掉。
將 test/com.alibaba.csp.sentinel.dashboard.rule.nacos 下所有文件復制到 src/main/java/com.alibaba.csp.sentinel.dashboard.rule 目錄下，如下圖所示：
在 com.alibaba.csp.sentinel.dashboard.rule 下創建 Nacos 配置文件的讀取類，實現代碼如下：
package com.alibaba.csp.sentinel.dashboard.rule;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
@ConfigurationProperties(prefix = "sentinel.nacos")
@Configuration
public class NacosPropertiesConfiguration {
private String serverAddr;
private String dataId;
private String groupId;
private String namespace;
private String username;
private String password;
// 省略 Getter/Setter 代碼
}只修改 NacosConfig 中的 nacosConfigService 方法，修改后的代碼如下：
@Bean
public ConfigService nacosConfigService(NacosPropertiesConfiguration nacosPropertiesConfiguration) throws Exception {
Properties properties = new Properties();
properties.put(PropertyKeyConst.SERVER_ADDR, nacosPropertiesConfiguration.getServerAddr());
properties.put(PropertyKeyConst.NAMESPACE, nacosPropertiesConfiguration.getNamespace());
properties.put(PropertyKeyConst.USERNAME,nacosPropertiesConfiguration.getUsername());
properties.put(PropertyKeyConst.PASSWORD,nacosPropertiesConfiguration.getPassword());
return ConfigFactory.createConfigService(properties);
// return ConfigFactory.createConfigService("localhost"); // 原代碼
}修改 com.alibaba.csp.sentinel.dashboard.controller.v2 目錄下的 FlowControllerV2 文件：
修改后代碼：
@Autowired
@Qualifier("flowRuleNacosProvider")
private DynamicRuleProvider<List<FlowRuleEntity>> ruleProvider;
@Autowired
@Qualifier("flowRuleNacosPublisher")
private DynamicRulePublisher<List<FlowRuleEntity>> rulePublisher;PS：此操作的目的是開啟 Controller 層操作 Nacos 的開關。
如下圖所示：
在 application.properties 中設置 Nacos 連接信息，配置如下：
sentinel.nacos.serverAddr=localhost:8848
sentinel.nacos.username=nacos
sentinel.nacos.password=nacos
sentinel.nacos.namespace=
sentinel.nacos.groupId=DEFAULT_GROUP
sentinel.nacos.dataId=sentinel-dashboard-demo-sentinel修改 webapp/resources/app/scripts/directives/sidebar/sidebar.html 文件：
搜索“dashboard.flowV1”改為“dashboard.flow”，如下圖所示：
identity.js 文件有兩處修改，它位于 webapp/resources/app/scripts/controllers/identity.js 目錄。
將“FlowServiceV1”修改為“FlowServiceV2”，如下圖所示：
搜索“/dashboard/flow/”修改為“/dashboard/v2/flow/”，如下圖所示：
PS：修改 identity.js 文件主要是用于在 Sentinel 點擊資源的“流控”按鈕添加規則后將信息同步給 Nacos。
Sentinel Dashboard 默認情況下，只能將配置規則保存到內存中，這樣就會程序重啟后配置規則丟失的情況，因此我們需要給 Sentinel 設置一個數據源，并且要和數據源之間實現雙向通訊，所以我們需要修改 Sentinel 的源碼。源碼的改造步驟雖然很多，但只要逐一核對和修改就可以實現 Sentinel 生成環境的配置了。看完記得收藏哦，防止以后用的時候找不到。
本文已收錄到我的面試小站 www.javacn.site，其中包含的內容有：Redis、JVM、并發、并發、MySQL、Spring、Spring MVC、Spring Boot、Spring Cloud、MyBatis、設計模式、消息隊列等模塊。
好，這里是codetrend專欄“SpringCloud2023實戰”。
本文簡單介紹SpringCloud2023中使用Sentinel進行限流管理。
隨著微服務的流行，服務和服務之間的穩定性變得越來越重要。
Sentinel 是面向分布式、多語言異構化服務架構的流量治理組件，主要以流量為切入點，從流量路由、流量控制、流量整形、熔斷降級、系統自適應過載保護、熱點流量防護等多個維度來幫助開發者保障微服務的穩定性。
Sentinel 同時提供系統維度的自適應保護能力。
防止雪崩，是系統防護中重要的一環。當系統負載較高的時候，如果還持續讓請求進入，可能會導致系統崩潰，無法響應。在集群環境下，網絡負載均衡會把本應這臺機器承載的流量轉發到其它的機器上去。
如果這個時候其它的機器也處在一個邊緣狀態的時候，這個增加的流量就會導致這臺機器也崩潰，最后導致整個集群不可用。
Spring Cloud Alibaba 默認為 Sentinel 整合了 Servlet、RestTemplate、FeignClient 和 Spring WebFlux。
Sentinel 在 Spring Cloud 生態中，不僅補全了 Hystrix 在 Servlet 和 RestTemplate 這一塊的空白，而且還完全兼容了 Hystrix 在 FeignClient 中限流降級的用法，并且支持運行時靈活地配置和調整限流降級規則。
Sentinel 的使用可以分為兩個部分:
Sentinel 的主要工作機制如下：
Sentinel 具有以下特征:
Sentinel 控制臺提供一個輕量級的控制臺，它提供機器發現、單機資源實時監控、集群資源匯總，以及規則管理的功能。您只需要對應用進行簡單的配置，就可以使用這些功能。
java -Dserver.port=10300 -Dcsp.sentinel.dashboard.server=localhost:10300 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar
# 如若8080端口沖突，可使用 -Dserver.port=新端口 進行設置。
spring:
cloud:
sentinel:
transport:
port: 10201
dashboard: localhost:10300
這里的 spring.cloud.sentinel.transport.port 端口配置會在應用對應的機器上啟動一個 Http Server，該 Server 會與 Sentinel 控制臺做交互。比如 Sentinel 控制臺添加了一個限流規則，會把規則數據 push 給這個 Http Server 接收，Http Server 再將規則注冊到 Sentinel 中。
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<dependencies>
<!-- sentinel核心包引入 -->
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-core</artifactId>
</dependency>
<!-- sentinel-springboot引入 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
</dependencies>
</project>
spring.application.name: banana-client4-sentinel
spring:
cloud:
sentinel:
transport:
port: 10201
dashboard: localhost:10300
zookeeper:
connect-string: localhost:2181
@Service
public class TestService {
@SentinelResource(value = "sayHello")
public String sayHello(String name) {
return "Hello, " + name;
}
}
@RestController
public class TestController {
@Autowired
private TestService service;
@GetMapping(value = "/hello/{name}")
public String apiHello(@PathVariable String name) {
return service.sayHello(name);
}
}
import requests
token_list =[]
for j in range(10):
token_list.append(str(j)+'hello')
response = requests.get('http://localhost:10200/client4/hello/'+str(j)+'hello','hello')
print(response.text)
輸出文檔如下：
Hello, 0hello
Hello, 1hello
Hello, 2hello
Hello, 3hello
Hello, 4hello
Blocked by Sentinel (flow limiting)
Blocked by Sentinel (flow limiting)
Blocked by Sentinel (flow limiting)
Blocked by Sentinel (flow limiting)
Blocked by Sentinel (flow limiting)
Feign 適配整合在 Spring Cloud Alibaba 中，可以參考 Spring Cloud Alibaba Sentinel 文檔 進行接入。
Sentinel 適配了 Feign 組件。如果想使用，除了引入 spring-cloud-starter-alibaba-sentinel 的依賴外還需要 2 個步驟：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
@FeignClient(name = "service-provider", fallback = EchoServiceFallback.class, configuration = FeignConfiguration.class)
public interface EchoService {
@RequestMapping(value = "/echo/{str}", method = RequestMethod.GET)
String echo(@PathVariable("str") String str);
}
class FeignConfiguration {
@Bean
public EchoServiceFallback echoServiceFallback() {
return new EchoServiceFallback();
}
}
class EchoServiceFallback implements EchoService {
@Override
public String echo(@PathVariable("str") String str) {
return "echo fallback";
}
}
若想跟 Sentinel Starter 配合使用，需要加上 spring-cloud-alibaba-sentinel-gateway 依賴，同時需要添加 spring-cloud-starter-gateway 依賴來讓 spring-cloud-alibaba-sentinel-gateway 模塊里的 Spring Cloud Gateway 自動化配置類生效：
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
同時請將 spring.cloud.sentinel.filter.enabled 配置項置為 false（若在網關流控控制臺上看到了 URL 資源，就是此配置項沒有置為 false）。Sentinel 網關流控默認的粒度是 route 維度以及自定義 API 分組維度，默認不支持 URL 粒度。
文檔來自Sentinel文檔。這里不仔細展開開發和說明，后續在網關業務層進行配置和說明。
完整源碼信息查看可以在gitee或者github上搜索r0ad。
來自一線全棧程序員nine的探索與實踐，持續迭代中。
歡迎關注或者點贊~
*請認真填寫需求信息，我們會在24小時內與您取得聯系。
