結(jié)構(gòu)或大內(nèi)存塊打包的辦法
Revision History:
Version Date Creator Description
Implementation Scope：
繼續(xù)閱讀之前，我們假設(shè)您熟悉以下知識(shí)：
- SAFEARRAY
- ISTREAM
- Microsoft MSMQ
目錄：
1:概述
2:借用SAFEARRAY打包把結(jié)構(gòu)寫入MSMQ隊(duì)列
3:借用IStream流打包傳遞數(shù)據(jù)到MSMQ隊(duì)列
1.概述
通常我們建議通過(guò)MSMQ傳遞基于XML的字符串，但有時(shí)候也需要傳遞一些結(jié)構(gòu)或者一些接口指針，那么如何打包傳遞呢？
這實(shí)際上可以轉(zhuǎn)換為一個(gè)普適問(wèn)題：
如何把一個(gè)結(jié)構(gòu)體(structure object)或者巨大內(nèi)存塊（比如5MB左右）打包為PROPVARIANT-compatible的類型？
首先，IMSMQMessagePtr的Body屬性接收_variant_t參數(shù):
inline void IMSMQMessage::PutBody ( const _variant_t & pvarBody ) {
HRESULT _hr = put_Body(pvarBody);
if (FAILED(_hr)) _com_issue_errorex(_hr, this, __uuidof(this));
}
如果我們想把結(jié)構(gòu)作為消息的Body寫入MSMQ消息隊(duì)列，我們需要把我們的結(jié)構(gòu)、大內(nèi)存塊或接口指針轉(zhuǎn)換為_(kāi)variant_t。
2.借用SAFEARRAY打包把結(jié)構(gòu)寫入MSMQ隊(duì)列
把一個(gè)結(jié)構(gòu)體打包為PROPVARIANT-compatible的類型，需要用到SAFEARRAY，一個(gè)帶有邊界信息的數(shù)組。這是一個(gè)常用技巧，很多文章都有提及，我就不多解釋了。
但是，注意這種方式一次只能打包65536字節(jié)以下的數(shù)據(jù)，這是由于
SAFEARRAY* SafeArrayCreateVector(
VARTYPE vt,
long lLbound,
unsigned int cElements);
的定義所限制的。
我們通常會(huì)用SafeArrayCreateVector API創(chuàng)建一個(gè)單維SAFEARRAY，分配一個(gè)sizeof(_DATA)大小的連續(xù)內(nèi)存塊，而這個(gè)函數(shù)的第三個(gè)參數(shù)是一個(gè)unsigned int類型，所以最大值就只能是65536了。
更多SAFEARRAY知識(shí)，參見(jiàn)使用SAFEARRAY傳遞對(duì)象。
2.借用SAFEARRAY打包把結(jié)構(gòu)寫入MSMQ隊(duì)列
續(xù)上1.1篇的打包步驟（VC++代碼）：
// ChangeStruct2Var函數(shù)的定義：
// 第一個(gè)參數(shù)：
// 類型：CComVariant
// 作用：接收者
// 第二個(gè)參數(shù)：
// 類型：_DATA*
// 作用：源
HRESULT ChangeStruct2Variant (CComVariant &var, _DATA *pData)
{
HRESULT hr = S_OK;
// 使用SafeArrayCreateVector API創(chuàng)建一個(gè)單維SAFEARRAY，分配一個(gè)sizeof(_DATA)大小的連續(xù)內(nèi)存塊
// VT--UI1代表非負(fù)整形的變量類型，1個(gè)字節(jié)
// 常數(shù)'0'定義數(shù)組的下界
LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, sizeof(_DATA));
LPBYTE pbData = NULL;
if (lpsa)
{
//在你訪問(wèn)SAFEARRAY數(shù)據(jù)之前，你必須調(diào)用SafeArrayAccessData。該函數(shù)鎖定數(shù)據(jù)并且返回一個(gè)指針。在這里，鎖定數(shù)組意味著增加該數(shù)組的內(nèi)部計(jì)數(shù)器（cLocks）
hr = SafeArrayAccessData(lpsa, (void **)&pbData);
}
else
hr = HRESULT_FROM_WIN32(GetLastError());
if (SUCCEEDED(hr))
{
// 使用safe array：
// 將傳入的_DATA指針指向的內(nèi)存復(fù)制到pbData
CopyMemory(pbData, pData, sizeof(*pData));
// 設(shè)置var的類型為數(shù)組
var.vt = VT_ARRAYVT_UI1;
// 將var和我們的單維SAFEARRAY拉上關(guān)系：
var.parray = lpsa;
}
if (pbData)
{
//相應(yīng)用來(lái)釋放數(shù)據(jù)的函數(shù)是SafeArrayUnaccessData()，該功能釋放該參數(shù)的計(jì)數(shù)。
SafeArrayUnaccessData(var.parray);
}
if (FAILED(hr))
{
// 銷毀SAFEARRAY
SafeArrayDestroy(lpsa);
}
return hr;
}
////////////////////////////////////////////////////////////
//Added Headers:
////////////////////////////////////////////////////////////
#include <comdef.h>
#include <atlbase.h>
///////////////////////////////////////////////////////////
//Added for MSMQ:
///////////////////////////////////////////////////////////
#import "mqoa.dll" no_namespace, named_guids
typedef struct _DATA
{
int _n;
char _str;
}_DATA;
//main:
{
.. ..
.. ..
IMSMQMessagePtr pisMsg = NULL;
hr = pisMsg.CreateInstance("MSMQ.MSMQMessage");
_DATA msg;
msg._n = 1;
msg._str = '1';
CComVariant var;
// 打包函數(shù)：
ChangeStruct2Variant(var, &msg);
// 打包后的CComVariant傳遞給MSMQMessege的Body屬性：
pisMsg->Body= var;
pisMsg->AppSpecific=-1;
// 發(fā)送到消息隊(duì)列：
pisMsg->Send(pisQueue);
.. ..
}
這樣，就可以成功地把一個(gè)結(jié)構(gòu)遞交到MSMQ隊(duì)列中了。
Implementation Scope：
繼續(xù)閱讀之前，我們假設(shè)您熟悉以下知識(shí)：
- SAFEARRAY
- ISTREAM
- Microsoft MSMQ
目錄：
1:概述
2:借用SAFEARRAY打包把結(jié)構(gòu)寫入MSMQ隊(duì)列
3:借用IStream流打包傳遞數(shù)據(jù)到MSMQ隊(duì)列
下面給出讀取MSMQ消息時(shí)解析的步驟（VC++代碼）：
////////////////////////////////////////////////////////////
//Added Headers:
////////////////////////////////////////////////////////////
#include <comdef.h>
#include <atlbase.h>
///////////////////////////////////////////////////////////
//Added for MSMQ:
///////////////////////////////////////////////////////////
#import "mqoa.dll" no_namespace, named_guids
typedef struct _DATA
{
int _n;
char _str;
}_DATA;
//main:
{
.. ..
.. ..
hr = pisQI->raw_Open(MQ_PEEK_ACCESS,MQ_DENY_NONE,&pisQueue);
IMSMQMessagePtr piMessage;
// 獲取MSMQ隊(duì)列中的一個(gè)消息：
piMessage = pisQueue->PeekCurrent();
_DATA *msg = new _DATA();
// 解析函數(shù)：
ChangeVariant2Struct(CComVariant(piMessage->Body), msg);
.. ..
}
// ChangeVariant2Struct函數(shù)的定義：
// 第一個(gè)參數(shù)：
// 類型：CComVariant
// 作用：源
// 第二個(gè)參數(shù)：
// 類型：_DATA*
// 作用：接收者
HRESULT ChangeVariant2Struct (CComVariant &var, _DATA *DP)
{
SAFEARRAY* psa;
BYTE HUGEP *lpb;
psa = var.parray;
SafeArrayAccessData(psa, (void HUGEP **)&lpb);
CopyMemory((LPVOID)DP, (LPVOID)lpb, 8);
SafeArrayUnaccessData(psa);
return S_OK;
}
Writen by zhengyun.NoJunk(at)tomosoft.dot.com
Disclaimers：
本文檔僅供參考。本文檔所包含的信息代表了在發(fā)布之日，zhengyun對(duì)所討論問(wèn)題的當(dāng)前看法，zhengyun不保證所給信息在發(fā)布之日以后的準(zhǔn)確性。
用戶應(yīng)清楚本文檔的準(zhǔn)確性及其使用可能帶來(lái)的全部風(fēng)險(xiǎn)。可以復(fù)制和傳播本文檔，但須遵守以下條款：
復(fù)制時(shí)不得修改原文，復(fù)制內(nèi)容須包含所有頁(yè) ；
所有副本均須含有 zhengyun的版權(quán)聲明以及所提供的其它聲明 ；
Implementation Scope：
繼續(xù)閱讀之前，我們假設(shè)您熟悉以下知識(shí)：
- SAFEARRAY
- ISTREAM
- Microsoft MSMQ
目錄：
1:概述
2:借用SAFEARRAY打包把結(jié)構(gòu)寫入MSMQ隊(duì)列
3:借用IStream流打包傳遞數(shù)據(jù)到MSMQ隊(duì)列
3.借用IStream流傳遞數(shù)據(jù)
正如前面所述，當(dāng)你有一塊非常巨大的數(shù)據(jù)要傳遞給MSMQ隊(duì)列時(shí)，而且你希望一次液壓成型，那么把它打包入IStream流，也是一個(gè)很常用技巧，了解COM的人都知道，我也不多解釋了。
我們研究了ATL中IPersistMemoryImpl接口Load方法的實(shí)現(xiàn)機(jī)理，來(lái)做我們的事情：
// 函數(shù)名：LoadStreamOnHugeMemory
// 功能： 同上
// 第一個(gè)參數(shù)pvMem指向一塊要打包的內(nèi)存，第二個(gè)參數(shù)指明這塊內(nèi)存的大小
HRESULT LoadStreamOnHugeMemory(void pvMem, ULONG cbSize)
{
// Get Memory Handle:
HGLOBAL h = GlobalAlloc(GMEM_MOVEABLE, cbSize);
If(NULL == h) return E_OUTOFMEMORY;
LPVOID pv = GlobalLock(h);
If(!pv) return E_OUTOFMEMORY;
// Copy to memory block
CopyMemory(pv, pvMem, cbSize);
CComPtr<IStream> spStream;
// Create stream on Memory:
HRESULT hr = CreateStreamOHGlobal(h, TRUE, &spStream);
If(FAILED(hr))
{
GlobalUnlock(h);
GlobalFree(h);
return hr;
}
// stream now owns the memory
// unlock the data
GlobalUnlock(hGlobal);
// Create a stream holder. Load the stream holder from the global stream.
// THIS STREAM HOLDER IS INTERITED FROM IPersistStream
// And all virtual functions are Modified to handle the object....
CComPtr <IStreamHolder> pHolder = new CComObject <CStreamHolder>;
CComPtr <IPersistStream> pHolderStream;
hr = pHolder->QueryInterface (IID_IPersistStream, (void **)&pHolderStream);
pStream->Seek( zero, STREAM_SEEK_SET, NULL );
pHolderStream->Load(pStream);
CComVariant vComData = pHolder;
.. ..
//
// now, you have a big chunk of memory loaded into a ComVariant
//
// 現(xiàn)在你可以把打包后的CComVariant傳遞給MSMQMessege的Body屬性了：
pisMsg->Body = vComData;
.. ..
}
其實(shí)，Aydin的實(shí)現(xiàn)和ATL中IPersistMemoryImpl接口Load方法實(shí)現(xiàn)異曲同工。我們不妨換一種方式實(shí)現(xiàn)。
Writen by zhengyun.NoJunk(at)tomosoft.dot.com
Disclaimers：
本文檔僅供參考。本文檔所包含的信息代表了在發(fā)布之日，zhengyun對(duì)所討論問(wèn)題的當(dāng)前看法，zhengyun不保證所給信息在發(fā)布之日以后的準(zhǔn)確性。
用戶應(yīng)清楚本文檔的準(zhǔn)確性及其使用可能帶來(lái)的全部風(fēng)險(xiǎn)。可以復(fù)制和傳播本文檔，但須遵守以下條款：
復(fù)制時(shí)不得修改原文，復(fù)制內(nèi)容須包含所有頁(yè) ；
所有副本均須含有 zhengyun的版權(quán)聲明以及所提供的其它聲明 ；
不得以贏利為目的對(duì)本文檔進(jìn)行傳播 。
Implementation Scope：
繼續(xù)閱讀之前，我們假設(shè)您熟悉以下知識(shí)：
- SAFEARRAY
- ISTREAM
- Microsoft MSMQ
目錄：
1:概述
2:借用SAFEARRAY打包把結(jié)構(gòu)寫入MSMQ隊(duì)列
3:借用IStream流打包傳遞數(shù)據(jù)到MSMQ隊(duì)列
其實(shí)，Aydin的實(shí)現(xiàn)和ATL中IPersistMemoryImpl接口Load方法實(shí)現(xiàn)異曲同工。我們不妨換一種方式實(shí)現(xiàn)。
Aydin給出的VC++代碼是：
// 智能流指針
CComPtr<IStream> pStream = NULL;
LARGE_INTEGER zero = {0,0};
// hGlobal是內(nèi)存句柄：
LPBYTE pChunk = (BYTE *) GlobalLock(hGlobal);
// 創(chuàng)建一個(gè)空的stream：
HRESULT hr = CreateStreamOnHGlobal(NULL, TRUE, &pStream );
pStream->Seek( zero, STREAM_SEEK_SET, NULL );
ULONG pcbWritten = 0;
// pChunk現(xiàn)在已經(jīng)指向我們的巨大內(nèi)存塊；
// 我們把這塊內(nèi)存寫入IStream流中：
pStream->Write (pChunk, dwNumRead, &pcbWritten);
// 檢查是否全部寫入了：
ATLASSERT(pcbWritten==dwNumRead);
// unlock the data
GlobalUnlock(hGlobal);
// 剩下的一樣，也是讓CComPtr <IPersistStream>來(lái)調(diào)用Load方法加載IStream
// Create a stream holder. Load the stream holder from the global stream.
// THIS STREAM HOLDER IS INTERITED FROM IPersistStream
// And all virtual functions are Modified to handle the object....
CComPtr <IStreamHolder> pHolder = new CComObject <CStreamHolder>;
CComPtr <IPersistStream> pHolderStream;
hr = pHolder->QueryInterface (IID_IPersistStream, (void **)&pHolderStream);
pStream->Seek( zero, STREAM_SEEK_SET, NULL );
pHolderStream->Load(pStream);
CComVariant vComData = pHolder;
.. ..
//
// now, you have a big chunk of memory loaded into a ComVariant
//
// 現(xiàn)在你可以把打包后的CComVariant傳遞給MSMQMessege的Body屬性了：
pisMsg->Body = vComData;
.. ..
//Coder: Aydin T.BAKIR
全文完。
Writen by zhengyun.NoJunk(at)tomosoft.dot.com
Disclaimers：
本文檔僅供參考。本文檔所包含的信息代表了在發(fā)布之日，zhengyun對(duì)所討論問(wèn)題的當(dāng)前看法，zhengyun不保證所給信息在發(fā)布之日以后的準(zhǔn)確性。
用戶應(yīng)清楚本文檔的準(zhǔn)確性及其使用可能帶來(lái)的全部風(fēng)險(xiǎn)。可以復(fù)制和傳播本文檔，但須遵守以下條款：
復(fù)制時(shí)不得修改原文，復(fù)制內(nèi)容須包含所有頁(yè) ；
所有副本均須含有 zhengyun的版權(quán)聲明以及所提供的其它聲明 ；
不得以贏利為目的對(duì)本文檔進(jìn)行傳播 。