如何在Golang微服务中接入Dgraph作为社交关系图底座-Golang-PHP中文网

不能直接用 dgo 连 dgraph 的 grpc 端口做线上服务，因其默认无连接池、健康检查和流式请求自动重试，且生产需显式配置 grpc.withtransportcredentials(insecure.newcredentials())，并复用单个 *dgo.dgraph 实例。

如何在golang微服务中接入dgraph作为社交关系图底座

为什么不能直接用 `dgo` 连 Dgraph 的 GRPC 端口做线上服务？

因为 dgo 客户端默认不带连接池和健康检查，微服务频繁建连会触发 connection refused 或 context deadline exceeded；更麻烦的是它不会自动重试失败的 GRPC 流式请求（比如 Query 或 Mutate 中的 streaming response），一出错就得上层兜底。

生产环境必须用 grpc.WithTransportCredentials(insecure.NewCredentials()) 替代默认的 grpc.WithInsecure()（Dgraph 0.22+ 强制要求显式声明）
每个微服务实例应复用一个 *dgo.Dgraph 实例，而不是每次请求 new 一个 client
若 Dgraph 部署在 Kubernetes 中，grpc.Dial 的地址别写 localhost:9080 —— 要用 headless service DNS 名，比如 dgraph-zero.dgraph.svc.cluster.local:5080

`Query` 拼写错误导致空结果却不报错？查这三处

Dgraph 的 Query 是纯字符串，语法错、变量名错、UID 错都不会抛异常，只会返回空 json.RawMessage。最常踩的坑是字段名大小写和 @cascade 位置。

func (c *Client) Query(ctx context.Context, q string, vars map[string]string) 中的 q 必须以 { 开头、} 结尾，中间不能有多余换行或注释（Dgraph 不支持 GraphQL 风格注释）
如果用了 uid 变量（如 $uid），必须确保 vars 里有对应 key，且值是字符串格式 UID（如 "0x123"），不是整数或空字符串
@cascade 必须紧贴字段定义后（如 friend @cascade { name }），写在 block 外或换行后就失效

// ✅ 正确示例
q := `{ me(func: uid($uid)) { name friends @cascade { name } } }`
vars := map[string]string{"$uid": "0xabc"}

如何安全地批量写入关注/拉黑关系而不卡住整个图库？

社交关系变更本质是边（edge）的增删，Dgraph 里用 Mutate 实现。但一次性提交几千条 set 或 delete 会导致事务超时、内存暴涨，甚至触发 exceeded maximum number of mutations 错误。

Golang Spf13 Viper

Go 配置库，使用 spf13/viper — 分层优先级（flag > env >file > KV > default），提供 BindPFlag/BindPFlags、SetEnvPrefix + SetEnvKeyReplace 等功能。

下载

单次 Mutate 的 NQuad 数量控制在 100 条以内（Dgraph 默认 limit 是 1000，但实际建议压到 100 保证成功率）
用 dgo.Txn 包裹多次 Mutate，并设 ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)，避免长事务阻塞
删除关系时别只写 _:user_a <follows> _:user_b .</follows> —— 必须带上 uid 或 expand(_all_) 精确匹配，否则可能误删其他边

Go 微服务重启时怎么避免 Dgraph 连接泄漏？

常见做法是在 main() 里 defer client.Close()，但这只对进程退出有效；K8s rolling update 时旧 pod 可能被 SIGTERM 强杀，defer 来不及执行。

注册 os.Interrupt 和 syscall.SIGTERM 信号，在 handler 里调用 client.Close() 并等待 GRPC 连接彻底断开（time.Sleep(200 * time.Millisecond)）
dgo.Dgraph 实例本身没有 Close() 方法，真正要关的是底层 grpc.ClientConn —— 你得从 client.GetStub().(*grpc.ClientConn) 取出来手动 Close()
若用 github.com/dgraph-io/dgo/v220（v220+），记得升级到 v220.2 以上，否则 GetStub() 返回类型不兼容