物聯網架構成長之路(53)-Sentinel流量控制中間件入門

0. 前言

 

1. 運行啟動sentinel-dashboard
　　到這里 https://github.com/alibaba/Sentinel/releases/download/1.7.1/sentinel-dashboard-1.7.1.jar 下載sentinel-dashboard
　　運行 java -jar sentinel-dashboard-1.7.1.jar --server.port=8858

　　提供Docker方式部署
➜ sentinel cat docker-compose.yml

version: '3.7'
services:
    sentinel:
        image: bladex/sentinel-dashboard:latest
        ports:
                - "8858:8858"
        environment:
                - auth.username=sentinel
                - auth.password=123456

 

2. Sentinel 客戶端編碼
pom.xml 增加

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>

application.properties

spring.application.name=demo
spring.cloud.sentinel.transport.dashboard=127.0.0.1:8858

 

Java代碼提供了代碼方式和注解方式集成
HelloProviderService.java

package com.wunaozai.demo;

import org.springframework.stereotype.Service;

import com.alibaba.csp.sentinel.annotation.SentinelResource;

@Service
public class HelloProviderService {
    
    @SentinelResource(value="say")
    public String sayHello(String msg) {
        return "Hello " + msg;
    }
}

HelloConsumerController.java

package com.wunaozai.demo;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.alibaba.csp.sentinel.Entry;
import com.alibaba.csp.sentinel.EntryType;
import com.alibaba.csp.sentinel.SphU;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;

@RestController
@RequestMapping(value="/hello")
public class HelloConsumerController {

    @Autowired
    private HelloProviderService helloproviderService;
    
    @SentinelResource(value="testResource")
    @RequestMapping(value="/say")
    public String sayHello(String msg) {
        String ret = helloproviderService.sayHello(msg);
        return ret;
    }
    
    @GetMapping(value="/testSentinel")
    public String testSentinel() {
        String resName = "testSentinel";
        Entry entry = null;
        String retVal;
        try {
            entry = SphU.entry(resName, EntryType.IN);
            retVal = "passed";
        } catch (BlockException e) {
            retVal = "blocked";
        }finally {
            if(entry != null) {
                entry.exit();
            }
        }
        return retVal;
    }
}

 

3. 運行及配置
　　由於是簡單的應用，所以，在沒有配置Sentinel的前提下，基本可以訪問

http://127.0.0.1:8080/hello/testSentinel
http://127.0.0.1:8080/hello/say?msg=yyy

　　這兩個路徑，沒有發生錯誤。
　　配置流控規則

　　配置流控后，再快速訪問上面兩個路徑。

http://127.0.0.1:8080/hello/testSentinel 超出QPS=2時，會出現 blocked
http://127.0.0.1:8080/hello/say?msg=yyy 超出QPS=5時，會出現程序異常

　　從下圖可以看到，超出QPS=5時，出現一次異常。

 

4. 持久化到Nacos
　　Sentinel Dashboard中添加的規則是存儲在內存中的，只要項目一重啟規則就丟失了
　　此處將規則持久化到nacos中，在nacos中添加規則，然后同步到dashboard中；
　　pom.xml 增加

        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
        </dependency>
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>15.0</version>
            <scope>compile</scope>
        </dependency>

　　application.properties 增加

spring.cloud.sentinel.datasource.ds.nacos.server-addr=127.0.0.1:8848
spring.cloud.sentinel.datasource.ds.nacos.data-id=mz-sentinel
spring.cloud.sentinel.datasource.ds.nacos.group-id=DEFAULT_GROUP
spring.cloud.sentinel.datasource.ds.nacos.data-type=json
spring.cloud.sentinel.datasource.ds.nacos.rule-type=flow

　　nacos 增加

[
    {
        "resource": "/hello",
        "limitApp": "default",
        "grade": 1,
        "count": 5,
        "strategy": 0,
        "controlBehavior": 0,
        "clusterMode": false
    }
]

　　啟動后，過一會，就會出現

 

5. 其他
　　通過上面，配置基本實現Sentinel規則持久化，每次重啟Sentinel后能恢復。但是這個時候，出現一個問題，就是在Sentinel-dashboard控制台修改時，不會保存到Nacos。但是Nacos在其客戶端總有Listener監聽器實現自動更新。所以在Nacos重新發布配置更新時，對應的Sentinel流控也會更新。基本實現動態化。
　　Sentinel控制台中修改規則：僅存在於服務的內存中，不會修改Nacos中的配置值，重啟后恢復原來的值。
　　Nacos控制台中修改規則：服務的內存中規則會更新，Nacos中持久化規則也會更新，重啟后依然保持。

 

 

參考資料：

　　https://www.cnblogs.com/gyli20170901/p/11279576.html
　　http://blog.didispace.com/spring-cloud-alibaba-sentinel-2-1/
　　https://github.com/alibaba/Sentinel/blob/master/sentinel-dashboard/src/main/resources/application.properties
　　https://github.com/alibaba/spring-cloud-alibaba/wiki/Sentinel
　　https://github.com/alibaba/Sentinel/wiki/%E4%BB%8B%E7%BB%8D

本文地址：https://www.cnblogs.com/wunaozai/p/12404712.html
本系列目錄： https://www.cnblogs.com/wunaozai/p/8067577.html
個人主頁：https://www.wunaozai.com/