如何为Tarantool 2.10+编码MessagePack的DateTime与UUID类型？

1. UUID 类型编码 #

Tarantool 使用 MessagePack 扩展类型（Ext Type） 表示 UUID，具体规则：

• 扩展类型码：0x30（十进制48）
• 数据部分：16字节的原始UUID二进制数组（与标准UUID的字节表示完全一致）

2. DateTime 类型编码 #

同样基于 MessagePack 扩展类型，规则如下：

• 扩展类型码：0x26（十进制38）
• 数据部分：12字节的小端序结构体：
  • 前8字节：int64 类型，存储相对于 1970-01-01T00:00:00Z 的 Unix 时间戳（秒数，支持正负值）
  • 后4字节：uint32 类型，存储纳秒数（范围 0~999,999,999）

RMP 原生支持 MessagePack 扩展类型，可通过自定义序列化逻辑适配 Tarantool 的格式，以下是具体实现示例：

依赖准备 #

在 Cargo.toml 中添加所需依赖：

[dependencies]
rmp = "0.8"
rmp-serde = "1.1"
uuid = { version = "1.4", features = ["serde"] }
chrono = { version = "0.4", features = ["serde", "utc"] }
byteorder = "1.4"
serde = { version = "1.0", features = ["derive"] }

1. UUID 类型序列化 #

方式1：直接实现 RMP 的 Encode trait #

use uuid::Uuid;
use rmp::{Encode, Ext, encode::BufWriter};

impl Encode for Uuid {
    fn encode<'a>(&self, buf: &mut BufWriter<'a>) -> Result<(), rmp::encode::Error> {
        let uuid_bytes = self.as_bytes();
        let ext = Ext::new(0x30, uuid_bytes.to_vec());
        ext.encode(buf)
    }
}

方式2：结合 Serde 自定义序列化 #

如果使用 rmp-serde 进行序列化，可通过包装类型实现：

use uuid::Uuid;
use serde::{Serialize, Serializer};
use rmp_serde::ext::Ext;

impl Serialize for Uuid {
    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
    where
        S: Serializer,
    {
        let ext = Ext::new(0x30, self.as_bytes());
        ext.serialize(serializer)
    }
}

2. DateTime 类型序列化 #

方式1：实现 RMP 的 Encode trait #

use chrono::{DateTime, Utc};
use rmp::{Encode, Ext, encode::BufWriter};
use byteorder::{LittleEndian, WriteBytesExt};
use std::io::Write;

impl Encode for DateTime<Utc> {
    fn encode<'a>(&self, buf: &mut BufWriter<'a>) -> Result<(), rmp::encode::Error> {
        let secs = self.timestamp();
        let nanos = self.timestamp_subsec_nanos();

        let mut data = Vec::with_capacity(12);
        data.write_i64::<LittleEndian>(secs)
            .map_err(|e| rmp::encode::Error::InvalidData(e.to_string()))?;
        data.write_u32::<LittleEndian>(nanos)
            .map_err(|e| rmp::encode::Error::InvalidData(e.to_string()))?;

        let ext = Ext::new(0x26, data);
        ext.encode(buf)
    }
}

方式2：结合 Serde 自定义序列化 #

use chrono::{DateTime, Utc};
use serde::{Serialize, Serializer};
use rmp_serde::ext::Ext;
use byteorder::{LittleEndian, WriteBytesExt};
use std::io::Write;

impl Serialize for DateTime<Utc> {
    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
    where
        S: Serializer,
    {
        let secs = self.timestamp();
        let nanos = self.timestamp_subsec_nanos();

        let mut data = Vec::with_capacity(12);
        data.write_i64::<LittleEndian>(secs)
            .map_err(|e| serde::ser::Error::custom(e.to_string()))?;
        data.write_u32::<LittleEndian>(nanos)
            .map_err(|e| serde::ser::Error::custom(e.to_string()))?;

        let ext = Ext::new(0x26, data);
        ext.serialize(serializer)
    }
}

验证注意事项 #

• 必须严格匹配 Tarantool 的扩展类型码和数据结构，否则无法被正确解析
• DateTime 需转换为 UTC 时间后再序列化，避免时区差异导致错误
• 若需反序列化 Tarantool 返回的对应类型，反向实现 Decode trait（或 Serde 的 Deserialize）即可

内容的提问来源于stack exchange，提问作者Meas