22 /* считываем из канала IPC, записываем в stdout */
23 mesg.mesg_type = getpid;
24 while ((n = Mesg_recv(readfd, &mesg)) > 0)
25 Write(STDOUT_FILENO, mesg.mesg_data, n);
26 }
Пример: одна очередь для каждого клиента
Изменим теперь предыдущий пример таким образом, чтобы все запросы клиентов передавались по одной очереди, но для отправки ответов использовалась бы отдельная очередь для каждого клиента. На рис. 6.3 изображена схема такого приложения.
Рис. 6.3. Одна очередь для сервера и по одной для каждого клиента
Ключ очереди сервера должен быть известен клиентам, а сами клиенты создают свои очереди с ключом IPC_PRIVATE. Вместо передачи серверу идентификатора процесса клиенты сообщают ему идентификатор своей очереди, в которую сервер направляет свой ответ. Этот сервер является параллельным: для каждого нового клиента порождается отдельный процесс.
ПРИМЕЧАНИЕ
При такой схеме может возникнуть проблема в случае «гибели» клиента, потому что тогда сообщения останутся в его очереди навсегда (по крайней мере до перезагрузки ядра или явного удаления очереди другим процессом).
Нижеследующие заголовочные файлы и функции не претерпевают изменений по сравнению с предыдущими версиями:
■ mesg.h (листинг 4.12);
■ svmsg.h (листинг 6.7);
■ функция main сервера (листинг 6.12);
■ функция mesg_send (листинг 4.13).
Функция main клиента приведена в листинге 6.16; она слегка изменилась по сравнению с листингом 6.14. Мы открываем очередь сервера с известным ключом (MQ_KEY1) и создаем нашу собственную очередь с ключом IPC_PRIVATE. Два идентификатора этих очередей становятся аргументами функции client (листинг 6.17). После завершения работы клиента его персональная очередь удаляется.
20 /* отправляем идентификатор очереди и имя файла серверу */
21 Mesg_send(writeid, &mesg);
22 /* считываем ответ из нашей очереди и записываем его в stdout */
23 while ((n = Mesg_recv(readid, &mesg)) > 0)
24 Write(STDOUT_FILENO, mesg.mesg_data, n);
25 }
В листинге 6.17 приведен текст функции client. Эта функция практически идентична функции из листинга 6.15, но вместо передачи идентификатора процесса клиента на сервер направляется идентификатор очереди клиента. Тип сообщения в структуре mesg остается равным 1, поскольку это значение устанавливается для сообщений, передаваемых в обе стороны.
В листинге 6.19 приведена функция server. Главное отличие от листинга 6.13 в том, что эта функция представляет собой бесконечный цикл, в котором для каждого нового клиента вызывается fork.