예제 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 "connection not exists\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} connected\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:4236
ws = new WebSocket("ws://192.168.1.2:4236");
ws.onmessage = function(e) {
    alert("서비스에서 받은 메시지：" + e.data);
};
  1. 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}를 실제 값으로 교체하세요.