SSE

Bu özellik workerman>=4.0.0 gerektirir

SSE, yani Server-sent Events, bir sunucu tarafından itme tekniğidir. Temel mantığı, istemcinin Accept: text/event-stream başlığı taşıyan bir http isteği göndermesidir; bağlantı kapanmaz, sunucu bu bağlantı üzerinden istemciye sürekli veri gönderebilir.

Websocket ile arasındaki farklar şunlardır:

• SSE yalnızca sunucudan istemciye veri gönderebilir; Websocket iki yönlü iletişimi destekler.
• SSE varsayılan olarak bağlantı kesilince yeniden bağlanmayı destekler; WebSocket bunu kendiniz gerçekleştirmeniz gerekir.
• SSE yalnızca utf8 metin taşıyabilir, ikili veriler utf8 formatında kodlanarak gönderilmelidir; WebSocket varsayılan olarak utf8 ve ikili verileri göndermeyi destekler.
• SSE yerleşik mesaj türleri vardır; WebSocket bunu kendiniz gerçekleştirmeniz gerekir.

Örnek

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)
{
    // Eğer Accept başlığı text/event-stream ise bu bir SSE isteğidir
    if ($request->header('accept') === 'text/event-stream') {
        // Öncelikle bir Content-Type: text/event-stream başlıklı yanıt gönderelim
        $connection->send(new Response(200, ['Content-Type' => 'text/event-stream'], "\r\n"));
        // İstemciye düzenli olarak veri göndermek için zamanlayıcı ayarlayalım
        $timer_id = Timer::add(2, function () use ($connection, &$timer_id){
            // Bağlantı kapandığında zamanlayıcıyı silmek gerekli, aksi takdirde zamanlayıcı birikmesi nedeniyle bellek sızıntısı oluşabilir
            if ($connection->getStatus() !== TcpConnection::STATUS_ESTABLISHED) {
                Timer::del($timer_id);
                return;
            }
            // message olayını gönderiyoruz, olay ile birlikte taşınan veri 'hello', mesaj id'si geçmesek de olur
            $connection->send(new ServerSentEvents(['event' => 'message', 'data' => 'hello', 'id'=>1]));
        });
        return;
    }
    $connection->send('ok');
};

// worker'ı çalıştır
Worker::runAll();

İstemci javascript kodu

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