無論是sqlserver的用戶,還是pb的用戶,作為c/s結構開發環境,他們在網絡通信的實現上,都有一種共同的方法——命名管道。由於當前操作系統的不惟一性,各個系統都有其獨自的通信協議,導致了不同系統間通信的困難。盡管tcp/ip協議目前已發展成為internet的標准,但仍不能保證c/s應用程序的順利進行。命名管道作為一種通信方法,有其獨特的優越性,這主要表現在它不完全依賴於某一種協議,而是適用於任何協議——只要能夠實現通信。
命名管道具有很好的使用靈活性,表現在:
1) 既可用於本地,又可用於網絡。
2) 可以通過它的名稱而被引用。
3) 支持多客戶機連接。
4) 支持雙向通信。
5) 支持異步重疊i/o操作。
不過,當前只有windows nt支持服務端的命名管道技術。
一、命名管道程序設計的實現
1.命名管道server和client間通信的實現流程
(1)建立連接:服務端通過函數createnamedpipe創建一個命名管道的實例並返回用於今後操作的句柄,或為已存在的管道創建新的實例。如果在已定義超時值變為零以前,有一個實例管道可以使用,則創建成功並返回管道句柄,並用以偵聽來自客戶端的連接請求,該功能通過connectnamedpipe函數實現。
另一方面,客戶端通過函數waitnamedpipe使服務進程等待來自客戶的實例連接,如果在超時值變為零以前,有一個管道可以為連接使用,則waitnamedpipe將返回true,並通過調用createfile或callnamedpipe來呼叫對服務端的連接。此時服務端將接受客戶端的連接請求,成功建立連接,服務端connectnamedpipe返回true,客戶端createfile將返回一指向管道文件的句柄。
從時序上講,首先是客戶端通過waitnamedpipe使服務端的createfile在限時時間內創建實例成功,然後雙方通過connectnamedpipe和createfile成功連接,並返回用以通信的文件句柄,此時雙方即可進行通信。
(2)通信實現:建立連接之後,客戶端與服務器端即可通過readfile和writefile,利用得到的管道文件句柄,彼此間進行信息交換。
(3)連接終止:當客戶端與服務端的通信結束,或由於某種原因一方需要斷開時,客戶端應調用closefile,而服務端應接著調用disconnectnamedpipe。當然服務端亦可通過單方面調用disconnectnamedpipe終止連接。最後應調用函數closehandle來關閉該管道。
2.命名管道服務器端和客戶端代碼實現
(1)客戶端:
HANDLE CltHandle;
char pipenamestr[30];
sprintf(pipenamestr,”\\\\servername\\pipe\\pipename”)
if (WaitNamedPipe( pipenamestr, NMPWAIT_WAIT_FOREVER)==FALSE
// 管道名要遵循UNC,格式為\ \.\pipe\pipname,名字不分大小寫。
AfxMessageBox(“操作失敗,請確定服務端正確建立管道實例!”);
Else
CltHandle=CreateFile(pipenamestr, GENERIC_READ|GENERIC_WRITE,
FILE_SHARE_READ| FILE_SHARE_WRITE,NULL, OPEN_EXISTING,
//為了與命名管道連接,此參數應一直為OPEN_EXISTING
FILE_ATTRIBUTE_ARCHIVE|FILE_FLAG_WRITE_THROUGH,
// FILE_FLAG_WRITE_THROUGH會使管道WriteFile調用處於阻塞狀態,直到數據傳送成功。
NULL);
If (CltHandle== INVALID_HANDLE_VALUE)
AfxMessageBox(“管道連接失敗”);
Else
DoUsertTransactInfo();
//執行用戶自定義信息交換函數__從管道讀、寫信息。
……
(2)服務端:
HANDLE SvrHandle;
char pipenamestr[30];
sprintf(pipenamestr,”\\\\.\\pipe\\pipename”)
SvrHandle=CreateNamedPipe(pipenamestr,
PIPE_ACCESS_DUPLEX|FILE_FLAG_WRITE_THROUGH,
//阻塞模式,這種模式僅對”字節傳輸管道”操作有效。
FILE_WAIT|PIPE_TYPE_BYTE,
//字節模式
PIPE_UNLIMITED_INSTANCES,
128,128,
NULL,NULL);
// SECURITY_ATTRIBUTES結構指針,描述一個新管道,確定子進程的繼承權,如果為NULL則該命名管道不能被繼承。
If (SvrHandle==INVALID_HANDLE_VALUE)
AfxMessageBox(“管道創建失敗,請確定客戶端提供連接可能!”);
Else
If (ConnectNamedPipe(SvrHandle,NULL)==FALSE)
AfxMessageBox(“建立連接失敗!”);
Else
DoUsertTransactInfo();
//用戶自定義信息交換函數
……
二、程序設計的注意事項
1.如果命名管道客戶端已打開,函數將會強迫關閉管道,用disconnectnamedpipe關閉的管道,其客戶端還必須用closehandle來關閉最後的管道。
2.readfile和writefile的hfile句柄是由createfile及connectnamedpipe返回得到。
3.一個已被某客戶端連接的管道句柄在被另一客戶通過connectnamedpipe建立連接之前,服務端必須用disconnectnamedpipe函數對已存在的連接進行強行拆離。服務端拆離管道會造成管道中數據的丟失,用flushfilebuffers函數可以保證數據不被丟失。
4.命名管道服務端可以通過新創建的管道句柄或已被連接過其他客戶的管道句柄來使用connectnamedpipe函數,但在連接新的客戶端之前,服務端必須用函數disconnectnamedpipe切斷之前的客戶句柄,否則connectnamedpipe將會返回false。
5.阻塞模式,這種模式僅對“字節傳輸管道操作有效,並且要求客戶端與服務端不在同一機器上。如果用這種模式,則只有當函數通過網絡向遠端計算機管道緩沖器寫數據成功時,才能有效返回。如果不用這種模式,系統會運行缺省方式以提高網絡的工作效率。
6.用戶必須用file—create—pipe—instance來訪問命名管道對象。新的命名管道建立後,來自安全參數的訪問控制列表定義了訪問該命名管道的權限。所有命名管道實例必須使用統一的管道傳輸方式、管道模式等參數。客戶端未啟動,管道服務端不能執行阻塞讀操作,否則會發生空等的阻塞狀態。當最後的命名管道實例的最後一個句柄被關閉時,就應該刪除該命名管道。