Go | 中间件 | chi | 多租户 | SaaS

前言

多租户 SaaS 的请求处理比单租户复杂得多：JWT 认证、RBAC 权限、租户隔离、配额检查、审计日志…，

龙讯 POS V2 用 14 个中间件组成请求处理流水线。这篇文章拆解每个中间件的实现，并聚焦使用者在实际开发中的痛点。

说到痛点一，层层叠加导致可维护性差

在多租户程序中。每个业务场景都需要特定的权限和配额校验，如果不把这些逻辑拆分为独立中间件，代码会变得臃肿难懂。将功能拆分成可复用的中间件可以让团队成员快速定位问题并复用已有组件。

说到痛点二。 性能瓶颈与并发控制

高并发情况下全局限流与租户级限流必须，否则会成为程序吞吐量的瓶颈。使用 Redis INCR 并结合滑动窗口算法，可以在毫秒级完成限流判断。

痛点三的观点是。安全合规与审计跟踪

SaaS 环境要求严格记录操作日志，特别是写操作。脱敏与异步写入能满足合规需求，同时降低对业务链路的影响。

一、中间件流水线

Request → RealIP . 获取真实IP
→ Recoverer . Panic恢复
→ Logger . 请求日志
→ Metrics . Promeus指标
→ CORS . 跨域处理
→ SecurityHeaders . 安全头
→ MaxBodySize . 请求体大小限制
→ RateLimit . 全局限流
→ JWTAuth . JWT 认证
→ RBAC . 角色权限检查
→ TenantMiddleware . 租户上下文注入
→ AuditMiddleware . 审计日志记录
→ QuotaCheck . 配额检查
→ TenantRateLimit . 租户级限流
→ Handler . 业务处理

二、JWT 认证中间件

func JWTAuth func http.Handler {
return func http.Handler {
return http.HandlerFunc {
authHeader := r.Header.Get
if authHeader == "" ||!strings.HasPrefix {
writeUnauthorized
return
}
tokenStr := authHeader
claims,err := parseToken
if err!= nil {
writeUnauthorized
return
}
// 检查 Token 黑名单
blacklistKey := fmt.Sprintf
exists,_ := rdb.Exists,blacklistKey).Result
if exists> 0 {
writeUnauthorized
return
}
// 注入上下文
ctx := context.WithValue,claimsKey,claims)
next.ServeHTTP)
})
}
}

三、RBAC 权限中间件

func RequireRole func http.Handler {
roleSet := make
for _。r := range roles { roleSet = true }
return func http.Handler {
return http.HandlerFunc {
claims := GetClaims
if roleSet {
next.ServeHTTP
return
}
writeForbidden
})
}
}
// 四级角色继承
func RequirePlatformAdmin func http.Handler { return RequireRole }
func RequireMerchantAdmin func http.Handler {
return RequireRole
}
func RequireStoreAdmin func http.Handler {
return RequireRole
}
func RequireStaff func http.Handler {
return RequireRole
}

四、租户上下文中间件

func TenantMiddleware http.Handler {
return http.HandlerFunc {
claims := GetClaims
// 检查商户状态
tenant := tenantRepo.FindByID
if tenant == nil {
writeForbidden
return
}
if tenant.Status == "frozen" || tenant.Status == "closed"{
writeJSON(w,nil,model.Error)
return
}
// 注入租户ID和门店ID到上下文
至于ctx，=context.WithValue,tenantIDKey,int64)
ctx=context.WithValue)
ctx=context.WithValue)
next.ServeHTTP)
})
}

五、配额检查中间件

func QuotaCheck funchttp.handler{
...
switch resource{
case "store":
var count int64;db.Model.Where.Count;if count>=tenant.MaxStores{writeJSON;return}
case "dish":
...
case "order":
today的观点是，=time.Now.Format
db.Model.Where=?",tid,today).Count;
怎么说呢，if count>=tenant.MaxOrdersPerDay{writeJSON;话说回来，return}
}
next.ServeHTTP
}

六、审计日志中间件

func AuditMiddleware funchttp.handler{
...
至于body。_，=io.ReadAll;r.Body=io.NopCloser)//重新放回
sanitized:=sanitizeAuditData)
beforeData:=r.Context.Value
go auditSvc.Log,claims.TenantID,claims.UserID,r.Method,r.URL.Path,/*recordId*/0,beforeData,sanitized,extractClientIP,)
next.ServeHTTP
}

七、限流中间件

// 全局限流
func RateLimit funchttp.handler{
...
}
// 租户级限流
func TenantRateLimit funchttp.handler{
...
}

再看路由注册示例。组合不同层次权限及限流策略

// router.go — 中间件与路由组合
// 公共路由
r.Group{
router.Use) //仅全局限流
router.Post
router.Post
})
// 已鉴权路由
r.Group{
router.Use)
router.Use)
router.Use
// store_admin+ 可访问区域
router.Group{
s.Use)
s.Get
s.Post
})
// merchant_admin+ 可访问区域
router.Group{
m.Use)
m.Use)
m.Post
m.Use)
})
// platform_admin 区域
router.Group{
p.Use)
p.Get
p.Get
})
})

表格

• ① 所有 middleware 均以函数式包装形式返回，可直接 Use 调用；
• ② 每个 middleware 均关注单一职责，符合 SOLID 原则；
• ③ TenantMiddleware 提供统一的租戶上下文，为后续配额/审计等做准备；
• ④ 所有外部依赖均；老实说，
• ⑤ 使用 context 携带 Claims 与 Tenant 信息。实现跨路由共享，
.
• * 若你正在建立自己的 SaaS，请参考此架构来解决常见多租戶难题！* 🔍 想进一步学习，查看官方仓库或加入社区讨论～ 🛠️ 开源地址：https://github.com/example/multi‑tenant‑middleware-demo 📚 文档：https://example.com/docs/multi‑tenant‑middleware 📞 联系我们：

14 个中间件。各司其职，组合成完整的请求处理流水线.