2. 程式人生 > >Windows API 程序間通訊，管道(Pipe)

Windows API 程序間通訊，管道(Pipe)

阿新 • • 發佈：2019-01-27
通過pipe程序間通訊
**************************************//* 標頭檔案 */
#include <windows.h>
#include <stdio.h>
#include <tchar.h>/* 常量 */#define PIPE_TIMEOUT 5000#define BUFSIZE 4096/* 結構定義 */
typedef struct
{
OVERLAPPED oOverlap;
HANDLE hPipeInst;
TCHAR chRequest[BUFSIZE];
DWORD cbRead;
TCHAR chReply[BUFSIZE];
DWORD cbToWrite;
} PIPEINST,
*LPPIPEINST;
/* 函式宣告 */
VOID DisconnectAndClose(LPPIPEINST);
BOOL CreateAndConnectInstance(LPOVERLAPPED);
BOOL ConnectToNewClient(HANDLE, LPOVERLAPPED);
VOID GetAnswerToRequest(LPPIPEINST);
VOID WINAPI CompletedWriteRoutine(DWORD, DWORD, LPOVERLAPPED);
VOID WINAPI CompletedReadRoutine(DWORD, DWORD, LPOVERLAPPED);
/* 全域性變數 */
HANDLE hPipe;
/* ************************************
* int main(VOID)
* 功能 pipe 通訊服務端主函式
**************************************/int main(VOID)
{
HANDLE hConnectEvent;
OVERLAPPED oConnect;
LPPIPEINST lpPipeInst;
DWORD dwWait, cbRet;
BOOL fSuccess, fPendingIO;

// 用於連線操作的事件物件
hConnectEvent = CreateEvent(
NULL, // 預設屬性 TRUE, // 手工reset TRUE, // 初始狀態 signaled NULL); // 未命名if (hConnectEvent == NULL)
{
printf("CreateEvent failed with %d.\n", GetLastError());
return0;
}
// OVERLAPPED 事件 oConnect.hEvent = hConnectEvent;

// 建立連線例項，等待連線 fPendingIO = CreateAndConnectInstance(&oConnect);

while (1)
{
// 等待客戶端連線或讀寫操作完成 dwWait = WaitForSingleObjectEx(
hConnectEvent, // 等待的事件 INFINITE, // 無限等待 TRUE);

switch (dwWait)
{
case0:
// pending if (fPendingIO)
{
// 獲取 Overlapped I/O 的結果 fSuccess = GetOverlappedResult(
hPipe, // pipe 控制代碼 &oConnect, // OVERLAPPED 結構 &cbRet, // 已經傳送的資料量 FALSE); // 不等待if (!fSuccess)
{
printf("ConnectNamedPipe (%d)\n", GetLastError());
return0;
}
}

// 分配記憶體 lpPipeInst = (LPPIPEINST) HeapAlloc(GetProcessHeap(),0,sizeof(PIPEINST));
if (lpPipeInst == NULL)
{
printf("GlobalAlloc failed (%d)\n", GetLastError());
return0;
}
lpPipeInst->hPipeInst = hPipe;

// 讀和寫，注意CompletedWriteRoutine和CompletedReadRoutine的相互呼叫 lpPipeInst->cbToWrite =0;
CompletedWriteRoutine(0, 0, (LPOVERLAPPED) lpPipeInst);

// 再建立一個連線例項，以響應下一個客戶端的連線 fPendingIO = CreateAndConnectInstance(
&oConnect);
break;

// 讀寫完成 case WAIT_IO_COMPLETION:
break;

default:
{
printf("WaitForSingleObjectEx (%d)\n", GetLastError());
return0;
}
}
}
return0;
}

/* ************************************
* CompletedWriteRoutine
* 寫入pipe操作的完成函式
* 介面參見FileIOCompletionRoutine回撥函式定義
*
* 當寫操作完成時被呼叫，開始讀另外一個客戶端的請求
**************************************/
VOID WINAPI CompletedWriteRoutine(
DWORD dwErr,
DWORD cbWritten,
LPOVERLAPPED lpOverLap)
{
LPPIPEINST lpPipeInst;
BOOL fRead = FALSE;
// 儲存overlap例項 lpPipeInst = (LPPIPEINST) lpOverLap;

// 如果沒有錯誤if ((dwErr ==0) && (cbWritten == lpPipeInst->cbToWrite))
{
fRead = ReadFileEx(
lpPipeInst->hPipeInst,
lpPipeInst->chRequest,
BUFSIZE*sizeof(TCHAR),
(LPOVERLAPPED) lpPipeInst,
// 寫讀操作完成後，呼叫CompletedReadRoutine (LPOVERLAPPED_COMPLETION_ROUTINE) CompletedReadRoutine);
}
if (! fRead)
// 出錯，斷開連線 DisconnectAndClose(lpPipeInst);
}

/* ************************************
* CompletedReadRoutine
* 讀取pipe操作的完成函式
* 介面參見FileIOCompletionRoutine回撥函式定義
*
* 當讀操作完成時被呼叫，寫入回覆
**************************************/
VOID WINAPI CompletedReadRoutine(
DWORD dwErr,
DWORD cbBytesRead,
LPOVERLAPPED lpOverLap)
{
LPPIPEINST lpPipeInst;
BOOL fWrite = FALSE;

// 儲存overlap例項 lpPipeInst = (LPPIPEINST) lpOverLap;

// 如果沒有錯誤if ((dwErr ==0) && (cbBytesRead !=0))
{
// 根據客戶端的請求，生成回覆 GetAnswerToRequest(lpPipeInst);
// 將回複寫入到pipe fWrite = WriteFileEx(
lpPipeInst->hPipeInst,
lpPipeInst->chReply, //將響應寫入pipe lpPipeInst->cbToWrite,
(LPOVERLAPPED) lpPipeInst,
// 寫入完成後，呼叫CompletedWriteRoutine (LPOVERLAPPED_COMPLETION_ROUTINE) CompletedWriteRoutine);
}

if (! fWrite)
// 出錯，斷開連線 DisconnectAndClose(lpPipeInst);
}

/* ************************************
* VOID DisconnectAndClose(LPPIPEINST lpPipeInst)
* 功能 斷開一個連線的例項
* 引數 lpPipeInst，斷開並關閉的例項控制代碼
**************************************/
VOID DisconnectAndClose(LPPIPEINST lpPipeInst)
{
// 關閉連線例項if (! DisconnectNamedPipe(lpPipeInst->hPipeInst) )
{
printf("DisconnectNamedPipe failed with %d.\n", GetLastError());
}
// 關閉 pipe 例項的控制代碼 CloseHandle(lpPipeInst->hPipeInst);
// 釋放if (lpPipeInst != NULL)
HeapFree(GetProcessHeap(),0, lpPipeInst);
}

/* ************************************
* BOOL CreateAndConnectInstance(LPOVERLAPPED lpoOverlap)
* 功能 建立連線例項
* 引數 lpoOverlap，用於overlapped IO的結構
* 返回值 是否成功
**************************************/
BOOL CreateAndConnectInstance(LPOVERLAPPED lpoOverlap)
{
LPTSTR lpszPipename = TEXT("\\\\.\\pipe\\samplenamedpipe");
// 建立named pipe hPipe = CreateNamedPipe(
lpszPipename, // pipe 名 PIPE_ACCESS_DUPLEX |// 可讀可寫 FILE_FLAG_OVERLAPPED, // overlapped 模式
// pipe模式 PIPE_TYPE_MESSAGE |// 訊息型別 pipe PIPE_READMODE_MESSAGE |// 訊息讀模式 PIPE_WAIT, // 阻塞模式 PIPE_UNLIMITED_INSTANCES, // 無限制例項 BUFSIZE*sizeof(TCHAR), // 輸出快取大小 BUFSIZE*sizeof(TCHAR), // 輸入快取大小 PIPE_TIMEOUT, // 客戶端超時 NULL); // 預設安全屬性if (hPipe == INVALID_HANDLE_VALUE)
{
printf("CreateNamedPipe failed with %d.\n", GetLastError());
return0;
}

// 連線到新的客戶端return ConnectToNewClient(hPipe, lpoOverlap);
}

/* ************************************
* BOOL ConnectToNewClient(HANDLE hPipe, LPOVERLAPPED lpo)
* 功能 建立連線例項
* 引數 lpoOverlap，用於overlapped IO的結構
* 返回值 是否成功
**************************************/
BOOL ConnectToNewClient(HANDLE hPipe, LPOVERLAPPED lpo)
{
BOOL fConnected, fPendingIO = FALSE;

// 開始一個 overlapped 連線 fConnected = ConnectNamedPipe(hPipe, lpo);

if (fConnected)
{
printf("ConnectNamedPipe failed with %d.\n", GetLastError());
return0;
}
switch (GetLastError())
{
// overlapped連線進行中. case ERROR_IO_PENDING:
fPendingIO = TRUE;
break;
// 已經連線，因此Event未置位 case ERROR_PIPE_CONNECTED:
if (SetEvent(lpo->hEvent))
break;
// errordefault:
{
printf("ConnectNamedPipe failed with %d.\n", GetLastError());
return0;
}
}
return fPendingIO;
}

// TODO根據客戶端的請求，給出響應VOID GetAnswerToRequest(LPPIPEINST pipe)
{
_tprintf( TEXT("[%d] %s\n"), pipe->hPipeInst, pipe->chRequest);
lstrcpyn( pipe->chReply, TEXT("Default answer from server") ,BUFSIZE);
pipe->cbToWrite = (lstrlen(pipe->chReply)+1)*sizeof(TCHAR);
}

相關推薦

Windows API 程序間通訊，管道(Pipe)

通過pipe程序間通訊**************************************//* 標頭檔案 */#include <windows.h> #include <stdio.h>#include <tchar.h>/* 常量 */#define PIPE

程序間通訊之管道--pipe和fifo使用

匿名管道pipe 函式原型： #include <unistd.h> int pipe(int fildes[2]); 引數說明 fildes是我們傳入的陣列，也是一個傳出引數。fildes[0]是讀端，fildes[1]是寫端。 返回值 成功呼叫返回0。 失敗呼叫返回-1且

Linux系統程式設計——程序間通訊：管道（pipe）

管道的概述 管道也叫無名管道，它是是 UNIX 系統 IPC（程序間通訊） 的最古老形式，所有的 UNIX 系統都支援這種通訊機制。 無名管道有如下特點： 1、半雙工，資料在同一時刻只能在一個方向上流動。 2、資料只能從管道的一端寫入，從另一端讀出。

程序間通訊之管道通訊(PIPE匿名管道)

#include<stdio.h> #include<errno.h> #include<fcntl.h> #include<unistd.h> #include<stdlib.h> #include<string.h> int

程序間通訊：管道（pipe）

管道的概述 管道也叫無名管道，它是是 UNIX 系統 IPC（程序間通訊） 的最古老形式，所有的 UNIX 系統都支援這種通訊機制。 無名管道有如下特點： 1、半雙工，資料在同一時刻只能在一個方向上流動。 2、資料只能從管道的一端寫入，從另一端讀出。 3、寫入

Linux Pipe （程序間通訊，生產者消費者）

PIPE是Linux下可以用來實現程序間通訊的一種手段，當我們呼叫pipe系統呼叫時，將會產生一對檔案描述符，fd[0]可以用來讀，fd[1]用來寫，fd[1]寫的資料將會在fd[0]中讀到，我們稱之為管道。程序之間可以依賴管道的方式實現程序間通訊，pipe是半

Windows程序間通訊—命名管道

命名管道是通過網路來完成程序間的通訊，它遮蔽了底層的網路協議細節。我們在不瞭解網路協議的情況下，也可以利用命名管道來實現程序間的通訊。與Socket網路通訊相比，命名管道不再需要編寫身份驗證的程式碼。將命名管道作為一種網路程式設計方案時，它實際上建立了一個C/S通訊體系，並在其中可靠的傳輸資料。命名管道伺服器

Linux：程序間通訊之管道通訊詳解

        在學習程序的時候，我們瞭解到了程序的獨立性：程序之間是相互獨立的，每個程序有自己的虛擬地址空間，並且虛擬地址空間通過頁表的對映，對映到屬於自己的實體記憶體上。並且各個程序之間互相不影響，執行自己的程式碼。    

php程序間通訊--有名管道

管道PIPE 　　管道用於承載簡稱之間的通訊資料。為了方便理解，可以將管道比作檔案，程序A將資料寫到管道P中，然後程序B從管道P中讀取資料。php提供的管道操作API與操作檔案的API基本一樣，除了建立管道使用posix_mkfifo函式，讀寫等操作均與檔案操作函式相同。當然，你可以直接使用檔案

Visual C++網路程式設計經典案例詳解 第3章 多執行緒與非同步套接字程式設計 程序間通訊 命名管道 命名管道例項

vc新增控制檯工程 名字命名管道例項 新增原始檔 名字 伺服器 #include<windows.h>                                //包含標頭檔案 #include<stdio.h> int main() {  

Linux程序間通訊——01管道

程序間通訊: 對於每個程序來說，都有一份屬於它自己的記憶體資源，並且獨佔這份記憶體資源。而程序間通訊的目的就是讓不同的程序間能看到一份公共的資源。所有交換的資料必須通過核心來傳遞，在核心中開闢一塊緩衝區，通過這塊緩衝區來實現資料的傳遞，核心提供的這種機制稱為程序間通訊。

【linux開發】程序間通訊命名管道-共享記憶體-記憶體對映-訊息佇列-訊號量

程序間通訊命名管道-共享記憶體-記憶體對映-訊息佇列-訊號量  在Unix平臺上，建立命名管道是建立了一個fifo檔案，和在shell下面用mkfifo命令的效果是一樣的。看起來這個管道檔案就是一個普通的檔案系統瓜掛載點，但是它只不過是作為一個名稱存在，實際的內容是一塊系統

共享記憶體多程序間通訊，程序間同步使用訊號量來實現

Linux 環境下C程式設計指南，通過共享記憶體進行程序間通訊的例子，程序間同步使用訊號量來實現。 程式碼 11-5 使用說明：這是一個簡單的伺服器和客戶端程式，如果啟動程式時不帶引數，則執行伺服器程式； 如果帶引數，則執行客戶端程式，所帶引數只有一個，就是伺服器端所顯

Linux程序間通訊之——管道（整理）

 程序間通訊 fork pipe pie_t 等用法（管道機制 通訊） 每個程序各自有不同的使用者地址空間，任 何一個程序的全域性變數在另一個程序中都看不到，所以程序之間要交換資料必須通過核心，在核心中開闢一塊緩衝 區，程序1把資料從使用者空間拷到核心緩衝區，程序2再從

Linux -- 程序間通訊之管道

管道是Linux裡的一種檔案型別，同時也是Linux系統下程序間通訊的一種方式 建立一個管道檔案有兩種方式： 1.  Shell 下命令 mkfifo + filename，即建立一個有名管道 2.

人工智慧（PythonNet）—— 程序間通訊（管道、訊息佇列、共享記憶體、訊號、訊號量、套接字）

一、程序間通訊        程序間通訊(IPC,InterProcess Communication)是指在不同程序之間傳播或交換資訊。        由於每個程序的空間是互相獨立的，程序之間無法互相直接獲取彼此的資源，故引入程序間通訊來實現程序間的資源互動。       

java中程序間通訊，基於檔案和共享記憶體

附上編譯執行的原始碼： 1，請分別建立兩個工程來進行讀寫操作； 2，請在相應的目錄建立一個檔案例如：/home/tory/workspace/sharedMemory.txt 3，往檔案中輸入超過12個位元組資料：echo asldkjasldkddas > /hom

Linux 程序間通訊之管道

程序之間的通訊之管道 目錄 1 無名管道    管道是一種最基本的IPC機制，作用於父子程序之間，完成資料傳遞。 管道有以下特性： 1.其本質是一個偽檔案(實為核心緩衝區)其本質是一個偽檔案(實為核心緩衝區) 2.由兩

delphi 程序間通訊（管道通訊）

前段時間，因專案需求，需要用到管道通訊。感覺管道通訊就是一層窗戶紙，捅破了就好了。 需求是：客戶端（client），按鈕被觸發後，傳送指令給伺服器端（server），server接收到指令後進行相應的操作，並立馬返回資訊給client。對於client而言，只是主動呼叫了一

【Linux】程序間通訊-命名管道FIFO

命名管道概述 如果我們要在不相關的程序間交換資料，那麼使用FIFO檔案將會十分方便。 FIFO檔案通常也稱為命名管道（named pipe）。命名管道是一種特殊型別的檔案，它在檔案系統中以檔名的形式存在。 建立命名管道 建立命名管道一般有兩種方式： 命令列方式 一個比較舊