go_zero,多租户业务模式下,实行租户数据库分库。api服务与rpc服务传递隐藏数据。

提示,我这里使用的是go_zero+gorm进行数据库进行操作。其次,是有对gorm进行二次封装的。抄大佬的,未经允许没法贴出来。

第一步,将需要的分库标准放置在上下文中。我这边是以租户ID进行数据库区分。创建一个新的上下文。

提示:我的api服务上下文,是有用户的相关id,你也可以以别的方式获取。
重点在于:metadata,这是将你需要在rpc服务中用到的数据,以元数据的方式传到rpc服务中,这样你就能在元数据获取到信息。

func NewContext(ctx context.Context) context.Context {
	tenantId := ctx.Value(TenantIdKey).(json.Number).String() // 获取用户id
	md, ok := metadata.FromOutgoingContext(ctx)
	if !ok {
		md = metadata.Pairs()
	}
	md.Append(TenantIdKey, tenantId)
	return metadata.NewOutgoingContext(ctx, md)
}

第二步:在api服务中进行使用,刚才新创建的函数。

重点:我这里用了NewContext这个函数。

第三步:在rpc服务中,启动入口下自定义拦截器。

	s.AddUnaryInterceptors(interceptors.DatabaseInterceptor())    //这是服务的请求拦截器

 第四步:编写拦截器,获取前端传递过来的数据。

重点讲解:红箭头部分,黄色区域就是缓存已经做好的链接,提高性能。因为我在储存链接上出现了类型问题,导致缓存失败。希望有大佬可以提点一二。
以下是红箭头的代码:

第五步:如何使用