使用swoole扩展php websocket示例

使用swoole扩展php websocket示例

 WebSocket规范的目标是在浏览器中实现和服务器端双向通信。双向通信可以拓展浏览器上的应用类型，如果你想要用PHP来写websocket应用，那swoole_framework一定是最好的选择,需要的朋友可以参考下

 代码如下:

<?php

define('DEBUG', 'on');

define("WEBPATH", str_replace("","/", __DIR__));

require __DIR__ . '/../libs/lib_config.php';

 

class WebSocket extends SwooleNetworkProtocolWebSocket

{

    /**

     * 下线时，通知所有人

     */

    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 SwooleLogEchoLog(true)); //Logger

 

$server = new SwooleNetworkServer('0.0.0.0', 9503);

$server->setProtocol($AppSvr);

//$server->daemonize(); //作为守护进程

$server->run(array('worker_num' =>4));