Модель процессов и жизненный цикл

Server::runAll()
├── checkSapiEnv()        // Проверка окружения
├── initStdOut()          // Инициализация потоков вывода
├── init()                // Настройка событий и обработчиков
├── parseCommand()        // Разбор командной строки
├── checkPortAvailable()  // Проверка доступности портов
├── lock()                // Файловая блокировка
├── daemonize()           // Переход в режим демона (опционально)
├── initServers()         // Инициализация серверов
├── installSignal()       // Установка обработчиков сигналов
├── saveMasterPid()       // Сохранение PID мастера
└── displayUI()           // Отображение интерфейса

1. Первый fork():
   - Родительский процесс завершается (exit 0)
   - Дочерний процесс продолжает работу

2. posix_setsid():
   - Создание новой сессии
   - Отключение от управляющего терминала

3. Второй fork():
   - Предотвращает восстановление связи с терминалом
   - Финальный процесс становится демоном

forkServers()
├── Для каждого сервера:
│   ├── Определение количества worker процессов ($server->count)
│   └── while (count < required):
│       └── forkOneServerForLinux()
│           ├── pcntl_fork()
│           ├── В родителе: сохранение PID
│           └── В дочернем: инициализация worker

// Родительский процесс (Master)
if ($pid > 0) {
    // Сохраняем PID нового worker
    static::$pidMap[$serverId][$pid] = $pid;
    static::$idMap[$serverId][$id] = $pid;
    
    // Продолжаем создавать другие процессы
}

// Дочерний процесс (Worker)
elseif ($pid === 0) {
    // 1. Очистка состояния
    static::$pidsToRestart = static::$pidMap = [];
    
    // 2. Закрытие других серверов (worker обслуживает только один сервер)
    foreach (static::$servers as $key => $oneServer) {
        if ($oneServer->serverId !== $server->serverId) {
            $oneServer->unlisten();
            unset(static::$servers[$key]);
        }
    }
    
    // 3. Инициализация Event Loop
    static::$globalEvent = new EventLoopClass();
    
    // 4. Настройка пользователя процесса
    $server->setUserAndGroup();
    
    // 5. Запуск сервера
    $server->run();
    
    // 6. Запуск Event Loop (блокирующий вызов)
    static::$globalEvent->run();
}

monitorServers()
├── Бесконечный цикл:
│   ├── Проверка статуса worker процессов
│   ├── Обработка сигналов
│   ├── Перезапуск упавших процессов
│   └── Graceful reload (если запрошен)

while (true) {
    // Для каждого worker процесса
    foreach (static::$pidMap as $serverId => $pids) {
        foreach ($pids as $pid) {
            // Проверка существования процесса
            if (!posix_kill($pid, 0)) {
                // Процесс завершен - пересоздаем
                static::forkOneServerForLinux($server);
            }
        }
    }
    
    // Обработка сигналов (через signal handler)
    pcntl_signal_dispatch();
    
    // Пауза перед следующей проверкой
    usleep(10000); // 10ms
}

1. Event Loop обнаруживает событие "readable" на listening socket
2. Вызывается Server::acceptTcpConnection()
3. Создается объект TcpConnection
4. Регистрируется callback для чтения данных
5. Вызывается onConnect callback (если установлен)

1. Event Loop обнаруживает данные на клиентском сокете
2. TcpConnection::baseRead() читает данные в recvBuffer
3. Протокол прикладного уровня проверяет целостность пакета (input)
4. Когда пакет полный, вызывается decode()
5. Декодированные данные передаются в onMessage callback
6. Бизнес-логика обрабатывает запрос
7. Ответ кодируется протоколом (encode)
8. Данные отправляются клиенту через send()

// Кеш запросов (для оптимизации парсинга)
static $requests = [];

// Кеш применяется для:
// 1. Повторяющихся HTTP запросов
// 2. Избежания повторного парсинга идентичных данных
// 3. Оптимизации использования памяти

1. Мастер получает сигнал
2. Отправка SIGTERM всем worker процессам
3. Ожидание завершения (timeout = stopTimeout)
4. Принудительное завершение (SIGKILL) если timeout
5. Очистка ресурсов и выход

1. Мастер получает SIGQUIT
2. Установка флага gracefulStop = true
3. Отправка SIGQUIT всем worker процессам
4. Worker процессы:
   - Прекращают принимать новые соединения
   - Закрывают пустые соединения
   - Ожидают завершения обработки активных запросов
   - Закрывают соединения после обработки
5. По завершении всех соединений - выход

1. Мастер получает SIGUSR1
2. Отправка SIGUSR1 всем worker процессам
3. Worker процесс:
   - Завершает текущую обработку
   - Перезагружает PHP файлы (autoload)
   - Сохраняет активные соединения
   - Продолжает работу с новым кодом

1. Мастер получает SIGUSR2
2. Для каждого worker процесса последовательно:
   a. Создание нового worker с новым кодом
   b. Ожидание завершения старого worker
   c. Переход к следующему worker
3. Все соединения плавно переносятся на новые процессы

$server->user = 'www-data';
$server->group = 'www-data';

// После привязки к порту:
posix_setgid($gid);
posix_initgroups($user, $gid);
posix_setuid($uid);