SSE

यह सुविधा workerman>=4.0.0 की आवश्यकता है

SSE, या Server-sent Events, एक सर्वर-पुश तकनीक है। इसकी प्रकृति यह है कि क्लाइंट एक HTTP अनुरोध भेजता है जिसमें Accept: text/event-stream हेडर होता है, फिर कनेक्शन बंद नहीं होता है, और सर्वर इस कनेक्शन पर लगातार क्लाइंट को डेटा पुश कर सकता है।

यह websocket से अलग है:

• SSE केवल सर्वर से क्लाइंट की ओर पुश कर सकता है; Websocket दो-तरफा संचार की अनुमति देता है।
• SSE स्वचालित रूप से पुन: कनेक्शन का समर्थन करता है; WebSocket को स्वयं कार्यान्वित करना होता है।
• SSE केवल utf8 पाठ को संचरित कर सकता है, बाइनरी डेटा को utf8 में एन्कोड करके भेजना होगा; WebSocket स्वचालित रूप से utf8 और बाइनरी डेटा को संचरित करने का समर्थन करता है।
• SSE में एक अंतर्निहित संदेश प्रकार होता है; WebSocket को स्वयं कार्यान्वित करना होता है।

उदाहरण

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') {
        // सबसे पहले एक Content-Type: text/event-stream हेडर के साथ प्रतिक्रिया भेजें
        $connection->send(new Response(200, ['Content-Type' => 'text/event-stream'], "\r\n"));
        // नियमित अंतराल पर क्लाइंट को डेटा पुश करें
        $timer_id = Timer::add(2, function () use ($connection, &$timer_id){
            // कनेक्शन बंद होने पर टाइमर को हटाना चाहिए, जिससे टाइमर लगातार बढ़ने से मेमोरी लीक न हो
            if ($connection->getStatus() !== TcpConnection::STATUS_ESTABLISHED) {
                Timer::del($timer_id);
                return;
            }
            // message घटना भेजें, घटना के साथ डेटा hello है, संदेश id को पास नहीं किया जा सकता
            $connection->send(new ServerSentEvents(['event' => 'message', 'data' => 'hello', 'id'=>1]));
        });
        return;
    }
    $connection->send('ok');
};

// वर्कर चलाएँ
Worker::runAll();

क्लाइंट का जावास्क्रिप्ट कोड

var source = new EventSource('http://127.0.0.1:8080');
source.addEventListener('message', function (event) {
  var data = event.data;
  console.log(data); // hello आउटपुट करें
}, false);