北京建网站公司有哪些,邮箱网址注册免费,岳阳网站设计,如需郑州网站建设Tips: 中间记录了解决问题的过程#xff0c;如不感兴趣可直接跳至结尾 首先去es里查询skywalking trace的元数据 可以拿到一串base64加密后的data_binary(直接解密不能用#xff0c;会有乱码#xff0c;可参考https://github.com/apache/skywalking/issues/7423) 对data_b… Tips: 中间记录了解决问题的过程如不感兴趣可直接跳至结尾 首先去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()的逻辑我们先看一下java的源码
public static SegmentObject parseFrom(byte[] data) throws InvalidProtocolBufferException {return (SegmentObject)PARSER.parseFrom(data);
}它的本质就是调用com.google.protobuf提供的parseFrom()函数所以我们只需要用golang版本的proto去反序列化base64解密后的byte即可
反序列化
我先尝试了将java版本的SegmentObject转成json再转成proto文件然后生成pb.go用这里生成的SegmentObject去进行反序列化发现并不可行
最后是通过skywalking-go版本agent的源码找到了对应的pb文件 然后使用里面已经编译好的SegmentObject对象即可
import (encoding/base64fmtgoogle.golang.org/protobuf/prototestingagent skywalking.apache.org/repo/goapi/collect/language/agent/v3
)func TestSkyWalking(t *testing.T) {dataBinary : xxxby, err : base64.StdEncoding.DecodeString(dataBinary)if err ! nil {t.Error(err)}segmentObject : agent.SegmentObject{}err proto.Unmarshal(by, segmentObject)fmt.Printf(%v, segmentObject)}
