乐趣区

关于golang:Go-实现项目内链路追踪二

jiezi

上篇文章 Go – 实现我的项目内链路追踪 分享了，通过 链路 ID 能够将 申请信息 、 响应信息 、 调用第三方接口的信息 、 调试信息 、 执行的 SQL 信息 、 执行的 Redis 信息 串起来，记录的具体参数在文件中都有介绍。

这篇文章在下面的根底上，新增 2 个性能点：

  1. 新增将 调用 gRPC 接口信息 记录到 Trace 中；
  2. 新增对记录的敏感信息进行脱敏解决；

调用 gRPC 接口信息

记录参数

Object，构造如下：

type Grpc struct {
    Timestamp   string                 `json:"timestamp"`             // 工夫，格局：2006-01-02 15:04:05
    Addr        string                 `json:"addr"`                  // 地址
    Method      string                 `json:"method"`                // 操作方法
    Meta        metadata.MD            `json:"meta"`                  // Mate 信息
    Request     map[string]interface{} `json:"request"`               // 申请信息
    Response    map[string]interface{} `json:"response"`              // 返回信息
    CostSeconds float64                `json:"cost_seconds"`          // 执行工夫(单位秒)
    Code        string                 `json:"err_code,omitempty"`    // 错误码
    Message     string                 `json:"err_message,omitempty"` // 错误信息
}

如何收集参数

封装了一个 grpclient 包：

  • 反对设置 DialTimeout；
  • 反对设置 UnaryInterceptor；
  • 反对设置 KeepaliveParams；
  • 反对设置 TransportCredentials；

次要是在拦截器 Interceptor 中进行收集。

示例代码

实例化 gRPC client

// TODO 需从配置文件中获取
target := "127.0.0.1:9988"
secret := "abcdef"

clientInterceptor := NewClientInterceptor(func(message []byte) (authorization string, err error) {return GenerateSign(secret, message)
})

conn, err := grpclient.New(target,
    grpclient.WithKeepAlive(keepAlive),
    grpclient.WithDialTimeout(time.Second*5),
    grpclient.WithUnaryInterceptor(clientInterceptor.UnaryInterceptor),
)

return &clientConn{conn: conn,}, err

调用具体方法

// 外围：传递 core.Context 给 Interceptor 应用
client := hello.NewHelloClient(d.grpconn.Conn())
client.SayHello(grpc.ContextWithValueAndTimeout(c, time.Second*3), &hello.HelloRequest{Name: "Hello World"})

敏感信息脱敏

敏感信息脱敏又称为动态数据掩码（Dynamic Data Masking，简称为 DDM）可能避免把敏感数据裸露给未经受权的用户。

依据我的项目要求能够约定一些标准，例如：

类型 要求 示例 阐明
手机号 前 3 后 4 132**7986 定长 11 位数字
邮箱地址 前 1 后 1 l**w@gmail.com 仅对 @ 之前的邮箱名称进行掩码
姓名 隐姓 * 鸿章 将姓氏暗藏
明码 不输入
银行卡卡号 前 6 后 4 6228885676 银行卡卡号最多 19 位数字
身份证号 前 1 后 1 17 定长 18 位

如何实现

我当初的实现计划是：自定义 MarshalJSON()，欢送大佬们提出更好的计划。

示例代码

// 定义 Mobile 类型
type Mobile string

// 自定义 MarshalJSON()
func (m Mobile) MarshalJSON() ([]byte, error) {if len(m) != 11 {return []byte(`"` + m + `"`), nil
    }

    v := fmt.Sprintf("%s****%s", m[:3], m[len(m)-4:])
    return []byte(`"` + v + `"`), nil
}

测试

type message struct {Mobile    ddm.Mobile   `json:"mobile"`}

msg := new(message)
msg.Mobile = ddm.Mobile("13288889999")

marshal, _ := json.Marshal(msg)
fmt.Println(string(marshal))

// 输入：{"mobile":"132****9999"}

小结

本篇文章新增了 2 个实用的性能点，大家连忙应用起来吧。对于 敏感信息脱敏 期待各位大佬不吝赐教，提出更好的解决方案，谢谢！

以上代码都在 go-gin-api 我的项目中，地址：https://github.com/xinliangno…

退出移动版