VC++多線程--進程間通信
阿新 • • 發佈:2017-11-18
郵槽 客戶端連接 and 到來 技術 pau ont data- forever
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模式是指在當網絡中有相關的套接字消息到來時,程序才會調用相關的響應函數對該消息進行處理,否則,程序將在系統後臺繼續等待相關的消息到來或者實現其他操作。
VC++多線程--進程間通信