유형 정보 없이 알 수 없는 Protobuf 메시지를 어떻게 구문 분석할 수 있나요?-Golang-php.cn

유형 정보 없이 알 수 없는 Protobuf 메시지를 어떻게 구문 분석할 수 있나요?

Patricia Arquette

풀어 주다： 2024-11-28 01:36:10

원래의

681명이 탐색했습니다.

How Can I Parse Unknown Protobuf Messages Without Type Information?

유형 정보 없이 알 수 없는 프로토 메시지 디마샬링

protobuf의 proto.Unmarshal() 메서드에는 알려진 메시지 유형이 필요하지만 알 수 없는 메시지에는 문제가 발생합니다. . 그러나 protowire 패키지를 사용하면 제한된 정보를 추출할 수 있습니다.

접근 방식:

protowire.ConsumeField()를 사용하여 알 수 없는 메시지 페이로드를 반복합니다.
필드 유형을 식별합니다. be:
- Varint
- Fixed64
- 바이트
- StartGroup
- Fixed32
다음을 기반으로 필드 페이로드를 구문 분석합니다. 해당 유형입니다.
페이로드를 재귀적으로 구문 분석하여 하위 메시지를 처리합니다.

데이터 모델:

type Field struct {
    Tag Tag
    Val Val
}

type Tag struct {
    Num int32
    Type protowire.Type
}

type Val struct {
    Payload interface{}
    Length int
}

로그인 후 복사

파서:

func parseUnknown(b []byte) []Field {
    // Iteratively consume and parse fields
    for len(b) > 0 {
        // Read field tag and length
        n, t, fieldlen := protowire.ConsumeField(b)
        if fieldlen < 1 {
            return nil
        }
        field := Field{Tag: Tag{Num: int32(n), Type: t}}

        // Read and process tag and value content
        _, _, taglen := protowire.ConsumeTag(b[:fieldlen])
        if taglen < 1 {
            return nil
        }
        var v interface{}
        var vlen int
        switch t {
            case protowire.VarintType:
                v, vlen = protowire.ConsumeVarint(b[taglen:fieldlen])
            case protowire.Fixed64Type:
                v, vlen = protowire.ConsumeFixed64(b[taglen:fieldlen])
            case protowire.BytesType:
                v, vlen = protowire.ConsumeBytes(b[taglen:fieldlen])
                sub := parseUnknown(v.([]byte))
                if sub != nil {
                    v = sub
                }
            case protowire.StartGroupType:
                v, vlen = protowire.ConsumeGroup(n, b[taglen:fieldlen])
                sub := parseUnknown(v.([]byte))
                if sub != nil {
                    v = sub
                }
            case protowire.Fixed32Type:
                v, vlen = protowire.ConsumeFixed32(b[taglen:fieldlen])
        }
        if vlen < 1 {
            return nil
        }

        field.Val = Val{Payload: v, Length: vlen - taglen}
        fields = append(fields, field)
        b = b[fieldlen:]
    }
    return fields
}

로그인 후 복사

예(메시지 구조):

message Foo {
  string a = 1;
  string b = 2;
  Bar bar = 3;
}

message Bar {
  string c = 1;
}

로그인 후 복사

예(파싱됨) 출력):

main.Field{Tag:main.Tag{Num:1, Type:2}, Val:main.Val{Payload:[]uint8{0x41}, Length:1}}
main.Field{Tag:main.Tag{Num:2, Type:2}, Val:main.Val{Payload:[]uint8{0x42}, Length:1}}
main.Field{Tag:main.Tag{Num:1, Type:2}, Val:main.Val{Payload:[]uint8{0x43}, Length:1}}
main.Field{Tag:main.Tag{Num:3, Type:2}, Val:main.Val{Payload:[]main.Field{main.Field{Tag:main.Tag{Num:1, Type:2}, Val:main.Val{Payload:[]uint8{0x43}, Length:1}}}, Length:3}}

로그인 후 복사

고려 사항: