時間：2023-04-21 09:21:02 | 來源：網(wǎng)站運營
時間：2023-04-21 09:21:02 來源：網(wǎng)站運營
thinkphp6+swoole websocket使用教程自研路線不建議使用：?
在線咨詢
<?php namespace app/http; use Swoole/Server;use Swoole/Websocket/Frame;use Swoole/WebSocket/Server as WebsocketServer;use think/Config;use think/Request;use think/swoole/contract/websocket/HandlerInterface; class Ywliveanchor implements HandlerInterface{ /** @var WebsocketServer */ protected $server; /** @var Config */ protected $config; public function __construct(Server $server, Config $config) { $this->server = $server; $this->config = $config; } /** * "onOpen" listener. * * @param int $fd * @param Request $request */ public function onOpen($fd, Request $request) { echo "隊列{$fd}連接/n"; } /** * "onMessage" listener. * only triggered when event handler not found * * @param Frame $frame * @return bool */ public function onMessage(Frame $frame) { $packet = $frame->data; if (Packet::getPayload($packet)) { return false; } $this->checkHeartbeat($frame->fd, $packet); return true; } /** * "onClose" listener. * * @param int $fd * @param int $reactorId */ public function onClose($fd, $reactorId) { return; } protected function checkHeartbeat($fd, $packet) { $packetLength = strlen($packet); $payload = ''; if ($isPing = Packet::isSocketType($packet, 'ping')) { $payload .= Packet::PONG; } if ($isPing && $packetLength > 1) { $payload .= substr($packet, 1, $packetLength - 1); } if ($isPing) { $this->server->push($fd, $payload); } }} php think swoole // if ($pidManager->isRunning()) { // $this->output->writeln('<error>swoole http server process is already running.</error>'); // return; // } public function onMessage(Frame $frame) { /go(function ()use($frame) { $redis = new /Redis(); $redis->connect('127.0.0.1', 6379); $data=json_decode($frame->data); // var_dump($data); // if($data->con=='not_logged_in'){ // //未登錄 // //存儲房間信息 // $redis->sAdd('room'.$data->roominfo->id,$frame->fd); // $redis->set('fd_roominfo'.$frame->fd,json_encode($data->roominfo)); // }else if($data->con=='already_logged_in'){ // //已登錄存儲用戶信息 //1.提供user列表 $redis->set('fd_userinfo'.$frame->fd,json_encode($data));//fd綁定info消息 $redis->zAdd('user'.$data->roominfo->id,$frame->fd,json_encode($data));// 有序集合記錄房間info列表信息 $info=$redis->zRevRange('user'.$data->roominfo->id, 0, -1);//獲取房間info列表信息 //2.提供user單個信息 // $redis->set('fd_userinfo'.$frame->fd,json_encode($data->userinfo));//fd綁定userinfo // $userinfo=$redis->get('fd_userinfo'.$frame->fd); //存儲房間信息 $redis->set('fd_roominfo'.$frame->fd,json_encode($data->roominfo));//fd綁定房間 $redis->sAdd('room'.$data->roominfo->id,$frame->fd);//無序集合記錄房間fd列表 $room=$redis->sMembers('room'.$data->roominfo->id);//獲取房間fd列表 var_dump($room); $res=array( 'open'=>'1', //'data'=>['con'=>'open','msg'=>'發(fā)送成功','count'=>count($room),'info'=>json_decode($userinfo)] 'data'=>['con'=>'open','msg'=>'發(fā)送成功','count'=>count($room),'info'=>$info] ); }elseif($data->con=='already_logged_out'){ $roominfo= json_decode($redis->get('fd_roominfo'.$frame->fd));//獲取房間信息 $redis->srem('room'.$roominfo->id,$frame->fd);//刪除房間信息 $room=$redis->sMembers('room'.$roominfo->id); //獲取房間fd列表 var_dump($room); //1.提供user列表 $data=$redis->get('fd_userinfo'.$frame->fd);//獲取關(guān)閉用戶的info信息 // var_dump($data); $a=$redis->zRem('user'.$roominfo->id,$data); // var_dump($a); $info=$redis->zRevRange('user'.$roominfo->id, 0, -1); $redis->del('fd_userinfo'.$frame->fd);//移除房間用戶 // var_dump($info); //2.提供user單個信息 // $userinfo=$redis->get('fd_userinfo'.$frame->fd); // $redis->del('fd_userinfo'.$frame->fd); $res=array( 'open'=>'1', //'data'=>['con'=>'close',"count"=>count($room),'info'=>json_decode($userinfo)] 'data'=>['con'=>'close','msg'=>'發(fā)送成功','count'=>count($room),'info'=>$info] ); echo "隊列{$frame->fd}關(guān)閉1/n"; } /go(function ()use($res,$room) { $jsonStr = json_encode($res); foreach($room as $fd){ $this->server->push($fd, $jsonStr); } }); } 關(guān)鍵詞：使用,路線,建議,教程
微信公眾號
版權(quán)所有? 億企邦 1997-2025 保留一切法律許可權(quán)利。
