您现在的位置：程式碼之家 >> 編程語言 > >> C語言 >> C++ >> 關於C++

Google Protobuf 網路傳輸方案：自動反射訊息類型的編碼與解碼

編輯：關於C++

解決核心問題：接收 Protobuf 資料後，如何自動建立具體 Message 物件並反序列化。「自動」意指新增訊息類型時無需修改此部分程式碼、無需手動註冊。Protobuf 本身具備強大反射功能，可根據型別名稱建立具體 Message 物件，直接利用即可。

網路傳輸使用 Protobuf 的兩大問題

長度： Protobuf 無自帶長度資訊，需應用層自行分包（通常加固定長度長度前綴）
類型： Protobuf 無自帶類型資訊，需發送方傳遞類型，接收方據以建立具體 Message 物件

常見山寨做法及其缺陷

int typeId： 需維護全域唯一性，跨部門協作需中央分配機制
string typeName + lookup table： 唯一性較易（可用 fully qualified name），但每新增類型需手動修改查找表初始化碼

Protobuf 內建反射機制：正確解法

核心類別關係

Descriptor：每個具體 Message 類型對應一個全域 Descriptor 物件
DescriptorPool：可根據型別名稱查找 Descriptor*
MessageFactory：可根據 Descriptor* 取得 prototype（default instance）
Message::New()：原型模式，從 prototype 複製新物件

關鍵不變式驗證

const Descriptor* descriptor = DescriptorPool::generated_pool()->FindMessageTypeByName(type_name);
assert(descriptor == ConcreteMessage::descriptor());

const Message* prototype = MessageFactory::generated_factory()->GetPrototype(descriptor);
assert(prototype == &ConcreteMessage::default_instance());

Message* new_obj = prototype->New();
assert(typeid(*new_obj) == typeid(ConcreteMessage::default_instance()));

自動建立 Message 核心程式碼

Message* createMessage(const std::string& typeName) {
    Message* message = NULL;
    const Descriptor* descriptor = DescriptorPool::generated_pool()->FindMessageTypeByName(typeName);
    if (descriptor) {
        const Message* prototype = MessageFactory::generated_factory()->GetPrototype(descriptor);
        if (prototype) {
            message = prototype->New();
        }
    }
    return message; // 呼叫端負責釋放，muduo 中用 shared_ptr 管理
}

自訂 Protobuf 傳輸格式

struct ProtobufTransportFormat __attribute__ ((__packed__)) {
    int32_t len;              // 總長度
    int32_t nameLen;          // 類型名長度
    char typeName[nameLen];   // 類型名 (含結尾 \0)
    char protobufData[len-nameLen-8]; // Protobuf 序列化資料
    int32_t checkSum;         // Adler32(nameLen + typeName + protobufData)
};