程序包 org.springframework.http.codec.protobuf

类 ProtobufDecoder

  • 所有已实现的接口:
    Decoder<com.google.protobuf.Message>
    public class ProtobufDecoder
extends ProtobufCodecSupport
implements Decoder<com.google.protobuf.Message>
    A Decoder that reads Messages using Google Protocol Buffers.

    Flux deserialized via decode(Publisher, ResolvableType, MimeType, Map) are expected to use delimited Protobuf messages with the size of each message specified before the message itself. Single values deserialized via decodeToMono(Publisher, ResolvableType, MimeType, Map) are expected to use regular Protobuf message format (without the size prepended before the message).

    Notice that default instance of Protobuf message produces empty byte array, so Mono.just(Msg.getDefaultInstance()) sent over the network will be deserialized as an empty Mono.

    To generate Message Java classes, you need to install the protoc binary.

    This decoder requires Protobuf 3 or higher, and supports "application/x-protobuf" and "application/octet-stream" with the official "com.google.protobuf:protobuf-java" library.

    从以下版本开始:
    5.1
    作者:
    S茅bastien Deleuze
    另请参阅:
    ProtobufEncoder

    • 构造器详细资料

      • ProtobufDecoder

        public ProtobufDecoder​(com.google.protobuf.ExtensionRegistry extensionRegistry)
        Construct a new ProtobufDecoder with an initializer that allows the registration of message extensions.
        参数:
        extensionRegistry - a message extension registry

    • 方法详细资料

      • setMaxMessageSize

        public void setMaxMessageSize​(int maxMessageSize)
        The max size allowed per message.

        By default, this is set to 256K.

        参数:
        maxMessageSize - the max size per message, or -1 for unlimited

      • canDecode

        public boolean canDecode​(ResolvableType elementType,
                         @Nullable
                         MimeType mimeType)
        从接口复制的说明: Decoder
        Whether the decoder supports the given target element type and the MIME type of the source stream.
        指定者:
        canDecode 在接口中 Decoder<com.google.protobuf.Message>
        参数:
        elementType - the target element type for the output stream
        mimeType - the mime type associated with the stream to decode (can be null if not specified)
        返回:
        true if supported, false otherwise

      • decode

        public com.google.protobuf.Message decode​(DataBuffer dataBuffer,
                                          ResolvableType targetType,
                                          @Nullable
                                          MimeType mimeType,
                                          @Nullable
                                          Map<String,​Object> hints)
                                   throws DecodingException
        从接口复制的说明: Decoder
        Decode a data buffer to an Object of type T. This is useful for scenarios, that distinct messages (or events) are decoded and handled individually, in fully aggregated form.
        指定者:
        decode 在接口中 Decoder<com.google.protobuf.Message>
        参数:
        dataBuffer - the DataBuffer to decode
        targetType - the expected output type
        mimeType - the MIME type associated with the data
        hints - additional information about how to do encode
        返回:
        the decoded value, possibly null
        抛出:
        DecodingException