SSE

এই বৈশিষ্ট্যটির জন্য workerman>=4.0.0 প্রয়োজন

SSE অর্থাৎ Server-sent Events, এটি একটি সার্ভার পুশ প্রযুক্তি। এর সারাংশ হল ক্লায়েন্ট একটি Accept: text/event-stream হেডার সমন্বিত http অনুরোধ পাঠানোর পর, সংযোগ বন্ধ না হয়ে, সার্ভার এই সংযোগের উপর ক্লায়েন্টকে ডেটা অবিরত পুশ করতে পারে।

এটি 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, বার্তার আইডি প্রেরণ করা আবশ্যক নয়
            $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);