|
隊列組件（Queued Components）是一項基于微軟消息隊列服務（Microsoft Message Queuing Services）的ＣＯＭ＋技術。它提供了一種簡易的異步引用和執行組件的方法。發送方和接收方都不心考慮對方現在是否可用和能否獲得而獨立運行。
作為一項ＣＯＭ技術。隊列指的是用于存儲消息以便將來檢索的空間。隊列提供了一種非連接性的通訊機制（即發送方和接怍方之間并不是直接相連結，而是通過隊列進行相互通訊）。隊列負責存儲信息直到接收方準備好為止。由于發送方和接收方之間不是直接通訊的，所以可以相互之間獨立地運行，而不會影響到雙方。
下面舉例說明如何使用Delphi創建和使用隊列組件。
首先，我們將創建一個服務器。接口中的所有方法必須僅使用IN參數，不能有返回值。這是由于客戶端和服務器之間并沒有直接的連結。因為不能確切地知道請求什么時候會被執行，所以客戶端不能一直等待從服務器獲得應答。
在Delphi中，首先打開file/new/other/activeX,創建一個ActiveX Library,然后，加入一個automation對象。為你的服務器對象取一個名稱，比如QdComponent,其他的選項都使用默認值，單擊OK.這時你將會看到Type Library Editor,添加一個方法，命名為Task1,為這個方法添加一個參數，命名為TaskMessage,設定其類型為BSTR(即Delphi中的WideString類型)。如果Type Library Options設置為show Pascal code,那么你的方法聲明代碼應與以下代碼類似：
procedure task1(TaskMessage:widestring) [dispid $00000001];safecall;
保存項目文件為MyQdServer,單元文件為QdServer.
具體代碼如下：
unit QdServer;
{$WARN SYMBOL_PLATFORM OFF}
interface
uses comobj,ActiveX,MyQdServer_TLB,stdvcl,Dialogs;
type
TqdComponent=class(TautoObject,IQdComponent)
Protected
Procedure Task1(const TaskMessage:widestring);safecall;
End;
Implemention
Uses comServ;
Procedure TqdComponent.Task1(const TaskMessag:widestring);
Begin
Showmessage(TaskMessage);
End;
Initialization
TautoObjectFactory.Create(ComServer,TqdComponent,class_QdComponent
CiMultiInstance,tmApartment);
End.
安裝服務器
在控制面板中打開組件服務工具（Component Services Tool），在文件樹中找到”COM+ Application”,然后右擊，選擇New/Application接著選擇“Create an empty applcation”根據提示找到你的新程序，右擊它，轉到屬性頁，找到Queuing欄，選擇復選框中的兩項１．Queued 2.Listen.Listen表示任何被壓入隊列的消息，當它被擊活時，將馬上被處理。在你的新程序下右擊“components”選擇New/Component,選擇“install new component(s)”,根據提示，找到并安裝你的DLL文件，然后展開文件樹找到“interface”,右擊IqdComponent,打開屬性頁，在Queuing欄中選上”Queued”(如果看到出錯提示信息“MSMQ IS NOT RUNNING”)那么很可能你沒有安裝MSMQ，因為MSMQ不是默認的WINDOWS 2000的安裝選項。
創建客戶端
創建一個新的Delphi應用程序，在uses子句中加入MyQdServer_tlb.pas單元文件，添加一個按鈕和一個文本框。
你需要在程序運行時創建你的對象，所以使用一個符號變量來標記組件的信息，這個參數在FormShow事件處理函數中聲明和使用。
具體代碼如下：
unit unit1;
interface
uses
Windows,Messages,SysUtils,Variants,Classes,Graphics,Controls,Forms,
Dialogs,StdCtrls,Comobj,ActiveX,MyQdSever_TLB,
Type
Tform1=class(TForm)
Edit1;Tedit;
Button1:Tbutton;
Procedure Button1Click(sender:Tobject);
Procedure FormShow(sender:TObject);
Private
Qinterface:IqdComponent;
Public
{Public declarations}
end;
var
form1:Tform1;
implemention
{$R*.dfm}
Function NewCoGetObject(pazName:PwideChar;pBindOptions:PbindOpts;
Const iid:TIID;out ppv):Hresult;stdcall;external ‘ole32.dll’ name‘CoGetOject’
Procedure Tform1.Button1Click(sender:TObject);
Begin
Qinterface.task1(edit1.text);
End;
Procedure Tform1.FormShow(sender:Tobject);
Var
Qmoniker:PwideChar;
Begin
Qmoniker:=’Queue:/new{服務器的GUID或Server.interfaceName}’;
Olecheck(NewCoGetObject(Qmoniker,nil,IqdComponent,Qinterface));
End;
End.
運行客戶端程序，然后傳送一條消息，由于此時你并沒有啟動服務器，所以這時并不能顯示出來這條消息，需要啟動服務器，而最簡單的方法就是打開控制面板中的組件服務（Component Services），找到你的服務器，右擊選擇啟動。
|
