4.7 调用Sentinel

4.7.1 简介

对官方库的二次封装。

4.7.2 配置规范

配置说明4.7 调用Sentinel - 图1 (opens new window)

4.7.3 用法

访问redis示例4.7 调用Sentinel - 图2 (opens new window)

  1. // run: go run main.go --config=config.toml
  3. package main
  5. import (
  6.     "fmt"
  7.     "math/rand"
  8.     "time"
  10.     "github.com/douyu/jupiter/pkg/util/xgo"
  11.     "github.com/douyu/jupiter"
  12.     "github.com/douyu/jupiter/pkg/sentinel"
  13.     "github.com/douyu/jupiter/pkg/util/xtime"
  14.     "github.com/douyu/jupiter/pkg/xlog"
  15. )
  17. type Engine struct {
  18.     jupiter.Application
  19. }
  21. func NewEngine() *Engine {
  22.     eng := &Engine{}
  23.     if err := eng.Startup(
  24.         eng.exampleSentinel,
  25.     ); err != nil {
  26.         xlog.Panic("startup", xlog.Any("err", err))
  27.     }
  28.     return eng
  29. }
  31. func main() {
  32.     app := NewEngine()
  33.     if err := app.Run(); err != nil {
  34.         panic(err)
  35.     }
  36. }
  38. func (eng *Engine) exampleSentinel() (err error) {
  39.     err = sentinel.StdConfig("test").Build()
  40.     if err != nil {
  41.         panic(fmt.Sprintf("sentinel init failed: %s", err.Error()))
  42.     }
  44.     for k := 0; k < 20; k++ {
  45.         xgo.Go(func() {
  46.             e, b := sentinel.Entry("some-test")
  47.             if b != nil {
  48.                 // 请求被拒绝，在此处进行处理
  49.                 time.Sleep(time.Duration(rand.Uint64()%10) * time.Millisecond)
  50.             } else {
  51.                 // 请求允许通过，此处编写业务逻辑
  52.                 fmt.Println(xtime.CurrentTimeMillis(), "Passed")
  53.                 time.Sleep(time.Duration(rand.Uint64()%10) * time.Millisecond)
  55.                 // 务必保证业务结束后调用 Exit
  56.                 e.Exit()
  57.             }
  58.         })
  59.     }
  61.     return
  62. }

执行 go run main.go —config=config.toml,可以看到如下图结果 image