打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

打包传输结构体或大内存块

作者 郑昀

内容

BSTR的解法

SAFEARRAY的解法

boost::serialization的解法

IStream流的解法

本文假定您熟悉 SAFEARRAYC++BOOST MSMQ

摘要:本文阐述了结构体/大内存块分布式传输时常用的四种打包方法,并演示了您如何利用这四种方法通过MSMQ发送/读取数据。

有时候我们需要远程传输各种结构体或者数据块,比如您通过MSMQ消息队列传递任意大小的结构体或者接口指针,那么如何打包传递呢?这实际上可以分解为一个普适问题:

如何把一个结构体(Structure Object)或者巨大内存块(比如5MB左右)打包为二进制数据流或者PROPVARIANT-compatible的类型?

本文介绍了四种传输方法:

一个BSTR

一个SAFEARRAY

boost::serialization

IStream流。

本文还介绍了如何从MSMQ收发/解析这四种类型的数据。

BSTR的解法

BSTR的解法应该是这里面最简单的,也最容易理解的解法。

BSTR定义 “一个 BSTR 是预先确定长度的 OLECHAR(每个 16 位)缓冲区” 看,BSTR并不等同于OLECHAR,它的前面还提供了4个字节,用于保留字符串的长度。BSTR真正指向第五个字节,也就是真正的OLECHAR串的开始处。

由此我们通常可以使用 BSTR 前缀来判断OLECHAR是多少个字节,它们并不会把数据解释为字符串,因此数据可以是具有嵌入空值(0x00)的二进制数据。这个特性正好为我们所用。

另外一个需要注意的问题是,我们要调用 SysStringByteLen 来获得 BSTR 中字节的数量,而不是单纯地计算Unicode字符的数量。

首先,我们给出一个要传输的类定义,它拥有几个常见类型的成员变量:

class A

{

int i; unsigned int ui;

long l;unsigned long ul;

char szInt[MAX_PATH];

std::string strLong;

public:

A() :

i(std::rand()),

ui(std::rand()),

l(std::rand()),

ul(std::rand())

{

std::stringstream ss;

ss << i; ss >> szInt;

ss.clear();

ss << l; ss >> strLong;

}

};

打包很容易:

A aSend;

BSTR bstrSend = SysAllocStringByteLen(NULL, sizeof(aSend));

LPBYTE pv = reinterpret_cast (bstrSend);

CopyMemory(pv, (void *)&aSend, sizeof(aSend));

这里要解释一下MSMQ接收消息体的规则。智能指针IMSMQMessagePtrBody属性接收_variant_t参数。所以如果我们想把类对象实例作为消息的Body写入MSMQ消息队列,我们需要事先转换为_variant_t,下面的代码就是做这种转换的:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

CComBSTR bstrBody;

bstrBody.AppendBSTR(pData);

CComVariant varBody (bstrBody);

spMsg->Body = varBody;

hr = spMsg->Send(spQueue);

就这样,消息发送到了MSMQ

下面我们演示如何解包。

A aRead;

IMSMQMessagePtr pMsg;

ReadMSMQMessage(spQueueRead, pMsg);

UINT uiRead = SysStringByteLen(pMsg->Body.bstrVal);

LPBYTE pvRead = reinterpret_cast (pMsg->Body.bstrVal);

CopyMemory((void *)&aRead, pvRead, uiRead);

新的类对象实例aRead的数据经过这样的解包,就得到了aSend的数据。

SAFEARRAY的解法

SAFEARRAY的解法较BSTR解法复杂了一点,不过就本质而言,它也是简单地把结构体复制到字节数组中。SAFEARRAY是一个带有边界信息的数组,它只是数组的描述,并不是数组本身,真正的数组内容存储在一个单独的内存块中,SAFEARRAY中的pvData指向这个内存块。

值得注意的是,这种方式一次只能打包65536字节以下的数据,这是由于

SafeArrayCreateVectorcElements定义所限制的:

SAFEARRAY* SafeArrayCreateVector(

VARTYPE vt,

long lLbound,

unsigned int cElements);

我们通常会SafeArrayCreateVector API创建一个单维SAFEARRAY,分配一个sizeof(DATA)大小的连续内存块,而这个函数的第三个参数是一个unsigned int类型,所以最大值就只能是65536了。

下面的代码演示如何打包类A

A aSend;

_variant_t varBody;

使用SafeArrayCreateVector API创建一个单维SAFEARRAY

LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, Size);

在你访问SAFEARRAY数据之前,你必须调用SafeArrayAccessData,该函数锁定数据并且返回一个指针。在这里,锁定数组意味着增加该数组的内部计数器:

LPBYTE pbData = NULL;

if (lpsa)

hr = SafeArrayAccessData(lpsa, (void **)&pbData);

将类对象实例的内存复制到pbData,并将varBody和我们的单维SAFEARRAY拉上关系

if (SUCCEEDED(hr))

{

CopyMemory(pbData, (void *) &aSend, sizeof(*pData));

varBody.vt = VT_ARRAY|VT_UI1;

varBody.parray = lpsa;

}

相应用来释放数据的函数是SafeArrayUnaccessData(),该功能释放该参数的计数:

if (pbData)

SafeArrayUnaccessData(varBody.parray);

填写MSMQMessageBody属性:

IMSMQMessagePtr spMsg("MSMQ.MSMQMessage");

spMsg->Body = varBody;

好了,我们可以把这个消息体发送到MSMQ了。

收到MSMQ消息,反解也是依样画葫芦,

HRESULT ChangeVariant2Struct (_variant_t &var, A *DP)

{

SAFEARRAY* psa = var.parray;

调用SafeArrayGetUBoundSafeArrayGetLBound得到SAFEARRAY上下边界:

long lBound;

SafeArrayGetLBound(psa, 1, &lBound);

long lUp;

SafeArrayGetUBound(psa, 1, &lUp);

DWORD dwSize = lUp - lBound + 1;

if(dwSize < 1)

return S_FALSE;

从而计算出要复制的内存块的大小。

下面开始复制:

void * tp;

SafeArrayAccessData(psa, reinterpret_cast<void**>(&tp));

CopyMemory((LPVOID)DP, tp, dwSize);

SafeArrayUnaccessData(psa);

return S_OK;

}

下面演示如何调用上面定义的函数ChangeVariant2Struct,从消息Body属性中得到类A实例:

A aRead;

ZeroMemory((PVOID)&aRead, sizeof(aRead));

hr = ChangeVariant2Struct(pIMQMsg->Body,

&aRead);

boost::serialization的解法

boost. 1.32.0 2004 11 19 发布,其中Robert Rameyboost::serialization库可以将C++数据结构的任意集可逆地解构为一系列字节流。字节流的承载形式可以表现为:一个二进制数据的文件、文本数据、XML等。boost::serialization库完全是平台独立的。

我们借用它的一个例子来讲述我们的故事。首先你的类定义需要扩充:

class A

{

friend class boost::serialization::access;

template<class Archive>

void serialize(Archive & ar, const unsigned int /* version */){

ar & i & ui & l & ul & szBuf;

}

。。。

};

由于C++没有reflection能力,无法动态查询对象内部信息以及对象所属类的信息所以不但要加入一个友元,还需要用户介入serialize方法的具体细节。

另外我们还要借用boost_1_32_0/libs/serialization/example中提供的两个头文件:portable_binary_iarchive.hppportable_binary_oarchive.hpp

之后的打包就简洁多了:

std::stringstream ssSend;

std::string strSend;

{

portable_binary_oarchive pboa(ssSend);

pboa << aSend;

strSend = ssSend.str();

}

ssSend里就承载着二进制数据流。除此之外,你还可以用

A aFile;

std::ofstream ofs(filename.bin);

boost::archive::text_oarchive oa(ofs);

oa << s;

直接将数据流序列化到二进制数据文件中,这也可以作为传输的介质。

为了把strSend发送到MSMQ,我们还需要

CComBSTR bstr;

bstr.AppendBytes(strSend.c_str(),strSend.length());

CComVariant var(bstr);

spMsg->Body = var;

收到的MSMQ消息解包也很简单:

A aRead;

std::stringstream ssRead;

ssRead << bstrRead;

portable_binary_iarchive pbia(ssRead);

pbia >> aRead;

这种boost::serialization解法好处就是优雅的语法和平台无关性。

IStream流的解法

当你有一块非常巨大的数据或者各种COM接口指针要传递给MSMQ队列时,而且你希望一次液压成型,那么把它打包IStream也是一个很常用技巧,我也不多解释了。

总结

解法一、二和四依赖Microsoft平台,而boost::serialization解法则仅依赖于ANSI C++标准的设施,很容易移植。

解法一和二只是简单地复制字节流,对于Deep Pointer的传输可能就要借助于boost::serialization解法了,它可以保存和恢复pointers,也可以保存和恢复pointer所指向的数据,甚至可以正确处理指向共享数据的pointers

Disclaimers

Programmer’s Blog List

博客堂

博客园

Don Box's Blog

Eric.Weblog()

Blogs@asp.net

本文档仅供参考。本文档所包含的信息代表了在发布之日,zhengyun_ustc对所讨论问题的当前看法,zhengyun_ustc不保证所给信息在发布之日以后的准确性。

用户应清楚本文档的准确性及其使用可能带来的全部风险。可以复制和传播本文档,但须遵守以下条款:

  1. 复制时不得修改原文,复制内容须包含所有页
  2. 所有副本均须含有 zhengyun_ustc的版权声明以及所提供的其它声明
  3. 不得以赢利为目的对本文档进行传播

[C++]打包传输结构体或大内存块的四种办法(完全版)相关推荐

  1. 打包传输结构体或大内存块

    打包传输结构体或大内存块 http://blog.csdn.net/hejishan/article/details/2287190 作者 郑昀 内容   BSTR的解法 SAFEARRAY的解法 b ...

  2. C++_类和结构体所占内存大小,静态成员问题

    C++_类和结构体所占内存大小,静态成员问题 静态成员未初始化或者未调用(当然静态成员必须类外初始化才能调用)是不占内存的.静态成员不占类或结构体的内存 静态成员函数同样只声明未定义同样不占内存 指针 ...

  3. socket传输结构体,c++,发送OK,recv返回字节大小正确但接受数据为空

    socket传输结构体,c++,发送OK,recv返回字节大小正确但接受数据为空 服务端在ubuntu服务器下,客户端在windows下,采用socket进行通信,在客户端接收数据时,出现了诡异的情况 ...

  4. C语言定义了一个结构体怎么分配内存?C\C++中结构体变量与结构体指针内存分配问题?

    C语言定义了一个结构体怎么分配内存?C\C++中结构体变量与结构体指针内存分配问题? 问题1:结构体指针最开始怎么分配内存?用sizeof()是不能确定大小的. 问题2:给结构体变量分配之后,是否还要 ...

  5. 内存对齐 | 原来字段顺序还能影响结构体占用的内存空间

    大家好啊,不知道看了网管在上周的文章Go指针的使用限制和unsafe.Pointer突破之路,你们有没有感觉Golang 比之前想的还好用呢?确实能直接读写内存,很多以前觉得无能为力的事情就不再是问题 ...

  6. C语言小记:结构体及其在内存中的储存形式

    C语言小记:结构体及其在内存中的储存形式 1.结构体 结构体的作用:自定义一个包含多种不同数据类型的变量. 语法: struct 结构体名称 {结构体成员1:结构体成员2:结构体成员3:... } 定 ...

  7. 结构体与动态内存(5.11)

    结构体与动态内存: 一.结构体 <1>结构体简介 特点:构造类型,可以构造出任何程序员想要的类型. 思考:如何定义一个结构体 struct 结构体名 {数据类型 成员变量名:数据类型 成员 ...

  8. 现要为某一个销售部门编写一个程序管理约100种商品。要求设计一个结构体类型来描述商品,每种商品包括商品编号(如A001)、商品名称、商品销售量和商品销售额等信息,并编写以下函数···········

    原题:现要为某一个销售部门编写一个程序管理约100种商品.要求设计一个结构体类型来描述商品,每种商品包括商品编号(如A001).商品名称.商品销售量和商品销售额等信息,并编写以下函数: 1.编写一个函 ...

  9. linux如何创建共享内存,linux实现共享内存同步的四种方法

    https://blog.csdn.net/sunxiaopengsun/article/details/79869115 本文主要对实现共享内存同步的四种方法进行了介绍. 共享内存是一种最为高效的进 ...

最新文章

  1. MYSQL使用存储过程插入中文数据的疑似bug(UTF8)
  2. [Zjoi2015]诸神眷顾的幻想乡
  3. MyEclipse默认编码为GBK,修改为UTF8的方法
  4. 【Java 虚拟机原理】垃圾回收算法 ( 设置 JVM 命令参数输出 GC 日志 | GC 日志输出示例 | GC 日志分析 )
  5. 【SpringBoot】编写一个自己的Starter
  6. java设计模式之行为型设计模式
  7. php中ajax用法,thinkphp中使用ajax
  8. ios sandbox
  9. 2021年PMP考试模拟题2(含答案)
  10. 微信分组可见怎么实现android,android如何管理微信分组
  11. 软件工程专业职业规划发展路线
  12. oracle kup04040,ORA-20011: Approximate NDV failed: ORA-29913: 执行 ODCIEXTTABLEOPE
  13. cocos2d-x开源游戏引擎,C++开发iphone/android/uphone/win32游戏
  14. API MISUSE: <CBPeripheralManager: 0x282c00070> can only accept this command while in the powered on
  15. 用GetGlyphOutline搞字模
  16. matlab求非线性方程的根,求非线性方程的根
  17. 这个行业一半人月薪超过8千!
  18. 计算机网络谢希仁(1)
  19. 从大数据应用案例中理解大数据的应用价值
  20. ker矩阵是什么意思_第五课:初等矩阵及酉矩阵

热门文章

  1. JAVA线程间通信的几种方式
  2. 英飞凌 AURIX TC3XX 系列单片机的 SOTA 功能实现
  3. linux文件权限s设置,Linux权限位(含特殊权限位s s t) 及chown\chmod命令使用
  4. calibre-web(web图书库)
  5. ArrayList 原理解析
  6. 联想(Lenovo)小新15IIL2020款i5-1035G电脑 Hackintosh 黑苹果efi引导文件
  7. 阿里专家马飞翔:一文读懂架构整洁之道
  8. Day19 学习java(网络编程、正则表达式)
  9. 编程神器 VS Code,只要这一篇就够了!
  10. 数据库(3.22/3.19