第九章 WebSocket · swoole文檔

# WebSocket `1.7.9`增加了內置的`WebSocket`服務器支持，通過幾行PHP代碼就可以寫出一個異步非阻塞多進程的`WebSocket`服務器。 ```php $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回調 ---- swoole_websocket_server 繼承自 swoole_http_server * 設置了`onRequest`回調，websocket服務器也可以同時作為http服務器 * 未設置`onRequest`回調，websocket服務器收到http請求后會返回`http 400`錯誤頁面 * 如果想通過接收http觸發所有websocket的推送，需要注意作用域的問題，面向過程請使用`global`對`swoole_websocket_server`進行引用，面向對象可以把`swoole_websocket_server`設置成一個成員屬性 1、面向過程代碼 ```php $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、面向對象代碼 ```php 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`服務器通信