Производительность и оптимизация

// Количество процессов = количество CPU cores
$server->count = cpu_count(); // Автоматическое определение

Блокирующий I/O:         Event-driven I/O:
Process → Socket         Process → Event Loop
    ↓                        ↓
  Wait                   Monitor (non-blocking)
    ↓                        ↓
  Block                  Continue processing
    ↓                        ↓
Handle 1 connection    Handle 1000+ connections

// Чтение оптимальными порциями
READ_BUFFER_SIZE = 87380; // Размер TCP окна

// Управление буфером отправки
if (strlen($sendBuffer) < $maxSendBufferSize) {
    // Продолжаем накопление
} else {
    // Приостанавливаем прием (backpressure)
    pauseRecv();
}

// Для повторяющихся HTTP запросов
static $requests = [];

// LRU кеш с ограничением размера
if (count($requests) > MAX_CACHE_SIZE) {
    unset($requests[key($requests)]); // Удаление самого старого
}

// TCP_NODELAY - отключение алгоритма Nagle
socket_set_option($socket, SOL_TCP, TCP_NODELAY, 1);

// SO_KEEPALIVE - поддержание соединения
socket_set_option($socket, SOL_SOCKET, SO_KEEPALIVE, 1);

// SO_REUSEPORT - распределение нагрузки
socket_set_option($socket, SOL_SOCKET, SO_REUSEPORT, 1);

// Максимальная длина очереди ожидающих соединений
const DEFAULT_BACKLOG = 102400;

1. Попытка прямой отправки:
   if (sendBuffer empty) {
       len = fwrite(socket, data);
       if (len == data.length) {
           return success; // Отправлено полностью
       }
   }

2. Добавление в буфер:
   sendBuffer .= data;

3. Регистрация в Event Loop:
   eventLoop->onWritable(socket, baseWrite);

// Для файлов > 2MB - потоковая передача
if ($fileSize > 2 * 1024 * 1024) {
    // 1. Отправка заголовков
    send($responseHeaders);
    
    // 2. Постепенное чтение и отправка
    while (!feof($file)) {
        $chunk = fread($file, 8192);
        send($chunk, true); // raw mode
    }
}

// Использование ссылок вместо копирования
$package = &$this->recvBuffer; // Ссылка, не копия

// Извлечение только при необходимости
$this->recvBuffer = substr($this->recvBuffer, $length);

// Min-heap для эффективного управления
class TimerQueue {
    private array $heap = [];
    
    public function extract(float $now): ?TimerCallback {
        if (empty($this->heap)) {
            return null;
        }
        
        // O(1) получение минимального элемента
        $timer = $this->heap[0];
        
        if ($timer->getTime() > $now) {
            return null; // Еще не время
        }
        
        // O(log n) удаление корня
        $this->removeRoot();
        
        return $timer;
    }
}

Оптимально: CPU cores × 1-2
Слишком мало: Недостаточное использование CPU
Слишком много: Конкуренция за ресурсы

Оптимально:
- maxSendBufferSize: 1-4 MB
- maxPackageSize: 1-10 MB
- readBufferSize: 64-128 KB

Производительность:
libuv > libev > libevent > stream_select

# Увеличение лимитов файловых дескрипторов
ulimit -n 65535

# Оптимизация TCP
echo 'net.core.somaxconn = 65535' >> /etc/sysctl.conf
echo 'net.ipv4.tcp_tw_reuse = 1' >> /etc/sysctl.conf
echo 'net.ipv4.ip_local_port_range = 1024 65535' >> /etc/sysctl.conf

# Применение
sysctl -p

; Отключение неиспользуемых функций
disable_functions = ""

; Оптимизация памяти
memory_limit = 256M
opcache.enable = 1
opcache.memory_consumption = 128

; Оптимизация сборщика мусора
zend.enable_gc = 1

// Получение статистики
$stats = ConnectionInterface::$statistics;
// [
//     'connection_count' => 1234,
//     'total_request' => 56789,
//     'throw_exception' => 5,
//     'send_fail' => 2
// ]

// Статистика сервера
Server::getAllServers();

// Проблема: Накопление объектов
$connections[] = $connection; // Без удаления

// Решение: Очистка при закрытии
$connection->onClose = function($conn) use (&$connections) {
    unset($connections[$conn->id]);
};

// Проблема
onMessage($conn, $data) {
    $result = file_get_contents('large_file.txt'); // Блокирует!
}

// Решение
onMessage($conn, $data) {
    $file = fopen('large_file.txt', 'r');
    $eventLoop->onReadable($file, function($file) use ($conn) {
        $chunk = fread($file, 8192);
        $conn->send($chunk);
    });
}

// Проблема: Линейный поиск
foreach ($connections as $conn) {
    if ($conn->id === $targetId) {
        // O(n)
    }
}

// Решение: Хэш-таблица
$connection = $connections[$targetId]; // O(1)

                ┌──────────────┐
                │ Load Balancer│
                └──────┬───────┘
                       │
        ┌──────────────┼──────────────┐
        │              │              │
   ┌────▼────┐    ┌────▼────┐    ┌────▼────┐
   │ Server 1│    │ Server 2│    │ Server 3│
   │ (4 CPU) │    │ (4 CPU) │    │ (4 CPU) │
   └─────────┘    └─────────┘    └─────────┘