使用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));