【轉】C++ 進程間的通訊(一):簡單的有名管道實現

原文： C++ 進程間的通訊(一):簡單的有名管道實現

--------------------------------------------------

進程間的通訊(一):簡單的有名管道實現

 

一 管道簡介

命名管道(Named Pipe)是服務器進程和一個或多個客戶進程之間通信的單向或雙向管道。不同於匿名管道的是命名管道可以在不相關的進程之間和不同計算機之間使用，服務器建立命名管道時給它指定一個名字，任何進程都可以通過該名字打開管道的另一端，根據給定的權限和服務器進程通信。

其優點是實現起來比較簡單方便.

缺點是會使進程之間的代碼耦合度增加.並且管道通信只適用於同一台主機上的進程之間通訊.

二 實現代碼

Server Code:

#include "stdafx.h"
#include <stdio.h>
#include <windows.h>
#include <ctime>

int main(int argc, _TCHAR* argv[])
{
    srand(time(NULL));

    char buf[256] = "";
    DWORD rlen = 0;
    HANDLE hPipe = CreateNamedPipe(
        TEXT("\\\\.\\Pipe\\mypipe"),                        //管道名
        PIPE_ACCESS_DUPLEX,                                 //管道類型
        PIPE_TYPE_MESSAGE|PIPE_READMODE_MESSAGE|PIPE_WAIT,  //管道參數
        PIPE_UNLIMITED_INSTANCES,                           //管道能創建的最大實例數量
        0,                                                  //輸出緩沖區長度 0表示默認
        0,                                                  //輸入緩沖區長度 0表示默認
        NMPWAIT_WAIT_FOREVER,                               //超時時間
        NULL);                                                  //指定一個SECURITY_ATTRIBUTES結構,或者傳遞零值.
    if (INVALID_HANDLE_VALUE == hPipe)
    {
        printf("Create Pipe Error(%d)\n",GetLastError());
    }
    else
    {
        printf("Waiting For Client Connection...\n");
        if(ConnectNamedPipe(hPipe, NULL)==NULL) //阻塞等待客戶端連接。
        {
            printf("Connection failed!\n");
        }
        else
        {
            printf("Connection Success!\n");
        }

        while (true)
        {
            if(ReadFile(hPipe,buf,256,&rlen,NULL)==FALSE) //接受客戶端發送過來的內容
            {
                printf("Read Data From Pipe Failed!\n");
                break;
            }
            else
            {
                printf("From Client: data = %s, size = %d\n", buf, rlen);
                char wbuf[256] = "";
                sprintf(wbuf, "%s%d", wbuf, rand()%1000);
                DWORD wlen = 0;
                WriteFile(hPipe, wbuf, sizeof(wbuf), &wlen, 0); //向客戶端發送內容
                printf("To Client: data = %s, size = %d\n", wbuf, wlen);
                Sleep(1000);
            }
        }
        CloseHandle(hPipe);//關閉管道
    }

    system("PAUSE");
    return 0;
}

Clietn Code:

#include "stdafx.h"
#include <stdio.h>
#include <windows.h>
#include <ctime>

int main(int argc, _TCHAR* argv[])
{
    srand(time(NULL));

    DWORD wlen = 0;
    Sleep(1000);//等待pipe的創建成功！

    BOOL bRet = WaitNamedPipe(TEXT("\\\\.\\Pipe\\mypipe"), NMPWAIT_WAIT_FOREVER);

    if (!bRet)
    {
        printf("connect the namedPipe failed!\n");
        return 0;
    }

    HANDLE hPipe=CreateFile(            //管道屬於一種特殊的文件
        TEXT("\\\\.\\Pipe\\mypipe"),    //創建的文件名
        GENERIC_READ | GENERIC_WRITE,   //文件模式
        0,                              //是否共享
        NULL,                           //指向一個SECURITY_ATTRIBUTES結構的指針
        OPEN_EXISTING,                  //創建參數
        FILE_ATTRIBUTE_NORMAL,          //文件屬性(隱藏,只讀)NORMAL為默認屬性
        NULL);                          //模板創建文件的句柄

    if (INVALID_HANDLE_VALUE == hPipe)
    {
        printf("open the exit pipe failed!\n");
    }
    else
    {
        while(true)
        {
            char buf[256] = "";
            sprintf(buf,"%s%d",buf,rand()%1000);
            if(WriteFile(hPipe,buf,sizeof(buf),&wlen,0)==FALSE) //向服務器發送內容
            {
                printf("write to pipe failed!\n");
                break;
            }
            else
            {
                printf("To Server: data = %s, size = %d\n", buf, wlen);
                char rbuf[256] = "";
                DWORD rlen = 0;
                ReadFile(hPipe, rbuf, sizeof(rbuf), &rlen, 0);  //接受服務發送過來的內容
                printf("From Server: data = %s, size = %d\n", rbuf, rlen);
            }
            Sleep(1000);
        }
        CloseHandle(hPipe);//關閉管道
    }

    system("PAUSE");
    return 0;
}