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

@Yoshi21 · Регистрация: 25.11.2012

Студворк — интернет-сервис помощи студентам

Всем доброго времени суток. Нужна помощь:
Имеется Сервер и Клиент связанные анонимным каналом. Через анонимный канал нужно передать 4 значения, которые в дальнейшем на сервере протабулируются. Вот пытался это организовать не получилось. Помогите разобраться. Заранее спасибо.

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
//клиент
#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;
}

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
//сервер
#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;
}

Убежденный · 15.05.2013, 11:11

Попробуйте свести код к минимальному примеру: создание дочернего процесса с
подменой стандартного вывода в пайп, чтение из пайпа и отображение результата.
Так будет понятно, в каком месте ошибка.

Канонический пример:
Creating a Child Process with Redirected Input and Output

На что стоит обратить внимание:

C++
1
2
3
4
5
6
7
//событие для информирования о доступности чтения
HANDLE hEv = CreateEventA(0, TRUE, FALSE, "READEVENT");
 
...
 
//ждем пока клиент запишет данные
WaitForSingleObject(hEv, INFINITE);

Использовать события для ожидания готовности дочернего процесса - ненадежно.
Если дочерний процесс неожиданно завершится, например, в результате ошибки
или пользователем через диспетчер задач, то выход из функции ожидания
никогда не произойдет.

C++
1
std::cout<<"Error code: "<<GetLastError()<<std::endl;

Нет никакой гарантии того, что GetLastError будет вызвана до вывода "Error code", и
нет гарантии, что вывод "Error code:" не изменит last error.
Правильно так:

C++
1
2
DWORD const LastError = GetLastError();
std::cout << "Error code: " << LastError << std::endl;

C++
1
2
3
4
5
6
7
8
9
STARTUPINFOA si = {sizeof(si)};
 
//передаем хэндлы в процесс-клиент
si.hStdOutput = hWrite;
si.hStdInput = hRead;
si.hStdError = hWrite;
 
//говорим о необходимости переопределения стандартных дескрипторов
si.dwFlags = STARTF_USESTDHANDLES;

Во-первых, не указано значения поля "cb" (длина структуры si).
Во-вторых, структуру STARTUPINFO лучше не заполнять вручную, а наследовать параметры,
заданные для текущего процесса, после чего подкорректировать ее содержимое в
соответствии со своими замыслами. См. функцию GetStartupInfo.
В-третьих, если вы подменяете хэндлы стандартных потоков, то должны использовать
разные устройства (пайпы), а не одно и то же. Как минимум, должно быть два пайпа -
один для hStdInput и второй для hStdOutput/hStdError.

C++
1
2
//запускаем процесс-клиент
if(!CreateProcessA(NULL, "CLIENT.exe", NULL, NULL, TRUE, 0, NULL, NULL, &si, &pi ))

В данном конкретном случае этот код корректный.
Но Unicode-версии функций CreateProcessXXXX могут изменять буфер с командной строкой,
об этом явно сказано в документации. А строковые литералы в C/C++ константны.
Поэтому надежнее так:

C++
1
2
3
4
// Массив допускает перезапись, в отличие от строковых литералов.
char pCmdLine[] = {"CLIENT.exe"};
 
if(!CreateProcessA(NULL, &pCmdLine[0], NULL, NULL, TRUE, 0, NULL, NULL, &si, &pi ))

@Yoshi21 · 15.05.2013, 15:26 **[ТС]**

Спасибо за советы и помощь буду разбираться, есть ещё 1 вопрос: как правильно передать на сервер интовский массив чисел?
Вот получается на клиенте массив

C++
1
int szBuf[4];

Вычесляю значения и передаю на сервер

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
    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);

Вот читаю на сервере данные из канала

C++
1
2
3
4
5
6
7
8
    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");
    }

(в консоль вывело 4 значения )Но получается я просто прочитал строку, мне же нужно дальше работать на сервере с этими 4 значениями. Объясните пожалуйста как передать этот szBuf[4].Спасибо.

Убежденный · 15.05.2013, 16:49

Здесь получается, что клиент передает числовые данные, преобразуя их в символьную строку.
Значит, сервер должен выполнить обратную операцию - преобразовать строку в числа.
Но еще лучше сразу передавать числа, только не через std::cout, а напрямую в пайп, с
помощью WriteFile.

@Yoshi21 · 15.05.2013, 19:34 **[ТС]**

Сообщение от Убежденный

Но еще лучше сразу передавать числа, только не через std::cout, а напрямую в пайп, с
помощью WriteFile.

Последовав Вашему совету попробовал это организовать с помощью WriteFile. Но увы теперь оно вообще не передает.

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
//клиент
#include <iostream>
#include <conio.h>
#include <windows.h>
 
using namespace std;
 
int main()
{
    int szBuf[4];
    srand(GetCurrentProcessId());
 
    HANDLE hWritePipe;
 
    //"открываем" событие, созданное сервером
    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;
 
    // преобразуем символьное представление дескриптора в число
    hWritePipe = (HANDLE)atoi;
    DWORD dwBytesWritten;
    if(!WriteFile(
                hWritePipe,
                &szBuf,
                sizeof(szBuf),
                &dwBytesWritten,
                NULL)){
    std::cout<<"Error code: "<<GetLastError()<<std::endl;}
 
    CloseHandle(hWritePipe);
 
    SetEvent(hEv);
 
    CloseHandle(hEv);
 
    return 0;
}

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
//сервер
#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()
{
    int szBuf[4];
    
    SECURITY_ATTRIBUTES sa = {sizeof(sa)};
    sa.bInheritHandle = TRUE; 
    sa.lpSecurityDescriptor = NULL;
    
    HANDLE hReadPipe, hWritePipe;
    
    //создаем анонимный канал
    if(!CreatePipe(&hReadPipe, &hWritePipe, NULL, 0))
    {
        std::cout<<"Error code: "<<GetLastError()<<std::endl;
        return -1;
    }
    
    CloseHandle(hWritePipe);
    
    HANDLE hEv = CreateEventA(0, TRUE, FALSE, "READEVENT");//событие для информирования о доступности чтения
    
    STARTUPINFOA si = {sizeof(si)};
    
    
    si.dwFlags = STARTF_USESTDHANDLES;//говорим о необходимости переопределения стандартных дескрипторов
    
    PROCESS_INFORMATION pi = {0};
    
    //запускаем процесс-клиент
    if(!CreateProcessA(NULL, "CLIENT.exe", NULL, NULL, TRUE, CREATE_NEW_CONSOLE, NULL, NULL, &si, &pi ))
    {
        std::cout<<"Error code: "<<GetLastError()<<std::endl;
        return -1;
    }
    
    CloseHandle(pi.hProcess);
    CloseHandle(pi.hThread);
    
    WaitForSingleObject(hEv, INFINITE);
    
    int nData=0;
    DWORD dwBytesRead;
    ReadFile(
                hReadPipe,
                &nData,
                sizeof(nData),
                &dwBytesRead,
                NULL);
    
    tab(szBuf[0],szBuf[1],szBuf[2],szBuf[3]);
    
    CloseHandle(hEv);
    CloseHandle(hReadPipe);
    
    return 0;
}

Убежденный · 15.05.2013, 19:58

C++
1
2
// преобразуем символьное представление дескриптора в число
hWritePipe = (HANDLE)atoi;

А это вообще компилируется ?

C++
1
2
3
4
5
6
7
8
//создаем анонимный канал
if(!CreatePipe(&hReadPipe, &hWritePipe, NULL, 0))
{
    std::cout<<"Error code: "<<GetLastError()<<std::endl;
    return -1;
}
    
CloseHandle(hWritePipe);

Хэндл закрывается преждевременно, дочерний процесс не успевает его унаследовать.
Эту функцию нужно вызывать уже после создания процесса.

C++
1
2
STARTUPINFOA si = {sizeof(si)};
si.dwFlags = STARTF_USESTDHANDLES;//говорим о необходимости переопределения стандартных дескрипторов

А сами дескрипторы где ?

C++
1
2
3
4
5
6
//запускаем процесс-клиент
if(!CreateProcessA(NULL, "CLIENT.exe", NULL, NULL, TRUE, CREATE_NEW_CONSOLE, NULL, NULL, &si, &pi ))
{
    std::cout<<"Error code: "<<GetLastError()<<std::endl;
    return -1;
}

Флаг CREATE_NEW_CONSOLE здесь лишний.

@Yoshi21 · 15.05.2013, 21:05 **[ТС]**

Сообщение от Убежденный

C++
1
2
// преобразуем символьное представление дескриптора в число
hWritePipe = (HANDLE)atoi;

А это вообще компилируется ?

C++
1
2
3
4
5
6
7
8
//создаем анонимный канал
if(!CreatePipe(&hReadPipe, &hWritePipe, NULL, 0))
{
    std::cout<<"Error code: "<<GetLastError()<<std::endl;
    return -1;
}
    
CloseHandle(hWritePipe);

Хэндл закрывается преждевременно, дочерний процесс не успевает его унаследовать.
Эту функцию нужно вызывать уже после создания процесса.

C++
1
2
STARTUPINFOA si = {sizeof(si)};
si.dwFlags = STARTF_USESTDHANDLES;//говорим о необходимости переопределения стандартных дескрипторов

А сами дескрипторы где ?

C++
1
2
3
4
5
6
//запускаем процесс-клиент
if(!CreateProcessA(NULL, "CLIENT.exe", NULL, NULL, TRUE, CREATE_NEW_CONSOLE, NULL, NULL, &si, &pi ))
{
    std::cout<<"Error code: "<<GetLastError()<<std::endl;
    return -1;
}

Флаг CREATE_NEW_CONSOLE здесь лишний.

Компилируется (использовал пример с "Системное програмирование в Windows" А.Побегайло), более того создается анонимный канал, даже запускается клиент но увы не отсылает данные.

C++
1
 std::cout<<"Error code: "<<GetLastError()<<std::endl;

Гетластерор указывает на код ошибки 6. Погуглив понял что что-то с хендлами не знаю правда что именно

Добавлено через 11 минут
А нет, выскакивает пустое окошко и всё =/

Добавлено через 30 минут
Убежденный,

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
//сервер
#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()
{
    int szBuf[4];
 
    SECURITY_ATTRIBUTES sa = {sizeof(sa)};
    sa.bInheritHandle = TRUE; //хэндлы наследуемые
    sa.lpSecurityDescriptor = NULL;
 
    HANDLE hReadPipe, hWritePipe;
 
    //создаем анонимный канал
    if(!CreatePipe(&hReadPipe, &hWritePipe, NULL, 0))
    {
        std::cout<<"Error code: "<<GetLastError()<<std::endl;
        return -1;
    }
        CloseHandle(hWritePipe);
    HANDLE hEv = CreateEventA(0, TRUE, FALSE, "READEVENT");//событие для информирования о доступности чтения
 
    STARTUPINFOA si = {sizeof(si)};
 
 
    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;
        return -1;
    }
 
    CloseHandle(pi.hProcess);
    CloseHandle(pi.hThread);
 
    WaitForSingleObject(hEv, INFINITE);
 
    //int nData=0;
    DWORD dwBytesRead;
    ReadFile(
                hReadPipe,
                &szBuf,
                sizeof(szBuf),
                &dwBytesRead,
                NULL);
    cout<<"Peredalo"<<endl;
 
    for (int i=0;i<4;i++)
           std::cout<<szBuf[i]<<endl;
 
    tab(szBuf[0],szBuf[1],szBuf[2],szBuf[3]);
 
    CloseHandle(hEv);
    CloseHandle(hReadPipe);
 
    return 0;
}

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
//клиент
#include <iostream>
#include <conio.h>
#include <windows.h>
 
using namespace std;
 
int main()
{
    int szBuf[4];
    srand(GetCurrentProcessId());
 
    HANDLE hWritePipe;
 
    //"открываем" событие, созданное сервером
    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;
 
    // преобразуем символьное представление дескриптора в число
    //hWritePipe = (HANDLE)atoi;
    DWORD dwBytesWritten;
    if(!WriteFile(
                hWritePipe,
                &szBuf,
                sizeof(szBuf),
                &dwBytesWritten,
                NULL)){
    std::cout<<"Error code: "<<GetLastError()<<std::endl;}
 
    CloseHandle(hWritePipe);
 
    SetEvent(hEv);
 
    CloseHandle(hEv);
 
    return 0;
}

Скомпилило, вывело массив - четыре 0, соответственно прихожу к мислы, что не передало.

Hикаких ошибок не выдало.

Убежденный · 15.05.2013, 21:25

Клиент у Вас работает с неинициализированным хэндлом hWritePipe:

C++
1
2
3
4
5
6
7
8
9
10
HANDLE hWritePipe;
 
// ...
 
if(!WriteFile(
    hWritePipe,
    &szBuf,
    sizeof(szBuf),
    &dwBytesWritten,
    NULL))

Нужно или вызвать GetStartupInfo и брать оттуда hStdOutput, либо
вызывать GetStdHandle(STD_OUTPUT_HANDLE) и использовать полученный
хэндл для записи данных в клиенте.

@Yoshi21 · 15.05.2013, 22:13 **[ТС]**

Сообщение от Убежденный

Клиент у Вас работает с неинициализированным хэндлом hWritePipe:

C++
1
2
3
4
5
6
7
8
9
10
HANDLE hWritePipe;
 
// ...
 
if(!WriteFile(
    hWritePipe,
    &szBuf,
    sizeof(szBuf),
    &dwBytesWritten,
    NULL))

Нужно или вызвать GetStartupInfo и брать оттуда hStdOutput, либо
вызывать GetStdHandle(STD_OUTPUT_HANDLE) и использовать полученный
хэндл для записи данных в клиенте.

На сколько я понял это делается вот так?

C++
1
2
3
//сервер
  STARTUPINFOA si = {sizeof(si)};
  si.hStdOutput=hWritePipe;

Убежденный · 15.05.2013, 22:48

Наоборот.
Клиент ничего не должен писать в STARTUPINFO, он должен получить
хэндл стандартного вывода (который был подменен серверным процессом на пайп).
Делается это либо вызовом GetStdHandle(STD_OUTPUT_HANDLE), либо с помощью
GetStartupInfo - нужный хэндл будет лежать в STARTUPINFO.hStdOutput.

@Yoshi21 · 15.05.2013, 22:54 **[ТС]**

Убежденный, я запутался. Если Вам не трудно, можете написать пару строк кода как это должно выглядеть?

Убежденный · 15.05.2013, 23:33

Мне не трудно, но Вы уверены, что в этом есть смысл ?
Может, стоит попробовать более простые примеры ?

@Yoshi21 · 15.05.2013, 23:41 **[ТС]**

Убежденный, тогда помогите пожалуйста.

Убежденный · 16.05.2013, 00:37

Пример использования пайпа для перенаправления стандартного вывода.
Обработка ошибок опущена для наглядности.

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
//---------------------
//
//    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);
 
    // Заполняем структуру STARTUPINFO для будущего процесса.
    // Подменяем хэндл стандартного вывода на хэндл записи в пайп.
 
    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-переменную из буфера и выводим ее на экран.
 
    int const Value = *((int const *)pBuffer);
 
    cout << "Value = " << Value << endl;
 
    // Очистка ресурсов и выход.
 
    delete [] pBuffer;
 
    return EXIT_SUCCESS;
}

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
//---------------------
//
//    C L I E N T
//
//---------------------
 
 
 
#include <iostream>
#include <Windows.h>
 
 
 
int main()
{
    using namespace std;
 
    // Получаем хэндл стандартного вывода.
    // Обычно здесь хэндл консоли, но сейчас серверный
    // процесс подменил его на хэндл пайпа.
    //
    // Альтернатива:
    //
    // STARTUPINFO si;
    // GetStartupInfoW(&si);
    // HANDLE const hStdOutput = si.hStdOutput;
 
    HANDLE const hStdOutput = GetStdHandle(STD_OUTPUT_HANDLE);
 
    // Записываем в устройство переменную типа int.
 
    int const Value = 123;
 
    DWORD nBytes;
    WriteFile(hStdOutput, &Value, sizeof (Value), &nBytes, NULL);
 
    return EXIT_SUCCESS;
}

Вывод:

> Value = 123

@Yoshi21 · 16.05.2013, 15:49 **[ТС]**

Убежденный, огромное спасибо за ваш пример! Чуть-чуть его модифицируя я сумел передать массив. Собственно вот:

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
//---------------------
//
//    C L I E N T
//
//---------------------
 
#include <iostream>
#include <Windows.h>
 
int main()
{
    using namespace std;
    srand(GetCurrentProcessId());
 
    // Получаем хэндл стандартного вывода.
    // Обычно здесь хэндл консоли, но сейчас серверный
    // процесс подменил его на хэндл пайпа.
    //
    // Альтернатива:
    //
    // STARTUPINFO si;
    // GetStartupInfoW(&si);
    // HANDLE const hStdOutput = si.hStdOutput;
 
 
    HANDLE const hStdOutput = GetStdHandle(STD_OUTPUT_HANDLE);
 
    // Записываем в устройство переменную типа 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;
}

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
//---------------------
//
//    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;
 
    CreatePipe(&hReadPipe, &hWritePipe, &sa, 0);
 
    // Заполняем структуру STARTUPINFO для будущего процесса.
    // Подменяем хэндл стандартного вывода на хэндл записи в пайп.
 
    STARTUPINFOW si;
    GetStartupInfoW(&si);
 
    si.dwFlags |= STARTF_USESTDHANDLES;
    si.hStdOutput = hWritePipe;
 
    // Запускаем дочерний процесс.
 
    PROCESS_INFORMATION pi;
 
    wchar_t pCmdLine[] = {L"cli.exe"}; // Буфер должен быть изменяемым !
 
    CreateProcessW(NULL,
        pCmdLine,
        NULL,
        NULL,
        TRUE, // <--- Наследовать хэндлы ? Да.
        NORMAL_PRIORITY_CLASS,
        NULL,
        NULL,
        &si,
        &pi);
 
    CloseHandle(pi.hProcess);
    CloseHandle(pi.hThread);
 
    // Закрываем хэндл записи - нам он не нужен, а у
    // дочернего процесса уже есть его копия.
 
    CloseHandle(hWritePipe);
 
    // Выделяем буфер достаточного размера, чтобы принять все данные.
 
 
    // Читаем из пайпа, пока на том конце не завершат запись или
    // пока буфер не будет заполнен.
 
    DWORD nBytes;
    int szBuf[4]={0,0,0,0};
    int i=0;
 
    ReadFile(hReadPipe,szBuf,sizeof(szBuf),&nBytes, NULL);
    CloseHandle(hReadPipe);
 
    // Получаем int-переменную из буфера и выводим ее на экран.
   
    for (int i=0;i<4;i++)
           cout<<szBuf[i]<<endl;
 
    tab(szBuf[0],szBuf[1],szBuf[2],szBuf[3]);
    // Очистка ресурсов и выход.
 
    return EXIT_SUCCESS;
}

Меня заинтересовало, а как их синхронизировать при помощи мьютексов?

Убежденный · 16.05.2013, 16:00

Сообщение от Yoshi21

Меня заинтересовало, а как их синхронизировать при помощи мьютексов?

А зачем их синхронизировать ? Разве они конкурируют за общий ресурс ?

@Yoshi21 · 16.05.2013, 16:03 **[ТС]**

Убежденный, пока нет, но в дальнейшем будут

Убежденный · 16.05.2013, 16:20

Там совершенно ничего сложного.
Один поток захватил мьютекс, второй ждет. Первый закончил
работу, вызвал release, второй приступил к делу. И т.д.
Здесь все написано: Mutex Objects

@Yoshi21 · 16.05.2013, 16:41 **[ТС]**

Убежденный, вроде организовал. Пользовался все той же "Системное программирование в Windows" А.Побегайло

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
//---------------------
//    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);
 
    // Записываем в устройство переменную типа 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++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
//---------------------
//    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");
 
    CreatePipe(&hReadPipe, &hWritePipe, &sa, 0);
 
    // Заполняем структуру STARTUPINFO для будущего процесса.
    // Подменяем хэндл стандартного вывода на хэндл записи в пайп.
 
    STARTUPINFOW si;
    GetStartupInfoW(&si);
 
    si.dwFlags |= STARTF_USESTDHANDLES;
    si.hStdOutput = hWritePipe;
 
    // Запускаем дочерний процесс.
 
    PROCESS_INFORMATION pi;
 
    wchar_t pCmdLine[] = {L"cli.exe"}; // Буфер должен быть изменяемым !
 
    CreateProcessW(NULL,
        pCmdLine,
        NULL,
        NULL,
        TRUE, // <--- Наследовать хэндлы ? Да.
        NORMAL_PRIORITY_CLASS,
        NULL,
        NULL,
        &si,
        &pi);
 
    CloseHandle(pi.hProcess);// Закр. хэндл записи - нам он не нужен, а у доч. проц. уже есть его копия.
    CloseHandle(pi.hThread);
 
    CloseHandle(hWritePipe);
 
    WaitForSingleObject(hMutex, INFINITE);
 
    // Читаем из пайпа, пока на том конце не завершат запись или
    // пока буфер не будет заполнен.
 
    DWORD nBytes;
    int szBuf[4]={0,0,0,0};
    int i=0;
 
    ReadFile(hReadPipe,szBuf,sizeof(szBuf),&nBytes, NULL);
    CloseHandle(hReadPipe);
 
    ReleaseMutex(hMutex);
    CloseHandle(hMutex);
 
    WaitForSingleObject(pi.hProcess, INFINITE);
 
    for (int i=0;i<4;i++)
           cout<<szBuf[i]<<endl;
 
    tab(szBuf[0],szBuf[1],szBuf[2],szBuf[3]);
 
    return EXIT_SUCCESS;
}

Убежденный · 16.05.2013, 16:44

1) Что-то я не вижу, где здесь захватывается мьютекс.
2) В данном коде мьютекс не нужен. Нечего охранять.

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами 8Observer8 20.02.2026 Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .	Конвертировать закладки radiotray-ng в m3u-плейлист damix 19.02.2026 Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .	Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI Eddy_Em 18.02.2026 Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .	Камера Toupcam IUA500KMA Eddy_Em 12.02.2026 Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу zbw 12.02.2026 И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.	«Знание-Сила» zbw 12.02.2026 «Знание-Сила» «Время-Деньги» «Деньги -Пуля»	SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров 8Observer8 12.02.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .	SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 11.02.2026 Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .

Убежденный Ушел с форума 16481 / 7444 / 1187 Регистрация: 02.05.2013 Сообщений: 11,616 Записей в блоге: 1
	15.05.2013, 16:49
	Здесь получается, что клиент передает числовые данные, преобразуя их в символьную строку. Значит, сервер должен выполнить обратную операцию - преобразовать строку в числа. Но еще лучше сразу передавать числа, только не через std::cout, а напрямую в пайп, с помощью WriteFile. 1

Убежденный Ушел с форума 16481 / 7444 / 1187 Регистрация: 02.05.2013 Сообщений: 11,616 Записей в блоге: 1
	15.05.2013, 22:48
	Наоборот. Клиент ничего не должен писать в STARTUPINFO, он должен получить хэндл стандартного вывода (который был подменен серверным процессом на пайп). Делается это либо вызовом GetStdHandle(STD_OUTPUT_HANDLE), либо с помощью GetStartupInfo - нужный хэндл будет лежать в STARTUPINFO.hStdOutput. 0

@Yoshi21 0 / 0 / 0 Регистрация: 25.11.2012 Сообщений: 30
	15.05.2013, 22:54 [ТС]
	Убежденный, я запутался. Если Вам не трудно, можете написать пару строк кода как это должно выглядеть? 0

Убежденный Ушел с форума 16481 / 7444 / 1187 Регистрация: 02.05.2013 Сообщений: 11,616 Записей в блоге: 1
	15.05.2013, 23:33
	Мне не трудно, но Вы уверены, что в этом есть смысл ? Может, стоит попробовать более простые примеры ? 0

@Yoshi21 0 / 0 / 0 Регистрация: 25.11.2012 Сообщений: 30
	15.05.2013, 23:41 [ТС]
	Убежденный, тогда помогите пожалуйста. 0

@Yoshi21 0 / 0 / 0 Регистрация: 25.11.2012 Сообщений: 30
	16.05.2013, 16:03 [ТС]
	Убежденный, пока нет, но в дальнейшем будут 0

Убежденный Ушел с форума 16481 / 7444 / 1187 Регистрация: 02.05.2013 Сообщений: 11,616 Записей в блоге: 1
	16.05.2013, 16:20
	Там совершенно ничего сложного. Один поток захватил мьютекс, второй ждет. Первый закончил работу, вызвал release, второй приступил к делу. И т.д. Здесь все написано: Mutex Objects 0

Убежденный Ушел с форума 16481 / 7444 / 1187 Регистрация: 02.05.2013 Сообщений: 11,616 Записей в блоге: 1
	16.05.2013, 16:44
	1) Что-то я не вижу, где здесь захватывается мьютекс. 2) В данном коде мьютекс не нужен. Нечего охранять. 0