Форум программистов, компьютерный форум, киберфорум
Наши страницы
С++ для начинающих
Войти
Регистрация
Восстановить пароль
 
Рейтинг 4.75/4: Рейтинг темы: голосов - 4, средняя оценка - 4.75
leniament
0 / 0 / 0
Регистрация: 08.11.2012
Сообщений: 28
1

Ответить клиенту через именованный канал результатом выполнения команд сервером, к примеру dir на сервере

21.02.2015, 07:12. Просмотров 814. Ответов 5
Метки нет (Все метки)

Есть сервер и клиент для обмена сообщениями при помощи именованных каналов. Клиент посылает серверу запрос на выполнение одной из команд: DIR, MKDIR, CD. Сервер принимает команду, выполняет ее, а результат отправляет клиенту. Проблема в том что не могу отправить клиенту результат выполнения dir, т.к. он многострочный, да и если при выполнении каких либо других команд, в консоли там вывелось сообщение о "ошибке синтаксиса команды" или к примеру "каталог уже существует" передать и эти сообщения клиенту.
Серверная часть:
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
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
#include <windows.h>
#include <stdio.h>
#include <conio.h>
#include <iostream>
int main()
{
    setlocale(LC_ALL, "RUSSIAN");
    // Флаг успешного создания канала
    BOOL   fConnected;
 
    // Идентификатор канала Pipe
    HANDLE hNamedPipe;
 
    // Имя создаваемого канала Pipe
    LPSTR  lpszPipeName = "\\\\.\\pipe\\$MyPipe$";
 
    // Буфер для передачи данных через канал
    char   szBuf[512];
 
    // Количество байт данных, принятых через канал
    DWORD  cbRead;
 
    // Количество байт данных, переданных через канал
    DWORD  cbWritten;
 
    // Создаем канал Pipe, имеющий имя lpszPipeName
    hNamedPipe = CreateNamedPipe(
        lpszPipeName,
        PIPE_ACCESS_DUPLEX,
        PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
        PIPE_UNLIMITED_INSTANCES,
        512, 512, 5000, NULL);
 
    // Если возникла ошибка, выводим ее код и завершаем
    // работу приложения
    if (hNamedPipe == INVALID_HANDLE_VALUE)
    {
        fprintf(stdout, "CreateNamedPipe: Error %ld\n",
            GetLastError());
        _getch();
        return 0;
    }
 
    // Выводим сообщение о начале процесса создания канала
    fprintf(stdout, "Waiting for connect...\n");
 
    // Ожидаем соединения со стороны клиента
    fConnected = ConnectNamedPipe(hNamedPipe, NULL);
 
    // При возникновении ошибки выводим ее код
    if (!fConnected)
    {
        switch (GetLastError())
        {
        case ERROR_NO_DATA:
            fprintf(stdout, "ConnectNamedPipe: ERROR_NO_DATA");
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        case ERROR_PIPE_CONNECTED:
            fprintf(stdout,
                "ConnectNamedPipe: ERROR_PIPE_CONNECTED");
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        case ERROR_PIPE_LISTENING:
            fprintf(stdout,
                "ConnectNamedPipe: ERROR_PIPE_LISTENING");
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        case ERROR_CALL_NOT_IMPLEMENTED:
            fprintf(stdout,
                "ConnectNamedPipe: ERROR_CALL_NOT_IMPLEMENTED");
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        default:
            fprintf(stdout, "ConnectNamedPipe: Error %ld\n",
                GetLastError());
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        }
 
        CloseHandle(hNamedPipe);
        _getch();
        return 0;
    }
 
    // Выводим сообщение об успешном создании канала
    fprintf(stdout, "\nConnected. Waiting for command...\n");
 
    // Цикл получения команд через канал
    while (1)
    {
        // Получаем очередную команду через канал Pipe
        if (ReadFile(hNamedPipe, szBuf, 512, &cbRead, NULL))
        {
//Выполняем команду
//Здесь чего я только не пробывал, результаты разные. Команды cd, mkdir *** выполняются и передаются, но dir только первую строку результата получилось передать и все.
                        //FILE   *pPipe;
 
            //pPipe = _popen(szBuf, "rt");
                       //_popen(szBuf, "wt");
            //fgets(szBuf, 128, pPipe);
 
            //И еще много всякого наверное бреда
 
            // Посылаем эту команду обратно клиентскому
            // приложению
            //Здесь соответственно тоже было много разных вариаций, зависящих от того что было выше
            if (!WriteFile(hNamedPipe, szBuf, 512,
                &cbWritten, NULL))
                break;
 
            // Выводим принятую команду на консоль 
            printf("Received: <%s>\n", szBuf);
 
            // Если пришла команда "exit", 
            // завершаем работу приложения
            if (!strcmp(szBuf, "exit"))
                break;
        }
        else
        {
            fprintf(stdout, "ReadFile: Error %ld\n",
                GetLastError());
            _getch();
            break;
        }
    }
 
    CloseHandle(hNamedPipe);
    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
#include <windows.h>
#include <stdio.h>
#include <conio.h>
 
DWORD main(int argc, char *argv[])
{
    // Идентификатор канала Pipe
    HANDLE hNamedPipe;
 
    // Количество байт, переданных через канал
    DWORD  cbWritten;
 
    // Количество байт, принятых через канал
    DWORD  cbRead;
 
    // Буфер для передачи данных
    char   szBuf[512];
 
    // Буфер для имени канала Pipe
    char   szPipeName[256];
 
 
    // Если при запуске PIPEC было указано имя срвера,
    // указываем его в имени канала Pipe
    if (argc > 1)
        sprintf(szPipeName, "\\\\%s\\pipe\\$MyPipe$",
        argv[1]);
 
    // Если имя сервера задано не было, создаем канал
    // с локальным процессом
    else
        strcpy(szPipeName, "\\\\.\\pipe\\$MyPipe$");
 
    // Создаем канал с процессом PIPES
    hNamedPipe = CreateFile(
        szPipeName, GENERIC_READ | GENERIC_WRITE,
        0, NULL, OPEN_EXISTING, 0, NULL);
 
    // Если возникла ошибка, выводим ее код и 
    // завершаем работу приложения
    if (hNamedPipe == INVALID_HANDLE_VALUE)
    {
        fprintf(stdout, "CreateFile: Error %ld\n",
            GetLastError());
        _getch();
        return 0;
    }
 
    // Выводим сообщение о создании канала
    fprintf(stdout, "\nConnected. Type 'exit' to terminate\n");
 
    // Цикл обмена данными с серверным процессом
    while (1)
    {
        // Выводим приглашение для ввода команды
        printf("cmd>");
 
        // Вводим текстовую строку
        gets(szBuf);
 
        // Передаем введенную строку серверному процессу
        // в качестве команды
        if (!WriteFile(hNamedPipe, szBuf, strlen(szBuf) + 1,
            &cbWritten, NULL))
            break;
 
 
        // Получаем результат обратно от сервера
        if (ReadFile(hNamedPipe, szBuf, 512, &cbRead, NULL))
            printf("Received back: <%s>\n", szBuf);
 
        // Если произошла ошибка, выводим ее код и
        // завершаем работу приложения
        else
        {
            fprintf(stdout, "ReadFile: Error %ld\n",
                GetLastError());
            _getch();
            break;
        }
 
        // В ответ на команду "exit" завершаем цикл
        // обмена данными с серверным процессом
        if (!strcmp(szBuf, "exit"))
            break;
    }
 
    // Закрываем идентификатор канала
    CloseHandle(hNamedPipe);
    return 0;
}
Спасибо за помощь.
0
Лучшие ответы (1)
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
21.02.2015, 07:12
Ответы с готовыми решениями:

Записать в именованный канал
Выполняю следующую команду в консоли: mkfifo mypipe Затем вторую команду:...

Syslog и запись в именованный канал
Всем доброго времени суток. Захотел я реализовать такую связку squid -&gt; syslog...

Кириллица при отправке сообщения клиенту сервером
Пишу консольный чат сервер... Споткнулся на кодировке... Между собой клиенты...

Создать защищенный канал между клиентом и сервером
Создать систему, использует защищенный канал между клиентом и сервером. ...

Реализовать отправку текста сервером клиенту каждые 5 секунд
Помогите пожалуйста, может у кого есть наброски Необходимо реализовать...

5
nmcf
6274 / 5577 / 2537
Регистрация: 14.04.2014
Сообщений: 23,468
21.02.2015, 07:27 2
А где само выполнение команд? Как ты выполняешь DIR и получаешь его результат в самом сервере?
0
leniament
0 / 0 / 0
Регистрация: 08.11.2012
Сообщений: 28
21.02.2015, 07:40  [ТС] 3
Вот в этом участке. Команды выполняю через _popen().Я закомментил там где я пробовал разные варианты.
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
 // Цикл получения команд через канал
    while (1)
    {
        // Получаем очередную команду через канал Pipe
        if (ReadFile(hNamedPipe, szBuf, 512, &cbRead, NULL))
        {
//Выполняем команду
//Здесь чего я только не пробывал, результаты разные. Команды cd, mkdir *** выполняются и передаются, но dir только первую строку результата получилось передать и все.
                        //FILE   *pPipe;
 
            //pPipe = _popen(szBuf, "rt");
                       //_popen(szBuf, "wt");
            //fgets(szBuf, 128, pPipe);
 
            //И еще много всякого наверное бреда
 
            // Посылаем эту команду обратно клиентскому
            // приложению
            //Здесь соответственно тоже было много разных вариаций, зависящих от того что было выше
            if (!WriteFile(hNamedPipe, szBuf, 512,
                &cbWritten, NULL))
                break;
 
            // Выводим принятую команду на консоль 
            printf("Received: <%s>\n", szBuf);
 
            // Если пришла команда "exit", 
            // завершаем работу приложения
            if (!strcmp(szBuf, "exit"))
                break;
        }
        else
        {
            fprintf(stdout, "ReadFile: Error %ld\n",
                GetLastError());
            _getch();
            break;
        }
    }
0
nmcf
6274 / 5577 / 2537
Регистрация: 14.04.2014
Сообщений: 23,468
21.02.2015, 07:57 4
Ну как вариант, в цикле считываешь все строки и собираешь в один большой буфер, затем передаёшь сначала его размер, затем сам буфер.
C++
1
2
3
4
5
   pPipe = _popen(szBuf, "rt");
   while( !feof( pPipe ) )
   {
      
   }
1
leniament
0 / 0 / 0
Регистрация: 08.11.2012
Сообщений: 28
21.02.2015, 08:39  [ТС] 5
Только сервер висит в ожидании Waiting for command..., а клиенту отвечает одной строкой, а при следующем запросе от клиента, ответ ему от сервера набор символов.

Добавлено через 11 минут
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
// Получаем очередную команду через канал Pipe
        if (ReadFile(hNamedPipe, szBuf, 512, &cbRead, NULL))
        {
            FILE * pPipe;
            pPipe = _popen(szBuf, "rt"); 
            char szBigBuf[100000];
            while (!feof(pPipe))   
            {
                fgets(szBigBuf,100000,pPipe); 
            }
            
            // Посылаем эту команду обратно клиентскому
            // приложению
 
            if (!WriteFile(hNamedPipe, szBigBuf, 100000,
                &cbWritten, NULL))
                break;
0
nmcf
6274 / 5577 / 2537
Регистрация: 14.04.2014
Сообщений: 23,468
21.02.2015, 09:01 6
Лучший ответ Сообщение было отмечено leniament как решение

Решение

Вот так с dir работает. Допили, чтобы ошибки проверялись и прочее.
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
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
#include <windows.h>
#include <stdio.h>
#include <conio.h>
#include <iostream>
int main()
{
    setlocale(LC_ALL, "RUSSIAN");
    // Флаг успешного создания канала
    BOOL   fConnected;
 
    // Идентификатор канала Pipe
    HANDLE hNamedPipe;
 
    // Имя создаваемого канала Pipe
    LPSTR  lpszPipeName = "\\\\.\\pipe\\$MyPipe$";
 
    // Буфер для передачи данных через канал
    char   szBuf[1024], buf[10240];
 
    // Количество байт данных, принятых через канал
    DWORD  cbRead;
 
    // Количество байт данных, переданных через канал
    DWORD  cbWritten;
 
    // Создаем канал Pipe, имеющий имя lpszPipeName
    hNamedPipe = CreateNamedPipe(
        lpszPipeName,
        PIPE_ACCESS_DUPLEX,
        PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
        PIPE_UNLIMITED_INSTANCES,
        512, 512, 5000, NULL);
 
    // Если возникла ошибка, выводим ее код и завершаем
    // работу приложения
    if (hNamedPipe == INVALID_HANDLE_VALUE)
    {
        fprintf(stdout, "CreateNamedPipe: Error %ld\n",
            GetLastError());
        _getch();
        return 0;
    }
 
    // Выводим сообщение о начале процесса создания канала
    fprintf(stdout, "Waiting for connect...\n");
 
    // Ожидаем соединения со стороны клиента
    fConnected = ConnectNamedPipe(hNamedPipe, NULL);
 
    // При возникновении ошибки выводим ее код
    if (!fConnected)
    {
        switch (GetLastError())
        {
        case ERROR_NO_DATA:
            fprintf(stdout, "ConnectNamedPipe: ERROR_NO_DATA");
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        case ERROR_PIPE_CONNECTED:
            fprintf(stdout,
                "ConnectNamedPipe: ERROR_PIPE_CONNECTED");
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        case ERROR_PIPE_LISTENING:
            fprintf(stdout,
                "ConnectNamedPipe: ERROR_PIPE_LISTENING");
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        case ERROR_CALL_NOT_IMPLEMENTED:
            fprintf(stdout,
                "ConnectNamedPipe: ERROR_CALL_NOT_IMPLEMENTED");
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        default:
            fprintf(stdout, "ConnectNamedPipe: Error %ld\n",
                GetLastError());
            _getch();
            CloseHandle(hNamedPipe);
            return 0;
            break;
 
        }
 
        CloseHandle(hNamedPipe);
        _getch();
        return 0;
    }
 
    // Выводим сообщение об успешном создании канала
    fprintf(stdout, "\nConnected. Waiting for command...\n");
 
 
    // Цикл получения команд через канал
    while (1)
    {
        // Получаем очередную команду через канал Pipe
 
        if (ReadFile(hNamedPipe, szBuf, 512, &cbRead, NULL))
        {
            // Выводим принятую команду на консоль 
            printf("Received: <%s>\n", szBuf);
 
            // Если пришла команда "exit", 
            // завершаем работу приложения
            if (!strcmp(szBuf, "exit"))
                break;
 
//Выполняем команду
            FILE   *pPipe = _popen(szBuf, "rt");
 
            buf[0] = '\0';
 
            while( !feof( pPipe ) )
            {
                fgets(szBuf, 1024, pPipe);
                strcat(buf, szBuf);
            }
            fclose(pPipe);
            int sz = strlen(buf) + 1;
 
            // Посылаем эту команду обратно клиентскому
            // приложению
            //Здесь соответственно тоже было много разных вариаций, зависящих от того что было выше
            WriteFile(hNamedPipe, &sz, 4, &cbWritten, NULL);
            if (!WriteFile(hNamedPipe, buf, sz,
                &cbWritten, NULL))
                break;
 
        }
        else
        {
            fprintf(stdout, "ReadFile: Error %ld\n",
                GetLastError());
            _getch();
            break;
        }
    }
 
    CloseHandle(hNamedPipe);
    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
#include <windows.h>
#include <stdio.h>
#include <conio.h>
 
DWORD main(int argc, char *argv[])
{
    // Идентификатор канала Pipe
    HANDLE hNamedPipe;
 
    // Количество байт, переданных через канал
    DWORD  cbWritten;
 
    // Количество байт, принятых через канал
    DWORD  cbRead;
 
    // Буфер для передачи данных
    char   szBuf[512];
 
    // Буфер для имени канала Pipe
    char   szPipeName[256];
 
 
    // Если при запуске PIPEC было указано имя срвера,
    // указываем его в имени канала Pipe
    if (argc > 1)
        sprintf(szPipeName, "\\\\%s\\pipe\\$MyPipe$",
        argv[1]);
 
    // Если имя сервера задано не было, создаем канал
    // с локальным процессом
    else
        strcpy(szPipeName, "\\\\.\\pipe\\$MyPipe$");
 
    // Создаем канал с процессом PIPES
    hNamedPipe = CreateFile(
        szPipeName, GENERIC_READ | GENERIC_WRITE,
        0, NULL, OPEN_EXISTING, 0, NULL);
 
    // Если возникла ошибка, выводим ее код и 
    // завершаем работу приложения
    if (hNamedPipe == INVALID_HANDLE_VALUE)
    {
        fprintf(stdout, "CreateFile: Error %ld\n",
            GetLastError());
        _getch();
        return 0;
    }
 
    // Выводим сообщение о создании канала
    fprintf(stdout, "\nConnected. Type 'exit' to terminate\n");
 
    // Цикл обмена данными с серверным процессом
    while (1)
    {
        // Выводим приглашение для ввода команды
        printf("cmd>");
 
        // Вводим текстовую строку
        gets(szBuf);
 
        // Передаем введенную строку серверному процессу
        // в качестве команды
        if (!WriteFile(hNamedPipe, szBuf, strlen(szBuf) + 1,
            &cbWritten, NULL))
            break;
 
 
        // Получаем результат обратно от сервера
        int sz;
        if (!ReadFile(hNamedPipe, &sz, 4, &cbRead, NULL)) break;
        char *buf = new char[sz];
        if (ReadFile(hNamedPipe, buf, sz, &cbRead, NULL))
        {
            printf("Received back: <%s>\n", buf);
        }
        // Если произошла ошибка, выводим ее код и
        // завершаем работу приложения
        else
        {
            delete[] buf;
            fprintf(stdout, "ReadFile: Error %ld\n",
                GetLastError());
            _getch();
            break;
        }
 
        // В ответ на команду "exit" завершаем цикл
        // обмена данными с серверным процессом
        if (!strcmp(buf, "exit"))
        {
            delete[] buf;
            break;
        }
        delete[] buf;
    }
 
    // Закрываем идентификатор канала
    CloseHandle(hNamedPipe);
    return 0;
}
1
21.02.2015, 09:01
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
21.02.2015, 09:01

Получение кода, который был отдан клиенту сервером
Добрый день. Делаю табличку посещений при помощи php. Реализовал получение...

Нужно обработать некоторые заголовки высылаемые сервером клиенту
написал я 4 объекта-Home interface,Remote interface,Bean Class,PrimaryKey...

Прием сервером от клиента чисел, затем сервер умножает и отправляет результат клиенту
Здравствуйте! Помогите пожалуйста сделать клиент-серверное приложение. Клиент...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
6
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2018, vBulletin Solutions, Inc.
Рейтинг@Mail.ru