Системное программирование в среде Windows

/* Выполнить командную строку (на сервере); отобразить ответ. */
/* Клиент создает долговременное соединение с сервером (захватывая */
/* экземпляр канала) и выводит приглашение пользователю для ввода команд.*/

#include "EvryThng.h"
#include "ClntSrvr.h" /* Определяет структуры записей запроса и ответа. */

int _tmain(int argc, LPTSTR argv[]) {
 HANDLE hNamedPipe = INVALID_HANDLE_VALUE;
TCHAR PromptMsg[] = _T("\nВведите команду: ");
 TCHAR QuitMsg[] = _T("$Quit");
 TCHAR ServerPipeName[MAX_PATH];
 REQUEST Request; /* См. файл ClntSrvr.h. */
 RESPONSE Response; /* См. файл ClntSrvr.h. */
 DWORD nRead, nWrite, NpMode = PIPE_READMODE_MESSAGE | PIPE_WAIT;
 LocateServer(ServerPipeName);
 /* Ожидать появления экземпляра именованного канала и "вступить в борьбу" за право его открытия. */
 while (INVALID_HANDLE_VALUE == hNamedPipe) {
 WaitNamedPipe(ServerPipeName, NMPWAIT_WAIT_FOREVER);
 hNamedPipe = CreateFile(ServerPipeName, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
 }
 /* Задать блокирование дескриптора именованного канала; режим сообщений.*/
 SetNamedPipeHandleState(hNamedPipe, &NpMode, NULL, NULL);
 /* Вывести приглашение пользователю для ввода команд. Завершить выполнение по получении команды "$quit." */
 while (ConsolePrompt(PromptMsg, Request.Record, MAX_RQRS_LEN, TRUE) && (_tcscmp(Request.Record, QuitMsg) != 0)) {
 WriteFile(hNamedPipe, &Request, RQ_SIZE, &nWrite, NULL);
 /* Считать каждый ответ и направить его на стандартный вывод.
 Response.Status = 0 означает "конец ответного сообщения." */
 while (ReadFile(hNamedPipe, &Response, RS_SIZE, &nRead, NULL) && (Response.Status == 0)) _tprintf(_T("%s"), Response.Record);
 }
 _tprintf(_T("Получена команда завершения работы. Соединение разрывается."));
 CloseHandle(hNamedPipe);
 return 0;
}

Программа 11.3 — это серверная программа, включающая функцию потока сервера, которая обрабатывает запросы, генерируемые с помощью программы 11.2. Кроме того, сервер создает "широковещательный серверный поток" ("server broadcast thread") (см. программу 11.4), который используется для широковещательной рассылки имени своего канала всем клиентам, желающим подключиться, посредством почтового ящика. В программе 11.2 вызывается функция LocateServer, представленная в программе 11.5, которая считывает информацию, отправленную данным процессом. Почтовые ящики описываются далее в настоящей главе.

Хотя соответствующий код и не включен в программу 11.4, в ней предусмотрена возможность защиты сервером (представлен на Web-сайте) своего именованного канала с целью предотвращения доступа к нему клиентов, не имеющих должных полномочий. Вопросы безопасности объектов рассматриваются в главе 15, где будет также показано, как использовать указанную возможность.

Программа 11.3. serverNP: многопоточный сервер именованного канала 

/* Глава 11. ServerNP. */
/* Многопоточный сервер командной строки. Версия на основе именованных каналов. */

#include "EvryThng.h"
#include "ClntSrvr.h" /* Определения сообщений запроса и ответа. */

typedef struct { /* Аргумент серверного потока. */
 HANDLE hNamedPipe; /* Экземпляр именованного канала. */
 DWORD ThreadNo;
 TCHAR TmpFileName[MAX_PATH]; /* Имя временного файла. */
} THREAD_ARG;

typedef THREAD_ARG *LPTHREAD_ARG;
volatile static BOOL ShutDown = FALSE;
static DWORD WINAPI Server(LPTHREAD_ARG);
static DWORD WINAPI Connect(LPTHREAD_ARG);
static DWORD WINAPI ServerBroadcast(LPLONG);
static BOOL WINAPI Handler(DWORD);
static TCHAR ShutRqst[] = _T("$ShutDownServer");

_tmain(int argc, LPTSTR argv[]) {
 /* Определение MAX_CLIENTS содержится в файле ClntSrvr.h. */
 HANDLE hNp, hMonitor, hSrvrThread[MAXCLIENTS];
 DWORD iNp, MonitorId, ThreadId;
 LPSECURITY_ATTRIBUTES pNPSA = NULL;
 THREAD_ARG ThArgs[MAXCLIENTS];
 /* Обработчик управляющих сигналов консоли, используемый для остановки сервера. */
 SetConsoleCtrlHandler(Handler, TRUE);
 /* Периодически создавать имя широковещательного канала потока. */
 hMonitor = (HANDLE)_beginthreadex(NULL, 0, ServerBroadcast, NULL, 0, &MonitorId);
 /* Создать экземпляр канала и временный файл для каждого серверного потока. */
 for (iNp = 0; iNp < MAX_CLIENTS; iNp++) {
 hNp = CreateNamedPipe(SERVER_PIPE, PIPE_ACCESS_DUPLEX, PIPE_READMODE_MESSAGE | PIPE_TYPE_MESSAGE | PIPE_WAIT, MAXCLIENTS, 0, 0, INFINITE, pNPSA);
 ThArgs[iNp].hNamedPipe = hNp;
 ThArgs[iNp].ThreadNo = iNp;
 GetTempFileName(_T("."), _T("CLP"), 0, ThArgs[iNp].TmpFileName);
 hSrvrThread[iNp] = (HANDLE)_beginthreadex(NULL, 0, Server, &ThArgs[iNp], 0, &ThreadId);
 }
 /* Ждать завершения выполнения всех потоков. */
 WaitForMultipleObjects(MAXCLIENTS, hSrvrThread, TRUE, INFINITE);
 WaitForSingleObject(hMonitor, INFINITE);
 CloseHandle(hMonitor);
 for (iNp = 0; iNp < MAXCLIENTS; iNp++) {