結(jié)構(gòu)或大內(nèi)存塊打包的辦法(上11)

1、文檔來源為 :從網(wǎng)絡(luò)收集整理 .word 版本可編輯 .歡迎下載支持 The information in this article applies to: - Microsoft Visual C+ 6.0,SP5 結(jié)構(gòu)或大內(nèi)存塊打包的辦法 (上 1.1) Revision History: Version Date Creator Description 2004-2-23 鄭昀 草稿 Implementation Scope： 繼續(xù)閱讀之前，我們假設(shè)您熟悉以下知識： n SAFEARRAY n ISTREAM n Microsoft MSMQ 目錄： 1:概述 2:借用 SAFEARRA

2、Y 打包把結(jié)構(gòu)寫入 MSMQ 隊列 3:借用 IStream 流打包傳遞數(shù)據(jù)到 MSMQ 隊列 1.概述 通常我們建議通過 MSMQ 傳遞基于 XML 的字符串，但有時候也需要傳遞一些結(jié)構(gòu)或者一些接 口指針，那么如何打包傳遞呢？ 這實際上可以轉(zhuǎn)換為一個普適問題： 如何把一個結(jié)構(gòu)體(structure object)或者巨大內(nèi)存塊(比如 5MB 左右)打包為 PROPVARIANT-compatible 的類型？ 首先， IMSMQMessagePtr 的 Body 屬性接收 _variant_t 參數(shù) : inline void IMSMQMessage:PutBody ( const _va

3、riant_t if (FAILED(_hr) _com_issue_errorex(_hr, this, _uuidof(this); 如果我們想把結(jié)構(gòu)作為消息的 Body 寫入 MSMQ 消息隊列，我們需要把我們的結(jié)構(gòu)、大內(nèi)存塊 或接口指針轉(zhuǎn)換為 _variant_t。 2.借用 SAFEARRAY 打包把結(jié)構(gòu)寫入 MSMQ 隊列 把一個結(jié)構(gòu)體打包為 PROPVARIANT-compatible 的類型， 需要用到 SAFEARRAY ，一個帶有邊界 信息的數(shù)組。這是一個常用技巧，很多文章都有提及，我就不多解釋了。 但是，注意這種方式一次只能打包 65536 字節(jié)以下的數(shù)據(jù)，這是由于 SA

4、FEARRAY* SafeArrayCreateVector( VARTYPE vt, long lLbound, unsigned int cElements); 的定義所限制的。 我們通常會用 SafeArrayCreateVector API 創(chuàng)建一個單維 SAFEARRAY ，分配一個 sizeof（_DATA） 大小的連續(xù)內(nèi)存塊，而這個函數(shù)的第三個參數(shù)是一個 unsigned int 類型，所以最大值就只能是 65536 了。 更多SAFEARRAY知識，參見使用SAFEARRA傳遞對象。 下面給出打包的步驟（ VC+ 代碼）： 這里本還有很長一段代碼，由于文檔長度限制為64KB，只

5、好放在上1.2篇了，希望諒解。 結(jié)構(gòu)或大內(nèi)存塊打包的辦法（上 1.2 ） 上 2 篇繼續(xù)介紹如何讀取這樣的 MSMQ 消息。 結(jié)構(gòu)或大內(nèi)存塊打包的辦法（上 2） 中、下篇將介紹“借用 IStream 流打包傳遞數(shù)據(jù)到 MSMQ 隊列”。 結(jié)構(gòu)或大內(nèi)存塊打包的辦法（中） 結(jié)構(gòu)或大內(nèi)存塊打包的辦法（下） 、 、 結(jié)構(gòu)或大內(nèi)存塊打包的辦法（上 1.2） Revision History: Version Date Creator Description 2004-2-23 鄭昀 草稿 2.借用 SAFEARRAY 打包把結(jié)構(gòu)寫入 MSMQ 隊列 續(xù)上1.1篇的打包步驟（VC+代碼）： / Chang

6、eStruct2Var函數(shù)的定義： / 第一個參數(shù)： / 類型： CComVariant / 作用：接收者 / 第二個參數(shù)： / 類型： _DATA* / 作用：源 HRESULT ChangeStruct2Variant （CComVariant / 使用 SafeArrayCreateVector API 創(chuàng)建一個單維 SAFEARRAY ，分配一個 sizeof(_DATA) 大小的 連續(xù)內(nèi)存塊 / VT-UI1 代表非負(fù)整形的變量類型， 1 個字節(jié) / 常數(shù) 0定義數(shù)組的下界 LPSAFEARRAY lpsa = SafeArrayCreateVector(VT_UI1, 0, siz

7、eof(_DATA); LPBYTE pbData = NULL; if (lpsa) 在你訪問SAFEARRAY數(shù)據(jù)之前，你必須調(diào)用 SafeArrayAccessData。該函數(shù)鎖定數(shù)據(jù)并且返 回一個指針。在這里，鎖定數(shù)組意味著增加該數(shù)組的內(nèi)部計數(shù)器(cLocks) hr = SafeArrayAccessData(lpsa, (void *) else hr = HRESULT_FROM_WIN32(GetLastError(); if (SUCCEEDED(hr) / 使用 safe array： / 將傳入的 _DATA 指針指向的內(nèi)存復(fù)制到 pbData CopyMemory(pb

8、Data, pData, sizeof(*pData); / 設(shè)置 var 的類型為數(shù)組 var.vt = VT_ARRAY|VT_UI1; / 將 var 和我們的單維 SAFEARRAY 拉上關(guān)系： var.parray = lpsa; if (pbData) /相應(yīng)用來釋放數(shù)據(jù)的函數(shù)是 SafeArrayUnaccessData(),該功能釋放該參數(shù)的計數(shù) SafeArrayUnaccessData(var.parray); if (FAILED(hr) / 銷毀 SAFEARRAY SafeArrayDestroy(lpsa); return hr; / /Added Headers:

9、 / #include #include / /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, / 打包后的 CComVariant 傳遞給 MSMQMessege 的 Body 屬性： pisMsg-Body= var; pisMsg-AppSpecific=-1; / 發(fā)送到消息隊列： pisMsg-Send（pisQueue）; 這樣，就可以成功地把一個結(jié)