Передача данных по Анонимным (Неименованым) каналам с последующим использованием этих данных

//клиент
#include <iostream>
#include <windows.h>
 
using namespace std;
 
int main()
{
    int szBuf[4];
    srand(GetCurrentProcessId());
 
    //"открываем" событие, созданное сервером
    HANDLE hEv = CreateEventA(0, TRUE, FALSE, "READEVENT");
 
    szBuf[0]=(rand()%5)+1;
    szBuf[1]=(szBuf[0]+rand()%20)*2;
    szBuf[2]=rand()%5;
    szBuf[3]=rand()%5;
 
    //пишем в канал (дескриптор вывода переопределен в коде создание процесса в сервере
    std::cout<<"Hi, i'm client\0"<<endl;
    for (int i=0;i<4;i++)
        std::cout<<szBuf[i]<<endl;
    //информируем сервер о готовности данных для чтения
    SetEvent(hEv);
 
    CloseHandle(hEv);
 
    return 0;
}

//сервер
#include <iostream>
#include <windows.h>
#include <stdio.h>
#include <conio.h>
#include <fstream>
#include <cmath>
using namespace std;
 
void tab(int start, int end, int step, int funcnum)
{
    ofstream file("ResultFile.txt",ios_base::app);
    if(start>end)
        swap(start,end);
    if(step==0)
        step++;
    switch(funcnum)
    {
    case 0:
        file<<"Крок: "<<step<<", Початкове значення: "<<start<<", Kiнцеве значення: "<<end<<" функція sin(x) має значення:\n";
        for(int i=start;i<end;i+=step)
        {
            file<<sin(i)<<"\t";
        }
        file<<"\n\n";
        break;
    case 1:
        file<<"Крок: "<<step<<", Початкове значення: "<<start<<", Kiнцеве значення: "<<end<<" функція cos(x) має значення:\n";
        for(int i=start;i<end;i+=step)
        {
            file<<cos(i)<<"\t";
        }
        file<<"\n\n";
        break;
    case 2:
        file<<"Крок: "<<step<<", Початкове значення: "<<start<<", Kiнцеве значення: "<<end<<" функція tg(x) має значення:\n";
        for(int i=start;i<end;i+=step)
        {
            file<<tan(i)<<"\t";
        }
        file<<"\n\n";
        break;
    case 3:
        file<<"Крок: "<<step<<", Початкове значення: "<<start<<", Kiнцеве значення: "<<end<<" функція ctg(x) має значення:\n";
        for(int i=start;i<end;i+=step)
        {
            file<<1/tan(i)<<"\t";
        }
        file<<"\n\n";
        break;
    default:
        file<<"Крок: "<<step<<", Початкове значення: "<<start<<", Kiнцеве значення: "<<end<<" функція 1/x має значення:\n";
        for(int i=start;i<end;i+=step)
        {
            file<<1.0/i<<"\t";
        }
        file<<"\n\n";
    }
    file.close();
}
 
int main()
{
    HANDLE hRead = INVALID_HANDLE_VALUE;
    HANDLE hWrite = INVALID_HANDLE_VALUE;
 
    int szBuf[4];
 
    SECURITY_ATTRIBUTES sa = {sizeof(sa)};
    sa.bInheritHandle = TRUE; //хэндлы наследуемые
    sa.lpSecurityDescriptor = NULL;
 
    //создаем анонимный канал
    if(!CreatePipe(&hRead, &hWrite, &sa, 0))
    {
        std::cout<<"Error code: "<<GetLastError()<<std::endl;
        return -1;
    }
 
    //событие для информирования о доступности чтения
    HANDLE hEv = CreateEventA(0, TRUE, FALSE, "READEVENT");
 
    STARTUPINFOA si = {sizeof(si)};
 
    //передаем хэндлы в процесс-клиент
    si.hStdOutput = hWrite;
    si.hStdInput = hRead;
    si.hStdError = hWrite;
 
    //говорим о необходимости переопределения стандартных дескрипторов
    si.dwFlags = STARTF_USESTDHANDLES;
 
    PROCESS_INFORMATION pi = {0};
 
    //запускаем процесс-клиент
    if(!CreateProcessA(NULL, "CLIENT.exe", NULL, NULL, TRUE, 0, NULL, NULL, &si, &pi ))
    {
        std::cout<<"Error code: "<<GetLastError()<<std::endl;
        CloseHandle(hRead);
        CloseHandle(hWrite);
        CloseHandle(hEv);
        return -1;
    }
    CloseHandle(pi.hProcess);
    CloseHandle(pi.hThread);
 
    //ждем пока клиент запишет данные
    WaitForSingleObject(hEv, INFINITE);
 
    DWORD readed = 0;
    BYTE buf[255] = {0};
 
    //читаем данные из канала и выводим их (в данном случае будет строка)
    if(ReadFile(hRead, buf, 255, &readed, NULL))
    {
        std::cout<<"Read from pipe:"<< (char*)buf<<std::endl;system("PAUSE");
    }
 
    for (int i=0;i<4;i++)
        std::cout<<szBuf<<endl;
 
    tab(szBuf[0],szBuf[1],szBuf[2],szBuf[3]);
 
    CloseHandle(hRead);
    CloseHandle(hWrite);
    CloseHandle(hEv);
 
    return 0;
}

WaitForSingleObject(hMutex, INFINITE);

//---------------------
//    C L I E N T
//---------------------
 
#include <iostream>
#include <Windows.h>
 
int main()
{
    using namespace std;
    srand(GetCurrentProcessId());
 
    HANDLE hMutex;
    hMutex = OpenMutex(SYNCHRONIZE, FALSE, L"DemoMutex");
 
    HANDLE const hStdOutput = GetStdHandle(STD_OUTPUT_HANDLE);
    
    //Захватываем мютекс
    WaitForSingleObject(hMutex, INFINITE); 
    
    // Записываем в устройство переменную типа int.
    int szBuf[4]={0,0,0,0};
    szBuf[0]=(rand()%5)+1;
    szBuf[1]=(szBuf[0]+rand()%20)*2;
    szBuf[2]=rand()%5;
    szBuf[3]=rand()%5;
 
    DWORD nBytes;
    WriteFile(hStdOutput, &szBuf, sizeof (szBuf), &nBytes, NULL);
 
    return EXIT_SUCCESS;
 
    ReleaseMutex(hMutex);
    CloseHandle(hMutex);
}

//---------------------
//    C L I E N T
//--------------------- 
#include <iostream>
#include <Windows.h>
  
int main()
{
    using namespace std;
 
    HANDLE const hStdOutput = GetStdHandle(STD_OUTPUT_HANDLE);
 
    int const Value = 123;
 
    DWORD nBytes;
    WriteFile(hStdOutput, &Value, sizeof (Value), &nBytes, NULL);
 
    return EXIT_SUCCESS;
}

//---------------------
//    S E R V E R
//---------------------  
#include <iostream>
#include <Windows.h>
  
int main()
{
    using namespace std;
 
    SECURITY_ATTRIBUTES sa;
    sa.bInheritHandle = TRUE;
    sa.lpSecurityDescriptor = NULL;
    sa.nLength = sizeof (sa);    
 
    HANDLE hReadPipe;
    HANDLE hWritePipe;    
 
    CreatePipe(&hReadPipe, &hWritePipe, &sa, 0);
 
    STARTUPINFOW si;
    GetStartupInfoW(&si);
 
    si.dwFlags |= STARTF_USESTDHANDLES;
    si.hStdOutput = hWritePipe;
 
    PROCESS_INFORMATION pi;
 
    wchar_t pCmdLine[] = {L"client.exe"}; // Буфер должен быть изменяемым !
 
    CreateProcessW(NULL,
        pCmdLine,
        NULL,
        NULL,
        TRUE, // <--- Наследовать хэндлы ? Да.
        NORMAL_PRIORITY_CLASS,
        NULL,
        NULL,
        &si,
        &pi);
 
    CloseHandle(pi.hProcess);
    CloseHandle(pi.hThread);
  
    CloseHandle(hWritePipe);
 
    DWORD const BuffSize = 100;
    byte *pBuffer = new byte[BuffSize];
 
    DWORD nBytes;
 
    ReadFile(hReadPipe, pBuffer, BuffSize, &nBytes, NULL);
    CloseHandle(hReadPipe);
 
    int const Value = *((int const *)pBuffer);
 
    cout << "Value = " << Value << endl;
 
    delete [] pBuffer;
 
    return EXIT_SUCCESS;
}

//---------------------
//    C L I E N T
//---------------------
 
#include <iostream>
#include <Windows.h>
 
int main()
{
    using namespace std;
    srand(GetCurrentProcessId());
 
    //"открываем" событие, созданное сервером
    HANDLE hEv = CreateEventA(0, TRUE, FALSE, "READEVENT");
 
    HANDLE hMutex;
    hMutex = OpenMutex(SYNCHRONIZE, FALSE, L"Mutex");
 
    HANDLE const hStdOutput = GetStdHandle(STD_OUTPUT_HANDLE);
 
    //Захватываем мютекс
    WaitForSingleObject(hMutex, INFINITE);
 
    // Записываем в устройство переменную типа int.
    int szBuf[4]={0,0,0,0};
    szBuf[0]=(rand()%5)+1;
    szBuf[1]=(szBuf[0]+rand()%20)*2;
    szBuf[2]=rand()%5;
    szBuf[3]=rand()%5;
 
    DWORD nBytes;
    if(!WriteFile(hStdOutput, &szBuf, sizeof (szBuf), &nBytes, NULL))
    {
        std::cout<<"Error code: "<<GetLastError()<<std::endl;
        return -1;
    };
 
    SetEvent(hEv);
    CloseHandle(hEv);
        CloseHandle(hMutex);
    return EXIT_SUCCESS;
}

//---------------------
//    S E R V E R
//---------------------
#include <iostream>
#include <Windows.h>
#include <stdio.h>
#include <conio.h>
#include <fstream>
#include <cmath>
using namespace std;
void tab(int start, int end, int step, int funcnum){...}
int main()
{
    SECURITY_ATTRIBUTES sa;
    sa.bInheritHandle = TRUE;
    sa.lpSecurityDescriptor = NULL;
    sa.nLength = sizeof (sa);
 
    HANDLE hReadPipe;
    HANDLE hWritePipe;
    HANDLE hMutex;
    hMutex = CreateMutex(NULL, FALSE, L"DemoMutex");
 
    if (!CreatePipe(&hReadPipe, &hWritePipe, &sa, 0))
    {
        std::cout<<"Error code: "<<GetLastError()<<std::endl;
        return -1;
    };
 
    //событие для информирования о доступности чтения
    HANDLE hEv = CreateEventA(0, TRUE, FALSE, "READEVENT");
 
    cout << "Server v ochikuvani" << endl;Sleep(500);
    // Заполняем структуру STARTUPINFO для будущего процесса.
    // Подменяем хэндл стандартного вывода на хэндл записи в пайп.
    STARTUPINFOW si;
    GetStartupInfoW(&si);
    si.dwFlags |= STARTF_USESTDHANDLES;
    si.hStdOutput = hWritePipe;
 
    // Запускаем дочерний процесс.
    PROCESS_INFORMATION pi;
    wchar_t pCmdLine[] = {L"cli.exe"}; // Буфер должен быть изменяемым !
 
    if(!CreateProcessW(NULL,
        pCmdLine,
        NULL,
        NULL,
        TRUE, // <--- Наследовать хэндлы ? Да.
        NORMAL_PRIORITY_CLASS,
        NULL,
        NULL,
        &si,
        &pi))
    {
        std::cout<<"Error code: "<<GetLastError()<<std::endl;
        return -1;
    };
    CloseHandle(pi.hProcess);// Закр. хэндл записи - нам он не нужен, а у доч. проц. уже есть его копия.
    CloseHandle(pi.hThread);
 
    //ждем пока клиент запишет данные
    WaitForSingleObject(hEv, INFINITE);
 
    cout<<"z'ednano"<<endl;Sleep(500);
    CloseHandle(hWritePipe);
 
    //Захватываем мютекс
    WaitForSingleObject(hMutex, INFINITE);
 
    cout<<"vstanovlennia na chytannia"<<endl;Sleep(500);
    DWORD nBytes;
    int szBuf[4]={0,0,0,0};
 
    ReleaseMutex(hMutex);
    if(!ReadFile(hReadPipe,szBuf,sizeof(szBuf),&nBytes, NULL))
    {
        std::cout<<"Error code: "<<GetLastError()<<std::endl;
        return -1;
    };
    CloseHandle(hReadPipe);
 
 
    cout<<"otrymyemo dani"<<endl;Sleep(500);
    WaitForSingleObject(pi.hProcess, INFINITE);
 
    for (int i=0;i<4;i++)
           {cout<<szBuf[i]<<endl;Sleep(500);}
 
    tab(szBuf[0],szBuf[1],szBuf[2],szBuf[3]);
    cout<<"Protabul'ovano"<<endl;
 
    CloseHandle(hMutex);
    CloseHandle(hEv);
    return EXIT_SUCCESS;
}