GatewayWorker 分佈初試

參考官網分佈說明 http://doc2.workerman.net/326144

準備：兩臺內網服務器A1，A2

A1服務器寫PHP腳本前端訪問

<?php
// 注意這裏使用A2服務器的內網ip:port
// 若是本地則能夠使用 0.0.0.0:port
// 外網服務器使用 外網ip:port
GatewayClient::$registerAddress = "172.16.100.24:6000";
// 發送數據
GatewayClient::sendToUid( "6201944211a7", "sdsadadas" );

A2服務器寫入gateway腳本

start_businessworker.php

<?php
use \Workerman\Worker;
use \Workerman\WebServer;
use \GatewayWorker\Gateway;
use \GatewayWorker\BusinessWorker;
use \Workerman\Autoloader;

// bussinessWorker 進程
$worker = new BusinessWorker();
// worker名稱
$worker->name = 'HdwBusinessWorker';
// bussinessWorker進程數量
$worker->count = 4;
// 服務註冊地址
// 分佈式則參考官網文檔
// 同臺服務器則能夠使用 127.0.0.1:port
// 內網服務器則能夠使用 內網ip:port
// 外網服務器則能夠使用 外網ip:port
$worker->registerAddress = '127.0.0.1:6000';
/**
 * 設置處理業務的類爲MyEvent。
 * 若是類帶有命名空間，則須要把命名空間加上，
 * 相似$worker->eventHandler='\my\namespace\MyEvent';
 */
// $worker->eventHandler = 'MyEvent';
// 設置使用哪一個類來處理業務，默認值是Events，即默認使用Events.php中的Events類來處理業務。業務類至少要實現onMessage靜態方法，onConnect和onClose靜態方法能夠不用實現。

// 若是不是在根目錄啓動，則運行runAll方法
if(!defined('GLOBAL_START')) {
    Worker::runAll();
}

start_gateway.php

<?php
use \Workerman\Worker;
use \Workerman\WebServer;
use \GatewayWorker\Gateway;
use \GatewayWorker\BusinessWorker;
use \Workerman\Autoloader;

// gateway 進程，這裏使用Text協議，能夠用telnet測試
$gateway = new Gateway("Hardware://0.0.0.0:6049");
// gateway名稱，status方便查看
$gateway->name = 'HdwGateway';
// gateway進程數
$gateway->count = 4;
// 本機ip，分佈式部署時使用內網ip
// 這裏ip必須爲內網ip知足A1服務器調用
$gateway->lanIp = '172.16.100.24';
// 內部通信起始端口，假如$gateway->count=4，起始端口爲4000
// 則通常會使用4000 4001 4002 4003 4個端口做爲內部通信端口 
$gateway->startPort = 6040;
// 服務註冊地址
$gateway->registerAddress = '127.0.0.1:6000';

// 心跳間隔
$gateway->pingInterval = 30;
// $pingNotResponseLimit * $pingInterval 時間內，客戶端未發送任何數據，斷開客戶端鏈接
$gateway->pingNotResponseLimit = 2;
// 心跳數據
// 技巧1：若是客戶端有定時向服務端發送心跳檢測，則服務端能夠沒必要向客戶端發送心跳檢測，即利用客戶端主動發送的數據判斷客戶端是否存活。這時咱們須要設置pingData=''
$gateway->pingData = getPingData();

/* 
// 當客戶端鏈接上來時，設置鏈接的onWebSocketConnect，即在websocket握手時的回調
$gateway->onConnect = function($connection)
{
    $connection->onWebSocketConnect = function($connection , $http_header)
    {
        // 能夠在這裏判斷鏈接來源是否合法，不合法就關掉鏈接
        // $_SERVER['HTTP_ORIGIN']標識來自哪一個站點的頁面發起的websocket連接
        if($_SERVER['HTTP_ORIGIN'] != 'http://kedou.workerman.net')
        {
            $connection->close();
        }
        // onWebSocketConnect 裏面$_GET $_SERVER是可用的
        // var_dump($_GET, $_SERVER);
    };
}; 
*/

// 若是不是在根目錄啓動，則運行runAll方法
if(!defined('GLOBAL_START')) {
    Worker::runAll();
}

start_register.php

<?php
use \Workerman\Worker;
use \GatewayWorker\Register;

// register 服務必須是text協議
$register = new Register('text://0.0.0.0:6000');
// 若是不是在根目錄啓動，則運行runAll方法
if(!defined('GLOBAL_START')) {
    Worker::runAll();
}

服務器：

A1服務器無任何須要配置，

A2服務器①、Register服務監聽的端口要能夠被其它內網服務器訪問（外網訪問能夠屏蔽）；②、start_gateway.php中若是$gateway->startPort=2300; $gateway->count=4;，則2300 2301 2302 2303四個端口須要被設置成能被其它服務器訪問，也就是起始端口$gateway->startPort到$gateway->startPort + $gateway->count - 1這 $gateway->count個端口要設置成能被其它內網服務器訪問。