``` <?php //創建WebSocket Server對象，監聽0.0.0.0:9502端口 $ws = new Swoole\WebSocket\Server('0.0.0.0', 9503); //監聽WebSocket連接打開事件 $ws->on('open', function ($ws, $request) { $fd=$request->fd; var_dump($request->fd, $request->server); $ws->push($request->fd, "hello, welcome\n"); }); //監聽WebSocket消息事件 $ws->on('message', function ($ws, $frame) { //echo "Message: {$frame->data}\n"; $ws->push($frame->fd, "服務端返回:{$frame->data}"); }); //第一種方式：通過curl調用swoole.xian008.com:9501(客戶端websocket連接地址) $ws->on('request', function (Swoole\Http\Request $request, Swoole\Http\Response $response) { global $ws;//調用外部的server //$server->connections 遍歷所有websocket連接用戶的fd，給所有用戶推送 foreach ($ws->connections as $fd) { // 需要先判斷是否是正確的websocket連接，否則有可能會push失敗 if ($ws->isEstablished($fd)) { $ws->push($fd, $request->post['message']); } } }); 第二種方式：通過redis訂閱來實現 $process = new Swoole\Process(function ($process)use($ws) { echo 'process'; $redis = new \Redis(); $redis->connect('127.0.0.1',6379); $redis->auth('xiaocinao'); $redis->subscribe(['name'],function ($redis,$channel,$msg)use($ws){ $ws->push(1,$msg); }); }); //監聽WebSocket連接關閉事件 $ws->on('close', function ($ws, $fd) { echo "client-{$fd} is closed\n"; }); $ws->addProcess($process); $ws->start(); ```