Форум программистов, компьютерный форум, киберфорум
Наши страницы

С++ для начинающих

Войти
Регистрация
Восстановить пароль
 
leniament
0 / 0 / 0
Регистрация: 08.11.2012
Сообщений: 28
#1

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

21.02.2015, 07:12. Просмотров 757. Ответов 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
Я подобрал для вас темы с готовыми решениями и ответами на вопрос Ответить клиенту через именованный канал результатом выполнения команд сервером, к примеру dir на сервере (C++):

Записать в именованный канал - Bash
Выполняю следующую команду в консоли: mkfifo mypipe Затем вторую команду: echo 'first' &gt; mypipe ВОТ ТУТ ТО И ПРОИСХОДИТ &quot;СТРАННОЕ&quot;....

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

Создать защищенный канал между клиентом и сервером - Delphi
Создать систему, использует защищенный канал между клиентом и сервером. Система должна уметь: - Проводить двустороннюю идентификацию...

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

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

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

5
nmcf
6099 / 5410 / 1891
Регистрация: 14.04.2014
Сообщений: 22,552
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
6099 / 5410 / 1891
Регистрация: 14.04.2014
Сообщений: 22,552
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
6099 / 5410 / 1891
Регистрация: 14.04.2014
Сообщений: 22,552
21.02.2015, 09:01 #6
Лучший ответ Сообщение было отмечено автором темы, экспертом или модератором как ответ
Вот так с 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
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
21.02.2015, 09:01
Привет! Вот еще темы с ответами:

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

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

Действия над результатом выполнения регулярки - C#
Добрый вечер. Заранее прошу меня извинить если такая тема была. Мой поиск не дал результатов. У меня следующий вопрос: Как над результатом...

Передача клиенту списка всех файлов на сервере - Java Сети
Доброго времени суток! Возможно ли как-то позволить клиенту выбирать место и файл на сервере через сокеты? Клиент должен выбирать сам место...


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

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

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