关于阿里云:阿里云-MSE-支持-Go-语言流量防护

作者：卜比

概述

随着 Go 语言、云原生的宽泛采纳，Go 语言在微服务场景中应用的越来越宽泛，对 Go 语言微服务的治理、限流降级需要也越来越强。

在 Go 语言中，尽管社区提供了 go.uber.org/ratelimit 等限流库，但其一，对多语言反对有余，只反对 Go，其二，性能上，限流降级会细分为流控、隔离、熔断、热点等性能，也不反对动静配置，在性能反对度上不够欠缺。

阿里云微服务引擎（MSE）联合 Sentinel，给 Go 语言、Java 语言利用带来微服务治理能力。本文将给大家介绍如何在 Go 语言微服务利用中应用限流降级能力。

什么是限流降级

在微服务利用中，限流降级次要分为三步：

• Target: 针对什么样的流量
• Strategy: 限流降级的策略
• FallbackAction: 触发后的行为 

比方，针对订单创立接口（Target），咱们限度申请为 1000QPS（Strategy），触发限流后，申请返回异样（FallbackAction）。

在阿里云 MSE 反对通过开源 Sentinel 的形式来定义资源，并从 MSE 获取、利用限流降级规定，整体接入如下：

如何应用 MSE 限流降级

利用接入

1. 下载 MSE Go SDK [ 1] ，解压到我的项目的./pkg-custom/github.com/aliyun/aliyun-mse-go-sdk-v1.0.7 目录。

<!—->

1. 1. 能够参考 SDK 的 example 目录下的例子，来进行接入。
2. 在 go.mod 文件中，增加如下依赖申明：

require (github.com/aliyun/aliyun-mse-go-sdk v1.0.7)

replace github.com/aliyun/aliyun-mse-go-sdk => ./pkg-custom/github.com/aliyun/aliyun-mse-go-sdk

3. 在利用的启动过程中，增加 MSE SDK 初始化命令：

import (mse_sdk "github.com/aliyun/aliyun-mse-go-sdk")
// 在利用的初始化逻辑中退出以下代码。// Sentinel core 的初始化蕴含在了这外面。如果之前有调用过 Sentinel 的初始化函数，须要去掉。err := mse_sdk.InitMseDefault
if err != nil {log.Fatalf("Failed to init MSE: %+v", err)
}

利用部署

在云原生部署形式中，通常的部署标准是 12 因子 [ 2]，其中对于配置， 举荐将利用的配置存储于环境变量中。这样利用在部署时，只须要切换不同的环境变量，就能够接入不同的环境。

同样的，MSE-Go-SDK 也举荐大家通过环境变量的形式接入 MSE，应用的环境变量如下：

依照上述步骤接入后，能够在利用列表页面看到咱们接入的利用：

资源定义

在文章开始的时候，咱们提到了限流降级 =Target+Strategy+FallbackAction。所以第一步就是要定义 Target。

• Sentinel 定义资源

MSE 反对用户通过 Sentinel 定义的资源，只须要用如下代码块包裹业务逻辑即可：

import (sentinel "github.com/alibaba/sentinel-golang/api")

// Entry 办法用于埋点
e, b := sentinel.Entry("your-resource-name", sentinel.WithTrafficType(base.Inbound))
if b != nil {// 申请被流控，能够从 BlockError 中获取限流详情} else {
  // 申请能够通过，在此处编写您的业务逻辑
  // 务必保障业务逻辑完结后 Exit
  e.Exit()}

当然，在日常的业务开发中，开发者经常通过微服务框架提供服务，比方 dubbo-go、Gin、gRPC 等，自然而然的，咱们心愿可能将这些服务注册为资源：

• dubbo-go 形式定义资源

只须要引入 dubbo-go adaptor 即可主动注册资源到 MSE：

import (_ "github.com/alibaba/sentinel-golang/adapter/dubbo")

• Dubbo 利用是在代码中通过 import 包的模式引入 Dubbo adapter，其中的 init() 函数会主动注入相干 filter。Dubbo-Go 版本须要≥1.3.0。Sentinel Dubbo adapter 会主动统计所有 provider 和 consumer 的调用。
• gRPC 利用接入

import (
  sentinelPlugin "github.com/alibaba/sentinel-golang/adapter/grpc"
  "google.golang.org/grpc"
)

s := grpc.NewServer(grpc.UnaryInterceptor(sentinelPlugin.NewUnaryServerInterceptor()))

• gRPC 利用在 gRPC 的初始化代码中引入 Sentinel 提供的 interceptor，Sentinel 针对 Server 和 Client 都提供了 unary 和 streaming 两种 interceptor，以上代码以 Server 端为例。默认的限流解决逻辑是返回 Sentinel 的 BlockError。您也能够在创立 interceptor 时提供自定义的 fallback 解决逻辑。
• Gin Web 利用接入

import (
  sentinelPlugin "github.com/alibaba/sentinel-golang/adapter/gin"
  "github.com/gin-gonic/gin"
)

r := gin.New()
r.Use(sentinelPlugin.SentinelMiddleware())

• Gin Web 利用在 Gin 的初始化代码中引入 SentinelMiddleware。Sentinel 会对每个 API route 进行统计，资源名称相似于 GET:/foo/:id。默认的限流解决逻辑是返回 429 (Too Many Requests) 错误码。
• Micro 利用接入

import (

  sentinelPlugin "github.com/alibaba/sentinel-golang/adapter/micro"
  "github.com/micro/go-micro/v2"
)

svc := micro.NewService(micro.WrapHandler(sentinelPlugin.NewHandlerWrapper()))

• 在 Go-Micro 的初始化代码中引入 Sentinel 提供的 wrapper。Sentinel 针对 Go-Micro Server 和 Client 都提供了 wrapper。以上代码以  Server 端为例。埋点默认会提取服务 method 作为资源名，默认的流控解决逻辑是返回 Sentinel 的 BlockError。您也能够在创立 wrapper 时提供自定义的 fallback 解决逻辑。

如何配置限流降级规定

通过上述形式接入后，就能够配置流控规定、隔离规定、熔断规定、热点规定等规定了：

• 查看利用

接入后，能够在利用列表页面看到咱们接入的利用：

在利用详情页面，也能够看到利用的概览数据：

能够查看代码中注册的资源：

• 配置流控规定

能够针对每种资源设置流控规定：

设置流控规定后，能够看到回绝 QPS 减少、通过 QPS 缩小：

抉择流控防护，能够预设服务可接受的 QPS 流量，当流量达到设定阈值时立刻拦挡超出局部的申请，防止利用被刹时的流量顶峰冲垮。

• 配置隔离规定

抉择隔离防护，能够通过管制接口或依赖的并发线程数，来保证系统的稳定性。通常实用于利用外部或上游依赖呈现不稳固的场景，例如慢 SQL、上游利用响应工夫变长等。

• 配置熔断规定

抉择熔断防护，能够监控利用外部或者上游依赖的响应工夫或异样比例，当达到指定的阈值时立刻升高上游依赖的优先级。在指定的工夫内，零碎不会调用该不稳固的资源，防止利用受到影响，从而保障利用高可用性。当指定工夫过后，再从新复原对该资源的调用。

• 配置热点规定

抉择热点参数防护，AHAS 将剖析统计参数，即资源调用过程中的调用次数较高的参数，并依据配置的热点规定对蕴含热点参数的资源调用进行限流，爱护零碎稳定性。热点即常常被拜访的数据。例如在以下场景中须要统计某个热点数据中拜访频次最高的 Top 数据，并对其拜访进行限度。

• 针对一段时间内最频繁购买的商品 ID 进行限度，避免击穿缓存而导致大量申请到数据库的情景。
• 针对一段时间内频繁拜访的用户 ID 进行限度，避免歹意刷单。

MSE 微服务治理布局

OpenSergo 开源我的项目联结 Sentinel 我的项目，正在制订、欠缺限流降级规范，不便不同语言利用通过对立管制面来实现对立的微服务治理。

阿里云微服务引擎（MSE）也会逐渐反对 OpenSergo 规范，让微服务开发者可能应用 OpenSergo 来对立治理不同语言的微服务利用。

同时，阿里云 MSE 也会基于微服务治理进行摸索，摸索实现流量治理、限流降级、数据库治理、音讯治理等性能，给微服务开发者带来全生命周期的微服务治理。

MSE 注册配置核心专业版首购享 9 折优惠，MSE 云原生网关预付费全规格享 9 折优惠。点击此处，即享优惠！

参考链接：

[1] MSE Go SDK：

https://mse-cn-hangzhou.oss-c…

[2] 12 因子：

https://12factor.net/zh_cn/