使用swoole扩展php websocket示例

前端技术 2023/09/03 PHP

复制代码 代码如下:

<?php
define(\'DEBUG\', \'on\');
define(\"WEBPATH\", str_replace(\"\\\\\",\"/\", __DIR__));
require __DIR__ . \'/../libs/lib_config.php\';

class WebSocket extends Swoole\\Network\\Protocol\\WebSocket
{
    /**
     * 下线时,通知所有人
     */
    function onClose($serv, $client_id, $from_id)
    {
        //将下线消息发送给所有人
        //$this->log(\"onOffline: \" . $client_id);
        //$this->broadcast($client_id, \"onOffline: \" . $client_id);
        parent::onClose($serv, $client_id, $from_id);
    }

    /**
     * 接收到消息时
     * @see WSProtocol::onMessage()
     */
    function onMessage($client_id, $ws)
    {
        $this->log(\"onMessage: \".$client_id.\' = \'.$ws[\'message\']);
        $this->send($client_id, \"Server: \".$ws[\'message\']);
  //$this->broadcast($client_id, $ws[\'message\']);
    }

    function broadcast($client_id, $msg)
    {
        foreach ($this->connections as $clid => $info)
        {
            if ($client_id != $clid)
            {
                $this->send($clid, $msg);
            }
        }
    }
}


$AppSvr = new WebSocket();
$AppSvr->loadSetting(__DIR__.\"/swoole.ini\"); //加载配置文件
$AppSvr->setLogger(new \\Swoole\\Log\\EchoLog(true)); //Logger

$server = new \\Swoole\\Network\\Server(\'0.0.0.0\', 9503);
$server->setProtocol($AppSvr);
//$server->daemonize(); //作为守护进程
$server->run(array(\'worker_num\' =>4));

本文地址:https://www.stayed.cn/item/8856

转载请注明出处。

本站部分内容来源于网络,如侵犯到您的权益,请 联系我

我的博客

人生若只如初见,何事秋风悲画扇。