ตัวอย่างที่ 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 client เชื่อมต่อกับ Channel server
    Channel\Client::connect('192.168.1.1', 2206);
    // ใช้ process id ของตัวเองเป็นชื่อเหตุการณ์
    $event_name = $worker->id;
    // Subscribe เหตุการณ์ 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);
    });

    // Subscribe เหตุการณ์การถ่ายทอด
    $event_name = 'การถ่ายทอด';
    // เมื่อได้รับเหตุการณ์การถ่ายทอดให้ส่งข้อมูลไปยังการเชื่อมต่อ client ทุกตัวใน process ปัจจุบัน
    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 ส่งข้อมูลไปยัง client ใด ๆ ต้องส่ง 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 process ใด ๆ
    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. เชื่อมต่อ client กับเซิร์ฟเวอร์

เปิดเบราว์เซอร์ chrome กด F12 เพื่อเปิดคอนโซลสำหรับพัฒนา ในแถบ Console ให้พิมพ์ (หรือใส่โค้ดด้านล่างลงในหน้า html เพื่อทำงานด้วย js)

// สามารถเชื่อมต่อไปยัง 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 ไปยังการเชื่อมต่อ client ทุกตัว

ไปที่ 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} เพื่อส่งข้อมูล $content ไปยังการเชื่อมต่อ client ใน worker process ใด ๆ

หมายเหตุ: ในการทดสอบให้เปลี่ยน {$worker_id} {$connection_id} และ{$content} เป็นค่าจริง