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
转载请注明出处。
本站部分内容来源于网络,如侵犯到您的权益,请 联系我