码迷,mamicode.com
首页 > 其他好文 > 详细

命名管道-简单的例子

时间:2014-05-23 23:13:19      阅读:304      评论:0      收藏:0      [点我收藏+]

标签:style   class   blog   c   code   java   

bubuko.com,布布扣
#include "stdafx.h"
#include<iostream>
#include<windows.h>
#include<ctime>
using namespace std;
DWORD WINAPI thread1(LPVOID param)
{
    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,NMPWAIT_WAIT_FOREVER,0);//创建了一个命名管道
    if(ConnectNamedPipe(hPipe, NULL)==NULL)//等待另一客户的链接。
    {
       cerr<<"链接失败!"<<endl;
    }
    else
    {
       cerr<<"链接成功"<<endl;
    }
    while (true)
    {
        if(ReadFile(hPipe,buf,256,&rlen,NULL)==FALSE)//读取管道中的内容(管道是一种特殊的文件)
        {
           CloseHandle(hPipe);//关闭管道
           cerr<<"read data from Pipe failed!"<<endl;
        }
        else
        {
           cout<<"thread1 get data="<<buf<<" size="<<rlen<<endl;

           char wbuf[256]="server message!!!";
           sprintf(wbuf,"%s - %d",wbuf,rand()%1000);
           DWORD wlen=0;
           WriteFile(hPipe,wbuf,sizeof(wbuf),&wlen,0);
           cout<<"thread1 write data to pipe,data="<<wbuf<<" size="<<wlen<<endl;//收完发
           Sleep(5000);
  
        }
    }
return 0;
}
DWORD WINAPI thread2(LPVOID param)
{
    char buf[256]="client message!!!";
    sprintf(buf,"%s - %d",buf,rand()%1000);
    DWORD wlen=0;
    Sleep(1000);//等待pipe的创建成功!
    if (WaitNamedPipe(TEXT("\\\\.\\Pipe\\mypipe"), NMPWAIT_WAIT_FOREVER) == FALSE)
    {
       cerr<<"connect the namedPipe failed!"<<endl;
       return 0;
    }
    HANDLE hPipe=CreateFile(TEXT("\\\\.\\Pipe\\mypipe"), GENERIC_READ | GENERIC_WRITE, 0,
   NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
    if((long)hPipe==-1)
    {
       cerr<<"open the exit pipe failed!"<<endl;
       return 0;
    }
    while(1)
    {
       if(WriteFile(hPipe,buf,sizeof(buf),&wlen,0)==FALSE)
       {
        cerr<<"write to pipe failed!"<<endl;
       }
       else
       {
        cout<<"write size="<<wlen<<endl;
        char rbuf[256];
        DWORD rlen=0;
       ReadFile(hPipe,rbuf,sizeof(rbuf),&rlen,0);//这里可以测试,一发必先有一收(另一进程中),否则将无法继续(阻塞式)
        cout<<"thread2 read from pipe data="<<rbuf<<" size="<<rlen<<endl<<endl;
       }
       Sleep(5000);
    }
    return 0;
}
int main()
{
    srand((unsigned)time(NULL));
    CreateThread(0,0,thread1,0,0,0);
    CreateThread(0,0,thread2,0,0,0);
    system("pause");
    return 1;
}                        
bubuko.com,布布扣

 

命名管道-简单的例子,布布扣,bubuko.com

命名管道-简单的例子

标签:style   class   blog   c   code   java   

原文地址:http://www.cnblogs.com/duyy/p/3737132.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!