package mainimport ("fmt""log""math/rand""time"sentinel "github.com/alibaba/sentinel-golang/api""github.com/alibaba/sentinel-golang/core/base""github.com/alibaba/sentinel-golang/core/flow""github.com/alibaba/sentinel-golang/util"
)func main() {// We should initialize Sentinel first.err := sentinel.InitDefault()if err != nil {log.Fatalf("Unexpected error: %+v", err)}_, err = flow.LoadRules([]*flow.FlowRule{{Resource:        "some-test",MetricType:      flow.QPS,Count:           10,ControlBehavior: flow.Reject,},})if err != nil {log.Fatalf("Unexpected error: %+v", err)return}ch := make(chan struct{})for i := 0; i < 10; i++ {go func() {for {e, b := sentinel.Entry("some-test", sentinel.WithTrafficType(base.Inbound))if b != nil {// Blocked. We could get the block reason from the BlockError.time.Sleep(time.Duration(rand.Uint64()%10) * time.Millisecond)} else {// Passed, wrap the logic here.fmt.Println(util.CurrentTimeMillis(), "passed")time.Sleep(time.Duration(rand.Uint64()%10) * time.Millisecond)// Be sure the entry is exited finally.e.Exit()}}}()}<-ch
}

git clone https://github.com/alibaba/nacos.git
cd nacos/
mvn -Prelease-nacos -Dmaven.test.skip=true clean install -U
ls -al distribution/target/
// change the $version to your actual path
cd distribution/target/nacos-server-$version/nacos/bin

unzip nacos-server-$version.zip 或者 tar -xvf nacos-server-$version.tar.gzcd nacos/bin

[{"resource": "some-test","metricType": 1,"count": 100.0,"controlBehavior":0}
]

module sentinel-go-nacos-examplego 1.13require (github.com/alibaba/sentinel-golang v0.6.0github.com/nacos-group/nacos-sdk-go v1.0.0
)

package mainimport ("fmt""math/rand""sync/atomic""time"sentinel "github.com/alibaba/sentinel-golang/api""github.com/alibaba/sentinel-golang/core/base""github.com/alibaba/sentinel-golang/ext/datasource/nacos""github.com/alibaba/sentinel-golang/util""github.com/nacos-group/nacos-sdk-go/clients""github.com/alibaba/sentinel-golang/ext/datasource""github.com/nacos-group/nacos-sdk-go/common/constant"
)type Counter struct {pass  *int64block *int64total *int64
}func main() {//流量计数器,为了流控打印日志更直观,和集成nacos数据源无关。counter := Counter{pass: new(int64), block: new(int64), total: new(int64)}//nacos server地址sc := []constant.ServerConfig{{ContextPath: "/nacos",Port:        8848,IpAddr:      "127.0.0.1",},}//nacos client 相关参数配置,具体配置可参考https://github.com/nacos-group/nacos-sdk-gocc := constant.ClientConfig{TimeoutMs: 5000,}//生成nacos config client(配置中心客户端)client, err := clients.CreateConfigClient(map[string]interface{}{"serverConfigs": sc,"clientConfig":  cc,})if err != nil {fmt.Printf("Fail to create client, err: %+v", err)return}//注册流控规则Handlerh := datasource.NewFlowRulesHandler(datasource.FlowRuleJsonArrayParser)//创建NacosDataSource数据源//sentinel-go 对应在nacos中创建配置文件的group//flow 对应在nacos中创建配置文件的dataIdnds, err := nacos.NewNacosDataSource(client, "sentinel-go", "flow", h)if err != nil {fmt.Printf("Fail to create nacos data source client, err: %+v", err)return}//nacos数据源初始化err = nds.Initialize()if err != nil {fmt.Printf("Fail to initialize nacos data source client, err: %+v", err)return}//启动统计go timerTask(&counter)//模拟流量ch := make(chan struct{})for i := 0; i < 10; i++ {go func() {for {atomic.AddInt64(counter.total, 1)//some-test 对应在nacos 流控配置文件中的resourcee, b := sentinel.Entry("some-test", sentinel.WithTrafficType(base.Inbound))if b != nil {atomic.AddInt64(counter.block, 1)// Blocked. We could get the block reason from the BlockError.time.Sleep(time.Duration(rand.Uint64()%10) * time.Millisecond)} else {atomic.AddInt64(counter.pass, 1)time.Sleep(time.Duration(rand.Uint64()%10) * time.Millisecond)// Be sure the entry is exited finally.e.Exit()}}}()}<-ch
}//statistic print
func timerTask(counter *Counter) {fmt.Println("begin to statistic!!!")var (oldTotal, oldPass, oldBlock int64)for {time.Sleep(1 * time.Second)globalTotal := atomic.LoadInt64(counter.total)oneSecondTotal := globalTotal - oldTotaloldTotal = globalTotalglobalPass := atomic.LoadInt64(counter.pass)oneSecondPass := globalPass - oldPassoldPass = globalPassglobalBlock := atomic.LoadInt64(counter.block)oneSecondBlock := globalBlock - oldBlockoldBlock = globalBlockfmt.Println(util.CurrentTimeMillis()/1000, "total:", oneSecondTotal, " pass:", oneSecondPass, " block:", oneSecondBlock)}
}

h := datasource.NewFlowRulesHandler(datasource.FlowRulesJsonConverter)nds, err := nacos.NewNacosDataSource(client, "sentinel-go", "flow", h)if err != nil {fmt.Printf("Fail to create nacos data source client, err: %+v", err)return}err = nds.Initialize()if err != nil {fmt.Printf("Fail to initialize nacos data source client, err: %+v", err)return}