SSE

Esta característica requiere workerman >= 4.0.0

SSE, que son los Server-sent Events, es una tecnología de empuje del lado del servidor. Su esencia es que después de que el cliente envía una solicitud http con el encabezado Accept: text/event-stream, la conexión no se cierra, y el servidor puede seguir enviando datos continuamente al cliente a través de esa conexión.

Las diferencias con WebSocket son:

• SSE solo permite que el servidor envíe datos al cliente; Websocket permite comunicación bidireccional.
• SSE soporta reconexión automática por defecto; WebSocket necesita ser implementado manualmente.
• SSE solo puede transportar texto en utf8; los datos binarios necesitan ser codificados en utf8 antes de ser enviados; WebSocket admite por defecto el transporte de datos en utf8 y binarios.
• SSE tiene tipos de mensajes incorporados; WebSocket necesita ser implementado manualmente.

Ejemplo

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)
{
    // Si el encabezado Accept es text/event-stream, entonces es una solicitud SSE
    if ($request->header('accept') === 'text/event-stream') {
        // Primero enviar una respuesta con el encabezado Content-Type: text/event-stream
        $connection->send(new Response(200, ['Content-Type' => 'text/event-stream'], "\r\n"));
        // Enviar datos al cliente de forma periódica
        $timer_id = Timer::add(2, function () use ($connection, &$timer_id){
            // Cuando la conexión se cierra, se debe eliminar el temporizador para evitar que se acumulen y cause fugas de memoria
            if ($connection->getStatus() !== TcpConnection::STATUS_ESTABLISHED) {
                Timer::del($timer_id);
                return;
            }
            // Enviar un evento message, los datos del evento son hello, el id del mensaje es opcional
            $connection->send(new ServerSentEvents(['event' => 'message', 'data' => 'hello', 'id'=>1]));
        });
        return;
    }
    $connection->send('ok');
};

// Ejecutar el worker
Worker::runAll();

Código JavaScript del cliente

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