>백엔드 개발 >Golang >알 수 없는 Protobuf 메시지의 역마샬링을 처리하는 방법은 무엇입니까?

알 수 없는 Protobuf 메시지의 역마샬링을 처리하는 방법은 무엇입니까?

DDD
DDD원래의
2024-12-02 16:51:16173검색

How to Handle Unmarshaling of Unknown Protobuf Messages?

Protobuf Unmarshal: 알 수 없는 메시지 처리

protobuf 페이로드의 메시지 유형을 미리 알 수 없는 시나리오에서는 인터페이스로 역마샬링 {} 유형은 protobuf 메시지 구현이 필요하므로 실행 가능하지 않습니다. 인터페이스.

대체 접근 방식

protobuf 페이로드에 수반되는 최소한 부분적인 정보(예: 문자열 또는 숫자)를 사용할 수 있는 경우 이를 인스턴스화하기 위한 키로 사용할 수 있습니다. 적절한 구체적인 protobuf 유형을 선택한 다음 역마샬링을 수행합니다.

Truely 처리 알 수 없는 메시지

메시지 유형에 대한 모든 정보가 없는 경우 protowire 패키지를 활용하여 protobuf 페이로드의 와이어 형식에서 제한된 정보를 추출할 수 있습니다.

위험 및 제한 사항

알 수 없는 proto 메시지를 구문 분석하면 특정 과제:

  • 모호한 표현: 와이어 형식이 모호하여 특정 데이터 구조의 정확한 유형을 결정하기 어려울 수 있습니다.
  • 손실 하위 필드 정보: 래핑된 메시지는 와이어 유형 및 태그 번호에 대한 컨텍스트를 잃어 잠재적으로 원본을 재구성하는 기능을 제한할 수 있습니다. 메시지 구조.
  • 비 Proto 유형 제외: 래핑된 JSON 또는 XML과 같은 비 Proto 데이터는 정확하게 캡처되지 않을 수 있습니다.

샘플 구현

아래 코드는 알려지지 않은 protobuf를 구문 분석하는 예를 제공합니다. message:

package main

import (
    "fmt"

    "github.com/jhump/protoreflect/desc"
    "github.com/jhump/protoreflect/internal/strategy"
    "github.com/jhump/protoreflect/protopath"
)

// Field represents an individual element parsed from an unknown protobuf message.
type Field struct {
    Tag   Tag
    Val   interface{}
    Length int
}

// Tag represents a field tag with its number and wire type.
type Tag struct {
    Num  int32
    Type int
}

// parseUnknown parses an unknown protobuf message.
func parseUnknown(b []byte, parentMsg *desc.MessageDescriptor) []Field {
    parser := &protowireParser{msg: parentMsg, buf: b}
    return parser.run()
}

type protowireParser struct {
    msg *desc.MessageDescriptor
    buf []byte
}

const wireTypeMask = 0x7

func (p *protowireParser) run() (fields []Field) {
    for len(p.buf) > 0 {
        field, l, err := protowire.ConsumeField(p.buf)
        if err != nil || l < 1 {
            log.Printf("Error parsing field: %v", err)
            p.buf = nil
            return
        }

        tag := Tag{Num: field.Tag, Type: field.WireType & wireTypeMask}

        var v interface{}
        switch field.WireType & wireTypeMask {
        // ... handle different wire types
        }

        fields = append(fields, Field{Tag: tag, Val: v, Length: l})
        p.buf = p.buf[l:]
    }

    return fields
}

결론

알 수 없는 protobuf 메시지를 구문 분석하는 것은 복잡한 작업이지만 protowire 패키지를 활용하면 충분할 수 있는 제한된 정보를 추출할 수 있습니다. 특정 시나리오에 적합합니다. 이 접근 방식은 정확한 표현이 중요한 프로덕션 등급 애플리케이션에는 적합하지 않습니다.

위 내용은 알 수 없는 Protobuf 메시지의 역마샬링을 처리하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.