VC++多線程--進程間通信

1、郵槽

郵槽是windows系統提供的一種單向通信的機制，郵槽能傳輸的數據非常小，一般在400k左右。

創建郵槽

HANDLE CreateMailslot(
LPCTSTR lpName, //指定郵件槽的名字，如//./Mailslot/[path]name，小數點表示服務器為本的機器（不能為遠程計算機創建郵件槽）。 DWORD nMaxMessageSize,//可寫入郵件槽的最大消息長度(字節單位)，客戶機發生消息大於該值服務器不接受該消息；為0，接收任意長度消息。 DWORD lReadTiemout,//等待模式和不等待模式,MAILSLOT_WAIT_FOREVER無限期等待，0立即返回，其它值以毫秒為單位。 LPSECURITY_ATTRIBUTES lpSecurityAttributes//訪問控制權限，一般都設為NULL );

實例

服務端

 1 #include <Windows.h>
 2 #include <stdio.h>  3 int main()  4 {  5 HANDLE mail; //定義郵槽句柄  6 mail=CreateMailslot("\\\\.\\mailslot\\newslot",0,MAILSLOT_WAIT_FOREVER,NULL); //創建郵槽  7 if (mail==INVALID_HANDLE_VALUE) //判斷郵槽句柄  8  {  9 printf("創建郵槽失敗！\r\n"); 10 CloseHandle(mail); //關閉句柄 11  } 12 else 13  { 14 printf("郵槽創建成功！\r\n"); 15 char text[200]; 16 DWORD readtext; //獲取實際讀取值 17 if (ReadFile(mail,text,200,&readtext,NULL)) //讀取數據 18  { 19  printf(text); 20  } 21 else 22  { 23 printf("\r\n讀取數據失敗!\r\n"); 24  } 25 CloseHandle(mail); //關閉句柄 26 Sleep(1000); 27  } 28 29 return 0; 30 }

客戶端

 1 #include <Windows.h>
 2 #include <stdio.h>  3 int main()  4 {  5 HANDLE mail2; //郵槽句柄  6 char text[]="我要發消息了";  7  DWORD writetext;  8 mail2=CreateFile("\\\\.\\mailslot\\newslot",GENERIC_WRITE,FILE_SHARE_READ,NULL,OPEN_EXISTING,FILE_ATTRIBUTE_NORMAL,NULL); //打開文件/創建文件  9 if (INVALID_HANDLE_VALUE==mail2) //判斷是否打開成功 10  { 11 printf("郵槽打開失敗！\r\n"); 12 13  } 14 else 15  { 16 if (WriteFile(mail2,text,sizeof(text),&writetext,NULL)) //寫數據 17  { 18 Sleep(100); 19 printf("數據寫入成功\r\n"); 20  } 21 else 22  { 23 Sleep(100); 24 printf("郵槽寫入失敗！\r\n"); 25  } 26 CloseHandle(mail2); //關閉郵槽 27  } 28 Sleep(10000); 29 return 0; 30 }

 

2、命名管道

命名管道是一種不但能在同一個機器上實現兩個進程通信，還能在網絡中不同機器上的兩個進程之間通信的機制。命名管道傳輸數據是采取基於連接並且可靠的傳輸方式，所以命名管道傳輸數據只能一對一進行傳輸。

HANDLE WINAPI CreateNamedPipe(
     LPCTSTR lpName,
      DWORD dwOpenMode,
      DWORD dwPipeMode,
      DWORD nMaxInstances,
      DWORD nOutBufferSize,
      DWORD nInBufferSize,
      DWORD nDefaultTimeOut,
      LPSECURITY_ATTRIBUTES lpSecurityAttributes
);

 實例：

服務端

 1 #include <Windows.h>
 2 #include <stdio.h>  3 int main()  4 {  5  HANDLE hpip;  6 OVERLAPPED ovi={0}; //定義結構體變量  7 char buf[200]; //定義數據緩沖區  8 DWORD readbuf; //獲取實際讀取字節數  9 hpip=CreateNamedPipe("\\\\.\\pipe\\newpipe",PIPE_ACCESS_DUPLEX,PIPE_TYPE_BYTE,PIPE_UNLIMITED_INSTANCES,1024,1024,0,NULL); //創建管道 10 printf("創建管道成功，正在等待客戶端連接...\r\n"); 11 if (ConnectNamedPipe(hpip,&ovi)) //等待客戶端的連接請求 12  { 13 printf("客戶端連接成功！\r\n"); 14 printf("正在讀取數據！\r\n"); 15 if (ReadFile(hpip,buf,200,&readbuf,NULL)) //讀取管道數據 16  { 17 printf("數據讀取成功！\r\n"); 18 printf("讀取的數據是：%s\r\n",buf); 19  } 20 else 21  { 22 printf("數據讀取失敗！\r\n"); 23  } 24  } 25 else 26  { 27 printf("客戶端連接失敗，請重試...\r\n"); 28  } 29 system("pause"); 30 return 0; 31 }

客戶端

 1 #include <Windows.h>
 2 #include <stdio.h>  3 int main()  4 {  5  HANDLE hpipe;  6 OVERLAPPED ovi={0};  7 char buf[200]="命名管道測試";  8  DWORD writebuf;  9 printf("正在連接管道......\r\n"); 10 if (WaitNamedPipe("\\\\.\\pipe\\newpipe",NMPWAIT_WAIT_FOREVER)) //連接命名管道 11  { 12 printf("管道連接成功！"); 13 printf("\r\n"); 14 hpipe=CreateFile("\\\\.\\pipe\\newpipe",GENERIC_READ|GENERIC_WRITE,0,NULL,OPEN_EXISTING,FILE_ATTRIBUTE_NORMAL,NULL); //打開制定命名管道 15 if (hpipe==INVALID_HANDLE_VALUE) 16  { 17 printf("打開管道失敗！\r\n"); 18  } 19 else 20  { 21 if (WriteFile(hpipe,buf,200,&writebuf,NULL)) //寫入數據到命名管道 22  { 23 printf("數據寫入成功！\r\n"); 24  } 25 else 26  { 27 printf("數據寫入失敗，請重試......\r\n"); 28  } 29  } 30  } 31 system("pause"); 32 return 0; 33 }

 

3、匿名管道

匿名管道是沒有命名的管道，只能在父進程和子進程之間進行數據通信，與命名管道相比，匿名管道不能被使用在網絡進程之間。

異步I/O模式

在套接字編程中，異步I/O模式是指在當網絡中有相關的套接字消息到來時，程序才會調用相關的響應函數對該消息進行處理，否則，程序將在系統后台繼續等待相關的消息到來或者實現其他操作。