swoole websocket封装类和调用

上代码 ws.php

ws = new swoole_websocket_server("0.0.0.0", 9512); $this->ws->set( [ 'worker_num' => 2, 'task_worker_num' => 2, ] ); $this->ws->on("open", [$this, 'onOpen']); $this->ws->on("message", [$this, 'onMessage']); $this->ws->on("task", [$this, 'onTask']); $this->ws->on("finish", [$this, 'onFinish']); $this->ws->on("close", [$this, 'onClose']); $this->ws->start(); } /** * 监听ws连接事件 * @param $ws * @param $request */ public function onOpen($ws, $request) { var_dump($request->fd); if($request->fd == 1) { // 每2秒执行 swoole_timer_tick(2000, function($timer_id){ echo "2s: timerId:{$timer_id}\n"; }); } } /** * 监听ws消息事件 * @param $ws * @param $frame */ public function onMessage($ws, $frame) { echo "ser-push-message:{$frame->data}\n"; // todo 10s $data = [ 'task' => 1, 'fd' => $frame->fd, ]; //$ws->task($data); swoole_timer_after(5000, function() use($ws, $frame) { echo "5s-after\n"; $ws->push($frame->fd, "server-time-after:"); }); $ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s")); } /** * @param $serv * @param $taskId * @param $workerId * @param $data */ public function onTask($serv, $taskId, $workerId, $data) { print_r($data); // 耗时场景 10s sleep(10); return "on task finish"; // 告诉worker } /** * @param $serv * @param $taskId * @param $data */ public function onFinish($serv, $taskId, $data) { echo "taskId:{$taskId}\n"; echo "finish-data-sucess:{$data}\n"; } /** * close * @param $ws * @param $fd */ public function onClose($ws, $fd) { echo "clientid:{$fd}\n"; }}$obj = new Ws();

前端代码 ws_client.html

dahai-swoole-ws测试

结果

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。