SSE

此特性需要workerman>=4.0.0

SSE也就是Server-sent Events，是一種服務(wù)端推送技術(shù)。它的本質(zhì)是客戶端發(fā)送一個攜帶Accept: text/event-stream 頭的http請求后，連接不關(guān)閉，服務(wù)端可以在這個連接上不斷的給客戶端推送數(shù)據(jù)。

它與websocket的區(qū)別是：

• SSE只能服務(wù)端向客戶端推；Websocket可以雙向通訊。
• SSE 默認支持斷線重連；WebSocket 需要自己實現(xiàn)。
• SSE 只能傳輸utf8文本，二進制數(shù)據(jù)需要編碼成utf8后傳送；WebSocket 默認支持傳送utf8和二進制數(shù)據(jù)。
• SSE 自帶消息類型；WebSocket 需要自己實現(xiàn)。

例子

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)
{
    // 如果Accept頭是text/event-stream則說明是SSE請求
    if ($request->header('accept') === 'text/event-stream') {
        // 首先發(fā)送一個 Content-Type: text/event-stream 頭的響應(yīng)
        $connection->send(new Response(200, ['Content-Type' => 'text/event-stream'], "\r\n"));
        // 定時向客戶端推送數(shù)據(jù)
        $timer_id = Timer::add(2, function () use ($connection, &$timer_id){
            // 連接關(guān)閉的時候要將定時器刪除，避免定時器不斷累積導(dǎo)致內(nèi)存泄漏
            if ($connection->getStatus() !== TcpConnection::STATUS_ESTABLISHED) {
                Timer::del($timer_id);
                return;
            }
            // 發(fā)送message事件，事件攜帶的數(shù)據(jù)為hello，消息id可以不傳
            $connection->send(new ServerSentEvents(['event' => 'message', 'data' => 'hello', 'id'=>1]));
        });
        return;
    }
    $connection->send('ok');
};

// 運行worker
Worker::runAll();

客戶端javascript代碼

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