SSE

Dieses Feature benötigt workerman>=4.0.0

SSE, also Server-sent Events, ist eine Server-Push-Technologie. Im Wesentlichen sendet der Client eine HTTP-Anfrage mit dem Header Accept: text/event-stream, nach dem die Verbindung nicht geschlossen wird und der Server kontinuierlich Daten an den Client über diese Verbindung pushen kann.

Die Unterschiede zu WebSocket sind:

• SSE kann nur vom Server an den Client pushen; WebSocket ermöglicht bidirektionale Kommunikation.
• SSE unterstützt standardmäßig die Wiederverbindung; WebSocket muss selbst implementiert werden.
• SSE kann nur UTF-8-Text übertragen; binäre Daten müssen in UTF-8 codiert und dann gesendet werden; WebSocket unterstützt standardmäßig die Übertragung von UTF-8 und binären Daten.
• SSE hat standardmäßig Nachrichtentypen; WebSocket muss selbst implementiert werden.

Beispiel

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
use Workerman\Protocols\Http\ServerSentEvents;
use Workerman\Protocols\Http\Response;
use Workerman\Timer;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:8080');

$worker->onMessage = function(TcpConnection $connection, Request $request)
{
    // Wenn der Accept-Header text/event-stream ist, handelt es sich um eine SSE-Anfrage
    if ($request->header('accept') === 'text/event-stream') {
        // Zuerst eine Antwort mit dem Header Content-Type: text/event-stream senden
        $connection->send(new Response(200, ['Content-Type' => 'text/event-stream'], "\r\n"));
        // Regelmäßig Daten an den Client pushen
        $timer_id = Timer::add(2, function () use ($connection, &$timer_id){
            // Den Timer löschen, wenn die Verbindung geschlossen ist, um zu vermeiden, dass der Timer sich anhäuft und zu einem Speicherauslauf führt
            if ($connection->getStatus() !== TcpConnection::STATUS_ESTABLISHED) {
                Timer::del($timer_id);
                return;
            }
            // Das message-Event senden; die Daten des Events sind hello, die Nachricht-ID kann weggelassen werden
            $connection->send(new ServerSentEvents(['event' => 'message', 'data' => 'hello', 'id'=>1]));
        });
        return;
    }
    $connection->send('ok');
};

// Worker ausführen
Worker::runAll();

Client-seitiger JavaScript-Code

var source = new EventSource('http://127.0.0.1:8080');
source.addEventListener('message', function (event) {
  var data = event.data;
  console.log(data); // Gibt hello aus
}, false);