关于api:Sentinel-GO-API-使用指南

39次阅读

共计 2133 个字符,预计需要花费 6 分钟才能阅读完成。

工具与资源核心
帮忙开发者更加高效的工作,提供围绕开发者全生命周期的工具与资源
https://developer.aliyun.com/…

API 使用指南

用户接入应用 Sentinel Go (后文均用 Sentinel 示意 Sentinel Go) 次要须要须要以下几步:

  1. 对 Sentinel 的运行环境进行相干配置并初始化。API 接口应用细节能够参考:配置形式
  2. 埋点(定义资源),该步骤次要是确定零碎中有哪些资源须要防护,资源定义可参考:老手指南
  3. 配置规定,该步骤次要是为每个资源都配置具体的规定,规定的配置可参考:老手指南以及各个模块的应用文档。
  4. 编写资源防护的入口和进口代码。开释形式可参考:老手指南

    通用配置及初始化

    应用 Sentinel 须要在利用启动时对 Sentinel 运行环境进行相干配置并触发初始化。api 包下提供如下函数:
    • InitDefault():从环境变量指定的配置文件以及环境变量中读取相应配置来初始化 Sentinel,若环境变量不存在则应用默认值。
    • Init(configPath string):从给定的 YAML 文件中读取相应配置来初始化 Sentinel。
    • InitWithConfig(confEntity config.Entity): 用户硬编码配置对象 config.Entity 来初始化 Sentinel。
    通用配置项加载策略和配置项请参考 配置形式应用文档
    示例代码:

  5. import (
  6. sentinel “github.com/alibaba/sentinel-golang/api”
  7. )
  8. func initSentinel() {
  9. err := sentinel.Init(confPath)
  10. if err != nil {
  11. // 初始化 Sentinel 失败
  12. }
  13. }
    留神:必须胜利调用 Sentinel 的初始化函数当前再调用埋点 API。

    埋点(定义资源)

    应用 Sentinel 的 Entry API 将业务逻辑封装起来,这一步称为“埋点”。每个埋点都有一个资源名称(resource),代表触发了这个资源的调用或拜访。
    埋点 API 位于 api 包中:
    • Entry(resource string, opts …Option) (base.SentinelEntry, base.BlockError)
    其中 resource 代表埋点资源名,opts 代表埋点配置。这里须要留神的是,返回值参数列表的第一个和第二个参数是互斥的,也就是说,如果 Entry 执行 pass,那么 Sentinel 会返回 (base.SentinelEntry, nil);如果 Entry 执行 blocked,那么 Sentinel 会返回(nil, base.BlockError)。
    目前反对以下埋点配置:
    • WithTrafficType(entryType base.TrafficType):标记该埋点资源的流量类型,其中 Inbound 代表入口流量,Outbound 代表进口流量。若不指定,默认为 Outbound。
    • WithResourceType(resourceType base.ResourceType):标记该埋点资源的分类。
    • WithAcquireCount(acquireCount uint32):标记每次触发该埋点计为几次调用(能够了解为 batch count)。若不指定,默认为 1。
    • WithArgs(args …interface{}):埋点携带的参数列表,为热点参数统计预留。
    • WithSlotChain(chain *base.SlotChain):埋点执行的查看的 slotchain,若不指定,默认应用全局 slotchain
    埋点 API 示例:

  14. import (
  15. sentinel “github.com/alibaba/sentinel-golang/api”
  16. )
  17. // Entry 办法用于埋点
  18. e, b := sentinel.Entry(“your-resource-name”, sentinel.WithTrafficType(base.Inbound))
  19. if b != nil {
  20. // 申请被流控,能够从 BlockError 中获取限流详情
  21. // block 后不须要进行 Exit()
  22. } else {
  23. // 申请能够通过,在此处编写您的业务逻辑
  24. // 务必保障业务逻辑完结后 Exit
  25. e.Exit()
  26. }
    若该次调用被回绝,则 Entry API 会返回 BlockError 代表被 Sentinel 限流。BlockError 提供了限流起因以及触发的规定等信息,能够不便开发者获取相干信息进行记录和解决。

    规定配置

    硬编码方式

    Sentinel 反对原始的硬编码方式加载规定,能够通过各个模块的 LoadRules(rules) 函数加载规定。以流控规定为例:

  27. _, err = flow.LoadRules([]*flow.Rule{
  28. {
  29. Resource: “some-test”,
  30. Threshold: 10,
  31. TokenCalculateStrategy: flow.Direct,
  32. ControlBehavior: flow.Reject,
  33. },
  34. })
  35. if err != nil {
  36. // 加载规定失败,进行相干解决
  37. }

    动静数据源

    Sentinel 提供动静数据源接口进行扩大,用户能够通过动静文件、etcd、consul、nacos 等配置核心来动静地配置规定。

正文完
 0