$SIG{CHLD} = \&REAPER;

while (Shisaddr = accept(CLIENT, SERVER)) {

next If Spid = fork; # Родитель

die "fork: S" unless defined Spid; # Неудача # otherwise child

close(SERVER); # He нужно для потомка

й ... Сделать что-то

exit; # Выход из потомка

} continue {

close(CLIENT); # Не нужно для родителя

Комментарий

Подобный подход очень часто используется в потоковых (SOCK STREAM) серверах на базе сокетов Интернета и UNIX. Каждое входящее подключение получает собственный дубликат сервера. Общая модель выглядит так;

1. Принять потоковое подключение.

2. Ответвить дубликат для обмена данными с этим потоком.

3. Вернуться к п. 1.

Такая методика не используется с датафаммными сокетами (SOCK DGRAM) из-за особенностей обмена данными в них. Из-за времени, затраченного на разветвление, эта модель непрактична для UDP-серверов. Вместо продолжительных соединений, обладающих определенным состоянием, серверы SOCK DGRAM работают с непредсказуемым набором датаграмм, обычно без определенного состояния. В этом варианте наща модель принимает следующий вид:

1. Принять датаграмму.

2. Обработать датаграмму.

3. Вернуться к п. 1.

Новое соединение обрабатывается порожденным процессом. Поскольку сокет SERVER никогда не будет использоваться этим процессом, мы немедленно закрываем его. Отчасти это делается из стремления к порядку, но в основном - для того, чтобы серверный сокет закрывался при заверщении родительского (серверного) процесса. Если потомки не будут закрывать сокет SERVER, операционная система будет считать его открытым даже после заверщения родителя. За подробностями обращайтесь к рецепту 17.9.

%SIG обеспечивает чистку таблицы процессов после заверщения потомков (см. главу 16).

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

Описание функций fork и accept вperlfunc{i); рецепты 16.15; 16.19; 17.12-17.13.

17.12. Серверы с предварительным ветвлением 627

17.12. Серверы с предварительным ветвлением

Проблема

Вы хотите написать сервер, параллельно обслуживающий нескольких клиентов (как и в предыдущем разделе), однако подключения поступают так быстро, что ветвление слишком сильно замедлит работу сервера.

Решение

Организуйте пул заранее разветвленных потомков, как показано в примере 17.5. Пример 17.5. preforker

#/usr/bin/perl

# preforker - сервер с предварительным ветвлением use 10::Socket: use Symbol; use POSIX;

# Создать сокет SERVER, вызвать bind и прослушивать порт. Sserver = IO;;Socket INET->new(LocalPort => 6969,

or die making socket $@\n

n Глобальные переменные SPREFORK = 5;

$MAX CLIENTS PER CHILD = 5;

%children = 0;

$children = 0;

sub REAPER {

$SIG{CHLD} = \&REAPER; my $pid = wait; $children --; delete $children{$pid};

Type Proto Reuse Listen

=> SOCK STREAM, => tcp, => 1, => 10 )

# Количество поддерживаемых потомков

# Количество клиентов, обрабатываемых

# каждым потомком.

# Ключами являются текущие

# идентификаторы процессов-потомков

# Текущее число потомков

# Чистка мертвых потомков

sub HUNTSMAN {

local($SIG{CHLD}) = -IGNORE; kill -INT => keys %children, exit;

# Обработчик сигнала SIGINT

# Убиваем своих потомков

# Корректно завершиться

Пример 17.5 (продолжение)

п Создать потомков, for (1 SPREFORK) { make new child();

# Установить обработчики сигналов. $SIG{CHLD} = \&REAPER; $SIG{INT} = \&HUNTSMAN,

# Поддерживать численность процессов while (1) {

sleep; # Ждать сигнала (например,

# смерти потомка), for ($1 = Schildren; $i < $PREFORK, $i++) {

make new child(), # Заполнить пул потомков

sub fflake new child { my $pid; my $sigset;

tt Блокировать сигнал для fork. Ssigset = POSIX::SigSet->new(SIGINT); sigprocmask(SIG BLOCK, Ssigset)

or die "Cant block SIGINT for fork: S!\n;

die fork: S" unless defined (Spid = fork),

if (Spid) {

# Родитель запоминает рождение потомка и возвращается. sigprocmask(SIG UNBLOCK, Ssigset)

or die "Cant unblock SIGINT for fork: S!\n"; $children{Spid} = 1, Schildren++; return; } else {

# Потомок *не может* выйти из этой подпрограммы $SIG{INT} = DEFAULT; # Пусть SIGINT убивает процесс,

tt как это было раньше.

# Разблокировать сигналы sigprocmask(SIG UNBLOCK, Ssigset)

or die "Cant unblock SIGINT for fork: S!\n";

tt Обрабатывать подключения, пока их число не достигнет

# $MAX CLIENTS PER CHILD.

for ($1=0, Si < SMAX CLIENTS PER CHILD; $i++) { Sclient = Sserver->accept() or last, # Сделать что-то с соединением