উদাহরণ 1

(Workerman সংস্করণ>=3.3.0 প্রয়োজন)

Worker-এর উপর ভিত্তি করে বহুমুখী (বিতরণ সন্নিবেশ) পুশ সিস্টেম, সন্নিবেশভাবে আউটবাউন্ড, সন্নিবেশ সম্প্রচার।

start_channel.php
পুরো সিস্টেমে শুধুমাত্র একটি start_channel পরিষেবা স্থাপন করা যেতে পারে। ধরি এটি 192.168.1.1-এ চলমান।

<?php
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';

// একটি Channel সার্ভার শুরু করুন
$channel_server = new Channel\Server('0.0.0.0', 2206);

Worker::runAll();

start_ws.php
পুরো সিস্টেমে একাধিক start_ws পরিষেবা স্থাপন করা যেতে পারে, ধরি এটি 192.168.1.2 এবং 192.168.1.3 দুটি সার্ভারে চলমান।

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

// websocket সার্ভার
$worker = new Worker('websocket://0.0.0.0:4236');
$worker->count=2;
$worker->name = 'pusher';
$worker->onWorkerStart = function($worker)
{
    // Channel ক্লায়েন্ট Channel সার্ভারে সংযুক্ত হচ্ছে
    Channel\Client::connect('192.168.1.1', 2206);
    // নিজের প্রক্রিয়া আইডি ব্যবহার করে একটি ইভেন্ট নাম হিসাবে
    $event_name = $worker->id;
    // worker->id ইভেন্টে সাবস্ক্রাইব করুন এবং ইভেন্ট হ্যান্ডলিং ফাংশন নিবন্ধন করুন
    Channel\Client::on($event_name, function($event_data)use($worker){
        $to_connection_id = $event_data['to_connection_id'];
        $message = $event_data['content'];
        if(!isset($worker->connections[$to_connection_id]))
        {
            echo "সংযোগ বিদ্যমান নয়\n";
            return;
        }
        $to_connection = $worker->connections[$to_connection_id];
        $to_connection->send($message);
    });

    // সম্প্রচার ইভেন্টে সাবস্ক্রাইব করুন
    $event_name = 'সম্প্রচার';
    // সম্প্রচার ইভেন্ট পাওয়ার পরে বর্তমান প্রক্রিয়ার সমস্ত ক্লায়েন্ট সংযোগে সম্প্রচার তথ্য পাঠান
    Channel\Client::on($event_name, function($event_data)use($worker){
        $message = $event_data['content'];
        foreach($worker->connections as $connection)
        {
            $connection->send($message);
        }
    });
};

$worker->onConnect = function(TcpConnection $connection)use($worker)
{
    $msg = "workerID:{$worker->id} connectionID:{$connection->id} সংযুক্ত\n";
    echo $msg;
    $connection->send($msg);
};
Worker::runAll();

start_http.php
পুরো সিস্টেমে একাধিক start_http পরিষেবা স্থাপন করা যেতে পারে, ধরি এটি 192.168.1.4 এবং 192.168.1.5 দুটি সার্ভারে চলমান।

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

// http অনুরোধগুলি পরিচালনা করার জন্য, যে কোনও ক্লায়েন্টকে তথ্য পুশ করতে, workerID এবং connectionID পাঠানো প্রয়োজন
$http_worker = new Worker('http://0.0.0.0:4237');
$http_worker->name = 'publisher';
$http_worker->onWorkerStart = function()
{
    Channel\Client::connect('192.168.1.1', 2206);
};
$http_worker->onMessage = function(TcpConnection $connection, $request)
{
    // workerman4.x 5.x এর সাথে সামঞ্জস্যপূর্ণ
    if (!is_array($request)) {
        $get = $request->get();
    }
    $connection->send('ok');
    if(empty($get['content'])) return;
    // একটি নির্দিষ্ট worker প্রক্রিয়ার মধ্যে একটি নির্দিষ্ট সংযোগে তথ্য পাঠানো হচ্ছে
    if(isset($get['to_worker_id']) && isset($get['to_connection_id']))
    {
        $event_name = $get['to_worker_id'];
        $to_connection_id = $get['to_connection_id'];
        $content = $get['content'];
        Channel\Client::publish($event_name, array(
           'to_connection_id' => $to_connection_id,
           'content'          => $content
        ));
    }
    // এটি একটি বৈশ্বিক সম্প্রচার তথ্য
    else
    {
        $event_name = 'সম্প্রচার';
        $content = $get['content'];
        Channel\Client::publish($event_name, array(
           'content'          => $content
        ));
    }
};

Worker::runAll();

পরীক্ষা

1. প্রতিটি সার্ভারে পরিষেবা চালান

2. ক্লায়েন্ট সার্ভারে সংযুক্ত করুন

Chrome ব্রাউজার খুলুন, F12 চাপুন ডিবাগ কনসোল খুলতে, Console বিভাগে প্রবেশ করুন (অথবা নীচের কোডটি HTML পেজে JS চালাতে রাখুন)

// ws://192.168.1.3-এও সংযুক্ত হতে পারে
ws = new WebSocket("ws://192.168.1.2:4236");
ws.onmessage = function(e) {
    alert("সার্ভারের বার্তা प्राप्त হয়েছে: " + e.data);
};

3. HTTP ইন্টারফেস কল করে তথ্য পুশ করুন

URL অ্যাক্সেস করুন http://192.168.1.4:4237/?content={$content} অথবা http://192.168.1.5:4237/?content={$content} সমস্ত ক্লায়েন্ট সংযোগে $content ডেটা পুশ করতে

URL অ্যাক্সেস করুন http://192.168.1.4:4237/?to_worker_id={$worker_id}&to_connection_id={$connection_id}&content={$content} অথবা http://192.168.1.5:4237/?to_worker_id={$worker_id}&to_connection_id={$connection_id}&content={$content} একটি নির্দিষ্ট worker প্রক্রিয়ার মধ্যে একটি নির্দিষ্ট ক্লায়েন্ট সংযোগে $content ডেটা পুশ করতে

মনে রাখবেন: পরীক্ষার সময় {$worker_id} {$connection_id} এবং{$content} বাস্তব মানে পরিবর্তন করুন