How to Enable Rate Limiting and Degradation in Go Microservices with Alibaba Cloud MSE

Rate‑Limiting and Degradation Model

Target : Identify the traffic to protect (e.g., order‑creation API).

Strategy : Define the limiting rule (e.g., 1000 QPS).

FallbackAction : Specify the behavior when the limit is exceeded (e.g., return an error).

Integrating the MSE Go SDK

Download the MSE Go SDK zip from

https://mse-cn-hangzhou.oss-cn-hangzhou.aliyuncs.com/sdk/go/latest/aliyun-mse-go-sdk.zip

and unzip to ./pkg-custom/github.com/aliyun/aliyun-mse-go-sdk-v1.0.7.

Reference the examples in the SDK’s example directory.

Add the dependency in 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

Initialize the SDK at application startup:

import (
    mse_sdk "github.com/aliyun/aliyun-mse-go-sdk"
)

err := mse_sdk.InitMseDefault()
if err != nil {
    log.Fatalf("Failed to init MSE: %+v", err)
}

Deployment Guidelines

Follow the 12‑Factor App principles; store configuration in environment variables. The MSE Go SDK reads the same variables (see SDK documentation for variable names).

Defining Sentinel Resources

Wrap business logic with sentinel.Entry to create a resource:

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

e, b := sentinel.Entry("your-resource-name", sentinel.WithTrafficType(base.Inbound))
if b != nil {
    // request blocked – handle limit (e.g., return error)
} else {
    // business logic
    e.Exit()
}

Framework adapters automatically register resources:

Dubbo‑go : import _ "github.com/alibaba/sentinel-golang/adapter/dubbo" (requires dubbo‑go ≥ 1.3.0).

gRPC : use sentinelPlugin.NewUnaryServerInterceptor() when creating the server.

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

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

Gin : add sentinelPlugin.SentinelMiddleware() to the router.

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

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

Go‑Micro : wrap the service with sentinelPlugin.NewHandlerWrapper().

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

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

Configuring Governance Rules via MSE Console

After SDK integration, flow, isolation, circuit‑breaker, and hotspot rules can be created in the MSE console:

Flow control : set a QPS threshold; requests exceeding the threshold are rejected.

Isolation : limit concurrent threads or connections to protect downstream services.

Circuit‑breaker : monitor response time or error ratio; when thresholds are crossed, the resource is temporarily disabled.

Hotspot protection : identify frequently accessed parameters and limit their usage to avoid cache breakdown.

Reference Links

MSE Go SDK download:

https://mse-cn-hangzhou.oss-cn-hangzhou.aliyuncs.com/sdk/go/latest/aliyun-mse-go-sdk.zip

12‑Factor App methodology:

https://12factor.net/zh_cn/