元信息传递

微服务之间通过 HTTP 和 gRPC API 进行接口交互，服务架构需要使用统一的元信息（Metadata）传输进行微服务间的传递。 目前 gRPC 中可以携带元信息传递，原理是将元信息放入 HTTP Header 中，这样上游即可收到对应的元信息 信息。 因此在Kratos的设计上，也是通过 HTTP Header 进行传递。在框架中先将元信息包封装成key/value结构，然后携带到 Transport Header 中。

默认格式规范

  • x-md-global-xxx，全局传递，例如 mirror/color/criticality
  • x-md-local-xxx，局部传递，例如 caller

也可以在 middleware/metadata 定制自己的 key prefix，配置固定的元信息传递

使用方式

首先配置 client/server 对应的 middleware/metadata 插件，然后可以自定义传递 key prefix，或者元信息常量，例如 caller。 然后可以通过元信息包中的 NewClientContext 或者 FromServerContext 进行配置或者获取。

注册元信息中间件

  1. // https://github.com/go-kratos/examples/tree/main/metadata
  3. // 注册元信息中间件到 gRPC 或 HTTP 的 server 或 client 中
  5. // server
  6. grpcSrv := grpc.NewServer(
  7.     grpc.Address(":9000"),
  8.     grpc.Middleware(
  9.         metadata.Server(),
  10.     ),
  11. )
  12. httpSrv := http.NewServer(
  13.     http.Address(":8000"),
  14.     http.Middleware(
  15.         metadata.Server(),
  16.     ),
  17. )
  19. // client
  20. conn, err := grpc.DialInsecure(
  21.     context.Background(),
  22.     grpc.WithEndpoint("127.0.0.1:9000"),
  23.     grpc.WithMiddleware(
  24.         metadata.Client(),
  25.     ),
  26. )

获取元信息字段的值

  1. if md, ok := metadata.FromServerContext(ctx); ok {
  2.     extra = md.Get("x-md-global-extra")
  3. }

设置元信息字段的值

  1. ctx = metadata.AppendToClientContext(ctx, "x-md-global-extra", "2233")