SSE

Questa funzione richiede workerman>=4.0.0

SSE, ovvero Server-sent Events, è una tecnologia di push dal server. La sua essenza è che dopo che il client invia una richiesta http con l'intestazione Accept: text/event-stream, la connessione non si chiude, consentendo al server di inviare continuamente dati al client su questa connessione.

Le differenze con WebSocket sono:

• SSE può solo inviare dati dal server al client; WebSocket supporta la comunicazione bidirezionale.
• SSE supporta automaticamente la riconnessione dopo una disconnessione; WebSocket deve implementarlo da solo.
• SSE può trasmettere solo testo utf8; i dati binari devono essere codificati in utf8 prima di essere inviati; WebSocket supporta nativamente l'invio di dati utf8 e binari.
• SSE ha tipi di messaggio integrati; WebSocket deve implementarlo da solo.

Esempio

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)
{
    // Se l'intestazione Accept è text/event-stream, significa che è una richiesta SSE
    if ($request->header('accept') === 'text/event-stream') {
        // Inviare innanzitutto una risposta con l'intestazione Content-Type: text/event-stream
        $connection->send(new Response(200, ['Content-Type' => 'text/event-stream'], "\r\n"));
        // Inviare dati al client a intervalli regolari
        $timer_id = Timer::add(2, function () use ($connection, &$timer_id){
            // Quando la connessione si chiude, è necessario eliminare il timer per evitare perdite di memoria
            if ($connection->getStatus() !== TcpConnection::STATUS_ESTABLISHED) {
                Timer::del($timer_id);
                return;
            }
            // Invia l'evento message, i dati dell'evento sono hello, l'id del messaggio può essere omesso
            $connection->send(new ServerSentEvents(['event' => 'message', 'data' => 'hello', 'id'=>1]));
        });
        return;
    }
    $connection->send('ok');
};

// Esecuzione del worker
Worker::runAll();

Codice javascript del client

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