उदाहरण 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);
    // अपने प्रक्रिया id को घटना नाम के रूप में उपयोग करें
    $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 पृष्ठ में जावास्क्रिप्ट के रूप में चलाएँ)

// यह भी ws://192.168.1.3:4236 से कनेक्ट हो सकता है
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} को वास्तविक मानों से बदलें