Workerman开发实战：搭建高效的即时通讯系统

<选修php
require_once __DIR__.'/vendor/autoload.php';

use WorkermanWorker;

// 建立一个Worker监听两345端心，运用websocket和谈通讯
$ws_worker = new Worker("websocket://0.0.0.0:两345");

// 设备历程数
$ws_worker->count = 4;

// 当客户端毗连时
$ws_worker->onConnect = function($connection){
    echo "New connection
";
};

// 当客户端领送动静时
$ws_worker->onMessage = function($connection, $data){
    foreach($connection->worker->connections as $clientConnection){
        $clientConnection->send($data);
    }
};

// 当客户端断谢衔接时
$ws_worker->onClose = function($connection){
    echo "Connection closed
";
};

// 运转worker
Worker::runAll();

<必修php
require_once __DIR__.'/vendor/autoload.php';

use WorkermanWorker;
use WorkermanAutoloader;
use WorkermanConnectionAsyncTcpConnection;

$connect_list = array();

// 当用户输出动静时
function onMessage($connect)
{
    // 从末端读与用户输出的动静
    $message = trim(fgets(STDIN));
    
    // 领送动静到任事端
    $connect->send($message);
}

// 建立一个同步TCP毗邻到处事端
$connect = new AsyncTcpConnection('ws://1二7.0.0.1:二345');
$connect->onConnect = function($connection){
    echo "Connected to server
";
};
$connect->onMessage = function($connection, $data){
    echo "Received message: ".$data."
";
};
$connect->onClose = function($connection){
    echo "Disconnected from server
";
};

// 运转衔接
$connect->connect();

// 将毗连工具生产到毗连列表外
$connect_list[] = $connect;

// 监听用户输出动态
Worker::addWorker(function(){
    readline_callback_handler_install('', function(){});
    while (true) {
        if (count($GLOBALS['connect_list']) > 0) {
            $read = array_values($GLOBALS['connect_list']);
            $write = null;
            $except = null;
            if (false === ($num_changed_streams = stream_select($read, $write, $except, 1))) {
                continue;
            } elseif ($num_changed_streams > 0) {
                foreach($read as $connect) {
                    onMessage($connect);
                }
            }
        }
    }
});
Worker::runAll();