WebSocket\Server · Swoole文檔手冊

# WebSocket\\Server [TOC] `1.7.9`增加了內置的`WebSocket`服務器支持，通過幾行PHP代碼就可以寫出一個異步非阻塞多進程的`WebSocket`服務器。 ~~~ $server = new Swoole\WebSocket\Server("0.0.0.0", 9501); $server->on('open', function (Swoole\WebSocket\Server $server, $request) { echo "server: handshake success with fd{$request->fd}\n"; }); $server->on('message', function (Swoole\WebSocket\Server $server, $frame) { echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n"; $server->push($frame->fd, "this is server"); }); $server->on('close', function ($ser, $fd) { echo "client {$fd} closed\n"; }); $server->start(); ~~~ ## onRequest回調 `WebSocket\Server`繼承自`Http\Server` * 設置了`onRequest`回調，`WebSocket\Server`也可以同時作為`http`服務器 * 未設置`onRequest`回調，`WebSocket\Server`收到`http`請求后會返回`http 400`錯誤頁面 * 如果想通過接收`http`觸發所有`websocket`的推送，需要注意作用域的問題，面向過程請使用`global`對`WebSocket\Server`進行引用，面向對象可以把`WebSocket\Server`設置成一個成員屬性 1、面向過程代碼 ~~~ $server = new Swoole\WebSocket\Server("0.0.0.0", 9501); $server->on('open', function (Swoole\WebSocket\Server $server, $request) { echo "server: handshake success with fd{$request->fd}\n"; }); $server->on('message', function (Swoole\WebSocket\Server $server, $frame) { echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n"; $server->push($frame->fd, "this is server"); }); $server->on('close', function ($ser, $fd) { echo "client {$fd} closed\n"; }); $server->on('request', function (Swoole\Http\Request $request, Swoole\Http\Response $response) { global $server;//調用外部的server // $server->connections 遍歷所有websocket連接用戶的fd，給所有用戶推送 foreach ($server->connections as $fd) { $server->push($fd, $request->get['message']); } }); $server->start(); ~~~ 2、面向對象代碼 ~~~ class WebsocketTest { public $server; public function __construct() { $this->server = new Swoole\WebSocket\Server("0.0.0.0", 9501); $this->server->on('open', function (swoole_websocket_server $server, $request) { echo "server: handshake success with fd{$request->fd}\n"; }); $this->server->on('message', function (Swoole\WebSocket\Server $server, $frame) { echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n"; $server->push($frame->fd, "this is server"); }); $this->server->on('close', function ($ser, $fd) { echo "client {$fd} closed\n"; }); $this->server->on('request', function ($request, $response) { // 接收http請求從get獲取message參數的值，給用戶推送 // $this->server->connections 遍歷所有websocket連接用戶的fd，給所有用戶推送 foreach ($this->server->connections as $fd) { $this->server->push($fd, $request->get['message']); } }); $this->server->start(); } } new WebsocketTest(); ~~~ ## 客戶端 * `Chrome`/`Firefox`/高版本`IE`/`Safari`等瀏覽器內置了`JS`語言的`WebSocket`客戶端 * 微信小程序開發框架內置的`WebSocket`客戶端 * 異步的`PHP`程序中可以使用`Swoole\Http\Client`作為`WebSocket`客戶端 * `apache/php-fpm`或其他同步阻塞的`PHP`程序中可以使用`swoole/framework`提供的[同步WebSocket客戶端](https://github.com/swoole/framework/blob/master/libs/Swoole/Client/WebSocket.php) * 非`WebSocket`客戶端不能與`WebSocket`服務器通信