Swoole\Server

<?php
// Voraussetzung: Swoole-Erweiterung installiert (pecl install swoole)

$server = new Swoole\Server('0.0.0.0', 9501, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);

// Serverkonfiguration
$server->set([
    'worker_num'    => 4,      // 4 Worker-Prozesse
    'max_conn'      => 1000,   // Maximale gleichzeitige Verbindungen
    'heartbeat_check_interval' => 60,
    'heartbeat_idle_time'      => 120,
]);

// Callback: Neue Verbindung
$server->on('Connect', function (Swoole\Server $server, int $fd, int $reactorId) {
    echo "[Connect] Client #{$fd} verbunden (Reactor: {$reactorId})\n";
});

// Callback: Daten empfangen — Echo zurück senden
$server->on('Receive', function (Swoole\Server $server, int $fd, int $reactorId, string $data) {
    echo "[Receive] Von Client #{$fd}: " . trim($data) . "\n";
    $server->send($fd, 'Echo: ' . $data);
});

// Callback: Verbindung getrennt
$server->on('Close', function (Swoole\Server $server, int $fd) {
    echo "[Close] Client #{$fd} getrennt\n";
});

// Server starten (blockiert ab hier)
$server->start();

<?php
// Task-Worker ermöglichen blockierende Aufgaben (z. B. DB-Abfragen)
// ohne den Event-Loop zu blockieren

$server = new Swoole\Server('127.0.0.1', 9502);

$server->set([
    'worker_num' => 2,
    'task_worker_num' => 4,  // Separate Task-Worker-Prozesse
]);

$server->on('Receive', function (Swoole\Server $server, int $fd, int $rid, string $data) {
    // Aufgabe an Task-Worker delegieren
    $taskId = $server->task([
        'fd'   => $fd,
        'data' => trim($data),
    ]);
    echo "Task #{$taskId} gestartet für Client #{$fd}\n";
});

// Task-Worker: Blockierende Verarbeitung (z. B. sleep als DB-Simulation)
$server->on('Task', function (Swoole\Server $server, int $taskId, int $workerId, mixed $data) {
    // Simulierte blockierende Arbeit
    $result = strtoupper($data['data']);
    sleep(1); // z. B. Datenbankabfrage
    $server->finish(['fd' => $data['fd'], 'result' => $result]);
});

// Ergebnis des Task-Workers an Client zurücksenden
$server->on('Finish', function (Swoole\Server $server, int $taskId, mixed $data) {
    $server->send($data['fd'], 'Ergebnis: ' . $data['result'] . "\n");
});

$server->on('Connect', function () {});
$server->on('Close', function () {});

$server->start();

<?php
// Hauptserver auf TCP, zusätzlicher UDP-Port über addlistener()

$server = new Swoole\Server('0.0.0.0', 9503, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);

// Zusätzlichen UDP-Port hinzufügen
$udpPort = $server->addlistener('0.0.0.0', 9504, SWOOLE_SOCK_UDP);
$udpPort->on('Packet', function (Swoole\Server $server, string $data, array $clientInfo) {
    echo "UDP-Paket von {$clientInfo['address']}:{$clientInfo['port']}: {$data}\n";
    $server->sendto($clientInfo['address'], $clientInfo['port'], 'UDP Echo: ' . $data);
});

$server->on('Connect', function (Swoole\Server $server, int $fd) {
    echo "TCP-Client #{$fd} verbunden\n";
});

$server->on('Receive', function (Swoole\Server $server, int $fd, int $rid, string $data) {
    $server->send($fd, 'TCP Echo: ' . $data);
});

$server->on('Close', function () {});

$server->on('Start', function (Swoole\Server $server) {
    echo "Server gestartet — TCP: 9503, UDP: 9504\n";
});

$server->start();