msgpack

MessagePack配置读取

用于读取输出类型为msgpack的转换结果

由于MessagePack 支持的语言很多，并且接口不统一，所以不提供读取库。所有打包的数据类似下面的形式：

{
    header : {
        xres_ver: "版本号字符串",
        data_ver: "版本号字符串",
        count: 配置记录个数,
        hash_code: "hash算法:hash值",
    }
    data_block: [
        {配置内容},
        {配置内容},
        {配置内容},
    ],
    data_message_type: "协议名"
}

Sample - Python3读取示例：

# 安装pip,已安装可跳过
wget -c --no-check-certificate "https://bootstrap.pypa.io/get-pip.py"
python get-pip.py

# 安装msgpack模块,已安装可跳过(以下2选1)
python3 -m pip install msgpack-python
pip install msgpack-python

#!/usr/bin/python
# -*- coding: utf-8 -*-

import msgpack

unpacker = msgpack.Unpacker(open('proto_v3/role_cfg.msgpack.bin', 'rb'))

cfg_mgr = {}

for unpacked in unpacker:
    # dump raw data
    print(unpacked)
    # make index in cfg_mgr
for cfg_name in unpacked[b'data_block']:
    cfg_set = unpacked[b'data_block'][cfg_name]
    cfg_index_set = {}
    for cfg_item in cfg_set:
        # we assume id is the key
        if b'id' not in cfg_item:
            continue
        cfg_index_set[cfg_item[b'id']] = cfg_item
    cfg_mgr[cfg_name] = cfg_index_set

# dump cfg_mgr
print(cfg_mgr)

# get cfg item from role_cfg with key = 10001
print(cfg_mgr[b'role_cfg'][10001])

Sample - Node.js读取示例：

# 安装msgpack模块,已安装可跳过
# 当然也可以用另一个模块 npm install msgpack5 --save，但是下面的例子使用的是msgpack-lite
npm install --save msgpack-lite

"use strick";
const fs = require("fs");
const msgpack = require("msgpack-lite");

const readStream = fs.createReadStream("proto_v3/role_cfg.msgpack.bin");
const decodeStream = msgpack.createDecodeStream();

// show multiple objects decoded from stream
const cfg_mgr = {};

readStream.pipe(decodeStream).on("data", function (obj) {
    for (const cfg_name in obj["data_block"]) {
        const cfg_set = obj["data_block"][cfg_name];
        const cfg_index = {};
        for (const cfg_item of cfg_set) {
            // we assume id is the key
            if (!cfg_item.id) {
                continue;
            }
            cfg_index[cfg_item.id] = cfg_item
        }

        cfg_mgr[cfg_name] = cfg_index;
    }
}).on("end", function () { // must run after read all data 
    // dump cfg_mgr ( )
    console.log(cfg_mgr)

    // get cfg item from role_cfg with key = 10001
    console.log(cfg_mgr['role_cfg'][10001])
});