實現從Redis中訂閱消息轉發到 WebSocket 客戶端

$server?=?new?swoole_websocket_server("0.0.0.0",?9501); $server->on('workerStart',?function?($server,?$workerId)?{ ????$client?=?new?swoole_redis; ????$client->on('message',?function?(swoole_redis?$client,?$result)?use?($server)?{ ????????if?($result[0]?==?'message')?{ ????????????foreach($server->connections?as?$fd)?{ ????????????????$server->push($fd,?$result[1]); ????????????} ????????} ????}); ????$client->connect('127.0.0.1',?6379,?function?(swoole_redis?$client,?$result)?{ ????????$client->subscribe('msg_0'); ????}); }); $server->on('open',?function?($server,?$request)?{ }); $server->on('message',?function?(swoole_websocket_server?$server,?$frame)?{ ????$server->push($frame->fd,?"hello"); }); $server->on('close',?function?($serv,?$fd)?{ }); $server->start();