[
  {
    "resource": "test",
    "threshold": 0,
    "tokenCalculateStrategy": 0,
    "controlBehavior": 0,
    "statIntervalInMs": 1000
  }
]

[
  {
    "resource": "test",
    "threshold": 0,
    "tokenCalculateStrategy": 0,
    "controlBehavior": 0,
    "statIntervalInMs": 1000
  }
]

package main
import (
	"fmt"
	"github.com/alibaba/sentinel-golang/api"
	"github.com/alibaba/sentinel-golang/core/base"
	"github.com/alibaba/sentinel-golang/ext/datasource"
	"log"
	"math/rand"
	"time"
	"github.com/alibaba/sentinel-golang/ext/datasource/file"
)
func main() {
	// 定義流控規(guī)則的文件路徑
	filePath := "./file/rules.json"
	// 創(chuàng)建一個(gè)處理流量控制規(guī)則的處理器
	h := datasource.NewFlowRulesHandler(datasource.FlowRuleJsonArrayParser)
	// 創(chuàng)建一個(gè)基于文件的數(shù)據(jù)源，使用指定的文件路徑和處理器
	ds := file.NewFileDataSource(filePath, h)
	// 初始化數(shù)據(jù)源，如果失敗則記錄錯(cuò)誤并退出程序
	err := ds.Initialize()
	if err != nil {
		log.Fatalf("創(chuàng)建文件數(shù)據(jù)源失敗: %+v", err)
	}
	// 啟動(dòng)一個(gè) goroutine 模擬請(qǐng)求
	go func() {
		for {
			// 創(chuàng)建 Sentinel 入口節(jié)點(diǎn)，資源名為 "test"
			e, b := api.Entry("test", api.WithTrafficType(base.Inbound))
			if b != nil {
				// 如果請(qǐng)求被 Sentinel 阻止，打印阻止類(lèi)型
				fmt.Printf("請(qǐng)求被 Sentinel 阻止: %v\n", b.BlockType())
			} else {
				// 如果請(qǐng)求通過(guò) Sentinel，打印通過(guò)信息
				fmt.Println("請(qǐng)求通過(guò) Sentinel")
				// 退出 Sentinel 入口節(jié)點(diǎn)
				e.Exit()
			}
			// 模擬處理時(shí)間，隨機(jī)睡眠 10-90 毫秒
			time.Sleep(time.Duration(rand.Uint64()%80+10) * time.Millisecond)
		}
	}()
	// 主 goroutine 無(wú)限阻塞，防止程序退出
	select {}
}

docker pull nacos/nacos-server:latest

docker run -d --name nacos -p 8848:8848 -e MODE=standalone nacos/nacos-server:latest

[
    {
        "resource": "test",
        "threshold": 0,
        "tokenCalculateStrategy": 0,
        "controlBehavior": 0,
        "statIntervalInMs": 1000
    }
]

package main
import (
	"fmt"
	"log"
	"math/rand"
	"time"
	"github.com/alibaba/sentinel-golang/api"
	"github.com/alibaba/sentinel-golang/core/base"
	"github.com/alibaba/sentinel-golang/ext/datasource"
	"github.com/alibaba/sentinel-golang/pkg/datasource/nacos"
	"github.com/nacos-group/nacos-sdk-go/clients"
	"github.com/nacos-group/nacos-sdk-go/common/constant"
)
// Nacos 相關(guān)配置
const (
	NamespaceID = "1bfc7fd2-e727-4ec5-b6af-941718755d16"
	Group       = "testGroup"
	DataID      = "testDataId"
)
func main() {
	// 初始化 Sentinel
	err := api.InitDefault()
	if err != nil {
		log.Fatalf("初始化 Sentinel 失敗: %v", err)
	}
	// 配置 Nacos 服務(wù)器信息
	sc := []constant.ServerConfig{
		{
			ContextPath: "/nacos",
			Port:        8848,
			IpAddr:      "10.225.254.130",
		},
	}
	// 配置 Nacos 客戶端信息
	cc := constant.ClientConfig{
		TimeoutMs:   5000,
		NamespaceId: NamespaceID,
	}
	// 創(chuàng)建 Nacos 配置客戶端
	client, err := clients.CreateConfigClient(map[string]interface{}{
		"serverConfigs": sc,
		"clientConfig":  cc,
	})
	if err != nil {
		log.Fatalf("創(chuàng)建 Nacos 配置客戶端失敗: %+v", err)
	}
	// 創(chuàng)建一個(gè)處理流量控制規(guī)則的處理器
	h := datasource.NewFlowRulesHandler(datasource.FlowRuleJsonArrayParser)
	// 創(chuàng)建 Nacos 數(shù)據(jù)源
	nds, err := nacos.NewNacosDataSource(client, Group, DataID, h)
	if err != nil {
		log.Fatalf("創(chuàng)建 Nacos 數(shù)據(jù)源失敗: %+v", err)
	}
	// 初始化 Nacos 數(shù)據(jù)源并加載規(guī)則
	err = nds.Initialize()
	if err != nil {
		log.Fatalf("初始化 Nacos 數(shù)據(jù)源失敗: %+v", err)
	}
	// 模擬請(qǐng)求
	go func() {
		for {
			// 創(chuàng)建 Sentinel 入口節(jié)點(diǎn)，資源名為 "test"
			e, b := api.Entry("test", api.WithTrafficType(base.Inbound))
			if b != nil {
				// 如果請(qǐng)求被 Sentinel 阻止，打印阻止類(lèi)型
				fmt.Printf("請(qǐng)求被 Sentinel 阻止: %v\n", b.BlockType())
			} else {
				// 如果請(qǐng)求通過(guò) Sentinel，打印通過(guò)信息
				fmt.Println("請(qǐng)求通過(guò) Sentinel")
				// 退出 Sentinel 入口節(jié)點(diǎn)
				e.Exit()
			}
			// 模擬處理時(shí)間，隨機(jī)休眠 10-90 毫秒
			time.Sleep(time.Duration(rand.Uint64()%80+10) * time.Millisecond)
		}
	}()
	// 保持主 goroutine 運(yùn)行，防止程序退出
	select {}
}