Golang版本处理Skywalking Trace上报数据

本文介绍: 我先尝试了将java 版本的Se gm entObje ct转成json，再转成pro t o 文件，然后生成 pb.go，用这里生成的。内有我们所有需要的数据，但golang并未找到类似的函数，所以我们需要用golang 实现类似。函数，所以我们只需要用golang 版本的pro t o去反序列化 base64解密后的byte 即可。最后是通过 skywalking–go 版本 agent的源码，找到了对应的pb 文件。Tip s: 中间记录了解决问题的过程，如不感兴趣可直接跳至结尾。的逻辑，我们先看一下java的源码。

Tip s: 中间记录了解决问题的过程，如不感兴趣可直接跳至结尾

首先去es里查询 skywalking trace的元数据

 可以拿到一串base64加密后的data_binary(直接解密不能用，会有乱码，可参考 https://github.com/apache/skywalking/issues/7423)
对data_binary进行base64解密

skywalking提供了一个 java的sdk 可以直接分析这串内容，代码如下所示：

String dataBinary= "xxxxxx"
byte[]decode = Base64.getDecoder().decode(dataBinary);
SegmentObject segmentObject = SegmentObject.parseFrom(decode);
System.out.println(JSON.toJSONString(segmentObject));

segmentObject内有我们所有需要的数据，但golang并未找到类似的函数，所以我们需要用golang 实现类似parseFrom()的逻辑，我们先看一下ja va的源码

public static SegmentObject parseFrom(byte[] data) throws InvalidProtocolBufferException {
    return (SegmentObject)PARSER.parseFrom(data);
}

它的本质就是调用com.google.protobuf提供的parseFrom()函数，所以我们只需要用golang版本的proto去反序列化 base64解密后的byte 即可

反序列化

我先尝试了将ja va版本的SegmentObject转成json，再转成proto 文件，然后生成 pb.go，用这里生成的SegmentObject去进行反序列化，发现并不可行

最后是通过 skywalking–go版本agent的源码，找到了对应的pb 文件
在这里插入图片描述
然后使用里面已经编译好的SegmentObject对象即可

import (
	"encoding/base64"
	"fmt"
	"google.golang.org/protobuf/proto"
	"testing"
	agent "skywalking.apache.org/repo/goapi/collect/language/agent/v3"
)

func TestSkyWalking(t *testing.T) {
	dataBinary := "xxx"
	by, err := base64.StdEncoding.DecodeString(dataBinary)
	if err != nil {
		t.Error(err)
	}
	segmentObject := &amp;agent.SegmentObject{}
	err = proto.Unmarshal(by, segmentObject)
	fmt.Printf("%v", segmentObject)

}