17.10. Написание двусторонних клиентов 623

Комментарий

При разветвлении (forking) процесса потомок получает копии всех открытых файловых манипуляторов родителя, включая сокеты. Вызывая close для файла или сокета, вы закрываете только копию манипулятора, принадлежащую текущему процессу. Если в другом процессе (родителе или потомке) манипулятор остался открытым, операционная система не будет считать файл или сокет закрытым.

Рассмотрим в качестве примера сокет, в который посылаются данные. Если он открыт в двух процессах, то один из процессов может закрыть его, и операционная система все равно не будет считать сокет закрытым, поскольку он остается открытым в другом процессе. До тех пор пока он не будет закрыт другим процессом, процесс, читающий из сокета, не получит признак конца файла. Это может привести к недоразумениям и взаимным блокировкам.

Чтобы избежать затруднений, либо вызовите close для незакрытых манипуляторов, либо воспользуйтесь функцией shutdown. Функция shutdown является более радикальной формой close - она сообщает операционной системе, что, даже несмотря на наличие копий манипулятора у других процессов, он должен быть помечен как закрытый, а другая сторона должна получить признак конца файла при чтении или SIGPIPE при записи.

Числовой аргумент shutdown позволяет указать, какие стороны соединения закрываются. Значение О говорит, что чтение данных закончено, а другой конец сокета при попытке передачи данных должен получить SIGPIPE. Значение 1 говорит о том, что закончена запись данных, а другой конец сокета при попытке чтения данных должен получать признак конца файла. Значение 2 говорит о за-верщении как чтения, так и записи.

Представьте себе сервер, который читает запрос своего клиента до конца файла и затем отправляет ответ. Если клиент вызовет close, сокет станет недоступным для ввода/вывода, поэтому ответ от сервера не доберется до клиента. Вместо этого клиент должен вызвать shutdown, чтобы закрыть соединение наполовину.

print SERVER my request\n , # Отправить данные shutdown(SERVER, 1), # Отправить признак конца данных,

# запись окончена Sanswer = <SERVER>, # Хотя чтение все еще возможно

> Смотри также-

Описание функций close и shutdown ьperlfunc{\); страница руководства shut-down{2) ващей системы (если есть).

17.10. Написание двусторонних клиентов

Проблема

Вы хотите написать полностью интерактивного клиента, в котором можно ввести строку, получить ответ, ввести другую строку, получить новый ответ и т. д. - словом, нечто похожее на telnet.

Решение

После того как соединение будет установлено, разветвите процесс. Один из близнецов только читает ввод и передает его серверу, а другой - читает выходные данные сервера и копирует их в поток вывода.

Комментарий

в отношениях «клиент/сервер» бывает трудно определить, чья сейчас очередь «говорить». Однозадачные решения, в которых используется версия select с четырьмя аргументами, трудны в написании и сопровождении. Однако нет причин игнорировать многозадачные решения, а функция fork кардинально упрощает эту проблему.

После подключения к серверу, с которым вы будете обмениваться данными, вызовите fork. Каждый из двух идентичных (или почти идентичных) процессов выполняет простую задачу. Родитель копирует все данные, полученные из сокета, в стандартный вывод, а потомок одновременно копирует все данные из стандартного ввода в сокет.

Исходный текст программы приведен в примере 17.4.

Пример 17.4. biclient

#1/usr/bm/perl -w

# biclient - двусторонний клиент с разветвлением

use strict, use 10 Socket,

my (Shost, Sport, Skidpid, Shandle, Sline),

unless (©ARGV == 2) { die usage SO host port } (Shost, Sport) = @ARGV,

# Создать tcp-подключение для заданного хоста и порта Shandle = 10 Socket INET->new(Proto => tcp ,

PeerAddr => Shost PeerPort => Sport) or die can t connect to port Sport on Shost S ,

Shandle->autoflush(1), # Запретить буферизацию

print STDERR [Connected to Shost Sport]\n ,

# Разделить программу на два идентичных процесса

die can t fork S unless defined(Skidpid = fork()),

If (Skidpid) {

n Родитель копирует сокет в стандартный вывод while (defined (Sline = <Shandle>)) { print STDOUT Sline,

kilK TERM => Skidpid), # Послать потомку SIGTERM

17.11. Разветвляющие серверы 625

else {

# Потомок копирует стандартный ввод в сокет while (defined ($line = <STDIN>)) { print Shandle Sline,

exit.

Добиться того же эффекта с одним процессом намного труднее. Проще создать два процесса и поручить каждому простую задачу, нежели кодировать выполнение двух задач в одном процессе. Стоит воспользоваться преимуществами мультизадачности и разделить программу на несколько подзадач, как многие сложнейщие проблемы упрощаются на глазах.

Функция kill в родительском блоке if нужна для того, чтобы послать сигнал потомку (в настоящее время работающему в блоке else), как только удаленный сервер закроет соединение со своего конца. Вызов kill в конце родительского блока ликвидирует порожденный процесс с заверщением работы сервера.

Если удаленный сервер передает данные по байтам и вы хотите получать их немедленно, без ожидания перевода строки (которого вообще может не быть), замените цикл while родительского процесса следующей конструкцией:

ту Sbyte,

while (sysread(Shandle, Sbyte, 1) == 1) { print STDOUT Sbyte,

t> Смотри также-

Описание функций sysread и fork в perlfunc(l); документация по стандартному модулю IO::Socket; рецепты 16.5; 16.10; 17.11.

17.11. Разветвляющие серверы

Проблема

Требуется написать сервер, который для работы с очередным клиентом ответвляет специальный подпроцесс.

Решение

Ответвляйте подпроцессы в цикле accept и используйте обработчик $SIG{CHLD} для чистки потомков.

# Создать сокет SERVER, вызвать bind и прослушивать use POSIX qw( sys wait h),

sub REAPER {

1 until (-1 == waitpid(-1, WNOHANG)),

$SIG{CHLD} = \&REAPER, # если $] >= 5 002