Partage d'exemples de développement Workerman : expérience de développement permettant d'atteindre une stabilité élevée du système de discussion en temps réel

composer require workerman/workerman

<?php
require_once __DIR__ . '/vendor/autoload.php';
use WorkermanWorker;

$worker = new Worker('websocket://0.0.0.0:8080');

$worker->count = 4; // 设置进程数

$worker->onConnect = function($connection) {
    // 当有新的客户端连接时，触发此回调函数
};

$worker->onMessage = function($connection, $data) {
    // 当接收到客户端消息时，触发此回调函数
};

$worker->onClose = function($connection) {
    // 当客户端连接关闭时，触发此回调函数
};

Worker::runAll();

// ...

$worker->onMessage = function($connection, $data) {
    global $worker;
    foreach($worker->connections as $client) {
        // 向所有客户端广播消息
        $client->send($data);
    }
};

// ...

// ...

use WorkermanLibTimer;

$worker->onWorkerStart = function() {
    // 每隔5秒检测是否有连接超时，超时则关闭连接
    Timer::add(5, function() {
        global $worker;
        $time_now = time();
        foreach($worker->connections as $connection) {
            if($time_now - $connection->lastMessageTime > 10) {
                $connection->close();
            }
        }
    });
};

// ...