提示,我这里使用的是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()) //这是服务的请求拦截器
第四步:编写拦截器,获取前端传递过来的数据。
重点讲解:红箭头部分,黄色区域就是缓存已经做好的链接,提高性能。因为我在储存链接上出现了类型问题,导致缓存失败。希望有大佬可以提点一二。
以下是红箭头的代码:
第五步:如何使用