Создание, подключение и именование каналов и почтовых ящиков
В табл. 11.1 сведены все допустимые формы имен каналов, которые могут использоваться клиентами и серверами приложения. Здесь же перечислены все функции, которые следует использовать для создания именованных каналов и соединения с ними.
Аналогичная информация для почтовых ящиков приведена в табл. 11.2. Вспомните, что почтовый клиент (или сервер) не обязательно должен выполняться тем же процессом или даже на той же системе, что и клиент (или сервер) приложения.
Таблица 11.1. Именованные каналы: создание, подключение и именование
| Клиент приложения | Сервер приложения | |
| Дескриптор именованного канала или соединение | CreateFile CallNamedPipe TransactNamedPipe | CreateNamedPipe |
| Имя канала | \\.\имя канала (канал является локальным) \\имя системы\имя канала (канал является локальным или удаленным) | \\.\имя канала (канал создается локальным) |
Таблица 11.2. Почтовые ящики: создание, подключение и именование
| Почтовый клиент | Почтовый сервер | |
| Дескриптор почтового ящика | CreateFile | CreateMailslot |
| Имя почтового ящика | \\.\имя почтового ящика (почтовый ящик является локальным) \\имя системы\имя почтового ящика (почтовый ящик располагается на указанной удаленной системе) \\*\имя почтового ящика (все почтовые ящики, имеющие одно и то же указанное имя) | \\.\имя почтового ящика (почтовый ящик создается локальным) |
Пример: сервер, обнаруживаемый клиентами
Программа 11.4 представляет функцию потока, которую сервер командной строки (программа 11.3),выступающий в роли почтового клиента, использует для широковещательной рассылки имени своего канала ожидающим клиентам. Возможно существование нескольких серверов с различными характеристиками и именами каналов, и клиенты получают их имена, используя почтовый ящик с известным именем. Эта функция запускается как поток программой 11.3.
Примечание
На практике многие клиент-серверные системы инвертируют используемую здесь логику поиска. Суть альтернативного варианта заключается в том, что клиент приложения действует и как почтовый клиент, осуществляя широковещательную рассылку сообщений, требующих, чтобы сервер ответил с использованием указанного именованного канала (имя канала определяется клиентом и включается в сообщение). Затем сервер приложения, действующий в качестве почтового сервера, считывает запрос и создает соединение с использованием указанного именованного канала.
Программа 11.4. SrvrBcst: функция потока почтового клиента
static DWORD WINAPI ServerBroadcast(LPLONG pNull) {
MS_MESSAGE MsNotify;
DWORD nXfer;
HANDLE hMsFile;
/*Открыть почтовый ящик для записывающей программы почтового "клиента"*/
while (!ShutDown) { /* Цикл выполняется до тех пор, пока имеются серверные потоки. */
/* Ждать, пока другой клиент не откроет почтовый ящик. */
Sleep(CS_TIMEOUT);
hMsFile = CreateFile(MS_CLTNAME, GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN EXISTING, FILE ATTRIBUTE NORMAL, NULL);
if (hMsFile == INVALID_HANDLE_VALUE) continue;
/* Отправить сообщение в почтовый ящик. */
MsNotify.msStatus = 0;
MsNotify.msUtilization = 0;
_tcscpy(MsNotify.msName, SERVER_PIPE);
if (WriteFile(hMsFile, &MsNotify, MSM_SIZE, &nXfer, NULL)) ReportError(_T("Ошибка записи почтового сервера."), 13, TRUE);
CloseHandle(hMsFile);
}
_tprintf(_T("Закрытие контролирующего потока.\n"));
_endthreadex(0);
return 0;
}
В программе 11.5 представлена функция, которая вызывается клиентом (см. программу 11.2) для обнаружения сервера.
Программа 11.5. LocSrvr: почтовый сервер
/* Глава 11. LocSrver.c */
/* Найти сервер путем считывания информации из почтового ящика, используемого для широковещательной рассылки имен серверов. */
#include "EvryThng.h"
#include "ClntSrvr.h" /* Определяет имя почтового ящика. */
BOOL LocateServer(LPTSTR pPipeName) {
HANDLE MsFile;
MS_MESSAGE ServerMsg;
BOOL Found = FALSE;
DWORD cbRead;
MsFile = CreateMailslot(MS_SRVNAME, 0, CS_TIMEOUT, NULL);
while (!Found) {
_tprintf(_T("Поиск сервера.\n"));
Found = ReadFile(MsFile, &ServerMsg, MSM_SIZE, &cbRead, NULL);
}
_tprintf(_T("Сервер найден.\n"));
CloseHandle(MsFile);
/* Имя канала сервера. */
_tcscpy(pPipeName, ServerMsg.msName);
return TRUE;
}