Struct MessageParser 

pub struct MessageParser { /* private fields */ }

消息解析器

Implementations

impl MessageParser

pub fn new( format: SerializationFormat, compression: CompressionAlgorithm, encryption: EncryptionAlgorithm, ) -> Self

创建新的消息解析器

pub fn with_custom_format( format_name: &str, compression: CompressionAlgorithm, encryption: EncryptionAlgorithm, ) -> Self

创建使用自定义序列化格式的解析器

参数

• format_name: 自定义序列化格式名称（必须在注册表中注册）
• compression: 压缩算法
• encryption: 加密算法

示例

use flare_core::common::message::MessageParser;
use flare_core::common::compression::CompressionAlgorithm;
use flare_core::common::encryption::EncryptionAlgorithm;

// 创建使用自定义格式的解析器
let parser = MessageParser::with_custom_format(
    "messagepack",
    CompressionAlgorithm::None,
    EncryptionAlgorithm::None,
);

pub fn new_with_format_compression( format: SerializationFormat, compression: CompressionAlgorithm, ) -> Self

创建使用指定格式和压缩的解析器

pub fn protobuf() -> Self

创建使用 Protobuf 格式的解析器

pub fn json() -> Self

创建使用 JSON 格式的解析器

pub fn default_format(&self) -> SerializationFormat

获取默认序列化格式

pub fn default_compression(&self) -> CompressionAlgorithm

获取默认压缩算法

pub fn default_encryption(&self) -> EncryptionAlgorithm

获取默认加密算法

pub fn parse(&self, data: &[u8]) -> Result<Frame>

解析消息（自动检测格式、压缩和加密）

处理流程：解密 -> 解压缩 -> 反序列化 默认使用容错模式（解密失败时尝试作为未加密数据处理）

pub fn parse_with_fallback( &self, data: &[u8], allow_fallback: bool, ) -> Result<Frame>

解析消息（支持容错标记）

参数

• data: 要解析的原始数据
• allow_fallback: 如果为 true，启用容错模式：
  • 解密失败时尝试作为未加密数据处理
  • 解压缩失败时尝试作为未压缩数据处理
  • 反序列化失败时尝试所有序列化格式
  • 如果为 false，严格模式：任何步骤失败都直接返回错误

处理流程

解密（根据 allow_fallback 决定是否容错） -> 解压缩（根据 allow_fallback 决定是否容错） -> 反序列化（根据 allow_fallback 决定是否容错）

pub fn parse_with_format( &self, data: &[u8], format: SerializationFormat, ) -> Result<Frame>

根据指定格式解析消息

pub fn serialize(&self, frame: &Frame) -> Result<Vec<u8>>

序列化消息（使用默认格式、压缩和加密）

pub fn serialize_with_format( &self, frame: &Frame, format: SerializationFormat, compression: CompressionAlgorithm, encryption: EncryptionAlgorithm, ) -> Result<Vec<u8>>

序列化消息（指定格式、压缩和加密）

处理流程：序列化 -> 压缩 -> 加密

pub fn serialize_with_format_compression( &self, frame: &Frame, format: SerializationFormat, compression: CompressionAlgorithm, ) -> Result<Vec<u8>>

序列化消息（指定格式和压缩，使用默认加密）

pub fn get_compression_from_frame(frame: &Frame) -> CompressionAlgorithm

从 Frame 的 metadata 中读取压缩算法

pub fn should_compress_payload( payload_len: usize, compression: &CompressionAlgorithm, ) -> bool

判断序列化后的 payload 是否必须按协商结果压缩。

pub fn get_format_from_frame(frame: &Frame) -> Option<SerializationFormat>

从 Frame 的 metadata 中读取序列化格式

pub fn get_encryption_from_frame(frame: &Frame) -> EncryptionAlgorithm

从 Frame 的 metadata 中读取加密算法

Trait Implementations

impl Clone for MessageParser

fn clone(&self) -> MessageParser

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MessageParser

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.