Go Sentinel 动态数据源配置指南(示例详解)

[
  {
    "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() {
	// 定义流控规则的文件路径
	filePath := "./file/rules.json"
	// 创建一个处理流量控制规则的处理器
	h := datasource.NewFlowRulesHandler(datasource.FlowRuleJsonArrayParser)
	// 创建一个基于文件的数据源，使用指定的文件路径和处理器
	ds := file.NewFileDataSource(filePath, h)
	// 初始化数据源，如果失败则记录错误并退出程序
	err := ds.Initialize()
	if err != nil {
		log.Fatalf("创建文件数据源失败: %+v", err)
	}
	// 启动一个 goroutine 模拟请求
	go func() {
		for {
			// 创建 Sentinel 入口节点，资源名为 "test"
			e, b := api.Entry("test", api.WithTrafficType(base.Inbound))
			if b != nil {
				// 如果请求被 Sentinel 阻止，打印阻止类型
				fmt.Printf("请求被 Sentinel 阻止: %v\n", b.BlockType())
			} else {
				// 如果请求通过 Sentinel，打印通过信息
				fmt.Println("请求通过 Sentinel")
				// 退出 Sentinel 入口节点
				e.Exit()
			}
			// 模拟处理时间，随机睡眠 10-90 毫秒
			time.Sleep(time.Duration(rand.Uint64()%80+10) * time.Millisecond)
		}
	}()
	// 主 goroutine 无限阻塞，防止程序退出
	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 相关配置
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 服务器信息
	sc := []constant.ServerConfig{
		{
			ContextPath: "/nacos",
			Port:        8848,
			IpAddr:      "10.225.254.130",
		},
	}
	// 配置 Nacos 客户端信息
	cc := constant.ClientConfig{
		TimeoutMs:   5000,
		NamespaceId: NamespaceID,
	}
	// 创建 Nacos 配置客户端
	client, err := clients.CreateConfigClient(map[string]interface{}{
		"serverConfigs": sc,
		"clientConfig":  cc,
	})
	if err != nil {
		log.Fatalf("创建 Nacos 配置客户端失败: %+v", err)
	}
	// 创建一个处理流量控制规则的处理器
	h := datasource.NewFlowRulesHandler(datasource.FlowRuleJsonArrayParser)
	// 创建 Nacos 数据源
	nds, err := nacos.NewNacosDataSource(client, Group, DataID, h)
	if err != nil {
		log.Fatalf("创建 Nacos 数据源失败: %+v", err)
	}
	// 初始化 Nacos 数据源并加载规则
	err = nds.Initialize()
	if err != nil {
		log.Fatalf("初始化 Nacos 数据源失败: %+v", err)
	}
	// 模拟请求
	go func() {
		for {
			// 创建 Sentinel 入口节点，资源名为 "test"
			e, b := api.Entry("test", api.WithTrafficType(base.Inbound))
			if b != nil {
				// 如果请求被 Sentinel 阻止，打印阻止类型
				fmt.Printf("请求被 Sentinel 阻止: %v\n", b.BlockType())
			} else {
				// 如果请求通过 Sentinel，打印通过信息
				fmt.Println("请求通过 Sentinel")
				// 退出 Sentinel 入口节点
				e.Exit()
			}
			// 模拟处理时间，随机休眠 10-90 毫秒
			time.Sleep(time.Duration(rand.Uint64()%80+10) * time.Millisecond)
		}
	}()
	// 保持主 goroutine 运行，防止程序退出
	select {}
}