基于swoole实现多人聊天室

　　本文实例为大家分享了swoole创建多人多房间聊天室的具体代码，供大家参考，具体内容如下

　　核心的swoole代码

　　基本的cs(client-sercer)结构不变,这里利用的是redis的哈希和set来储存和分组;从而达到了分组,统计,定时推送等功能;最后利用onclose事件来剔除断开的连接,全部代码如下:(没做前端,就不展示了)

　　核心的swoole ws.php

　　 <?php namespace app\common; require_once Predis.php; require_once Task.php; /** * socket面向对象的编译 */ class Ws { CONST HOST=0.0.0.0; CONST PORT=9501; public $ws=null; public $getmsg=null; public $server=null; public function __construct() { $this->ws=new \swoole_websocket_server(self::HOST,self::PORT); $this->ws->set([ //启动task必须要设置其数量 worker_num => 4, task_worker_num => 2, // heartbeat_check_interval => 5, // heartbeat_idle_time => 10, ]); //监听新端口 $this->server=$this->ws->listen(127.0.0.1, 9502, SWOOLE_SOCK_TCP); //关闭websocket模式 $this->server->set([ open_websocket_protocol => false, ]); $this->ws->on(start, [$this, onStart]); $this->ws->on(open,[$this,onopen]); $this->server->on(receive, [$this, onReceive]); $this->ws->on(task,[$this,onTask]); $this->ws->on(finish,[$this,onFinish]); $this->ws->on(message,[$this,onmessage]); $this->ws->on(close,[$this,onclose]); $this->server->on(close, [$this, oncloses]); $this->ws->start(); } //监听数据接收事件 public function onReceive($serv, $fd, $from_id, $data) { $shuju=json_decode($data,ture); // print_r($shuju).PHP_EOL; if (empty($shuju[data])) { $this->ws->push(Predis::getInstance()->get(fd), $data); }else{ if (empty($shuju[msg])) { //执行异步任务 $this->ws->task($shuju); }else{ $push_arr=Predis::getInstance()->hvals($shuju[data]); // echo 集群是:.print_r($push_arr); foreach ($push_arr as $v) { $this->ws->push($v, $shuju[msg]); } } } } /** * 设置进程名，为后续平滑重启进程 * @param $server */ public function onStart($server) { swoole_set_process_name(live_master); } /** 监听开启事件的回调 */ public function onopen($server, $request) { print_r(这时的fd是:,$request->fd); Predis::getInstance()->set(fd,$request->fd); } /** 监听接收事件的回调 */ public function onmessage($server, $frame) { $server->push($frame->fd, {$frame->data}); } /** 监听关闭事件的回调 */ public function onclose($ser, $fd) { print_r(你好,我的{$fd}\n); //退出并删除多余的分组fd $group=Predis::getInstance()->sMembers(group); foreach ($group as $v) { $fangjian=Predis::getInstance()->hgetall($v); foreach ($fangjian as $k => $vv) { if ($fd == $vv) { Predis::getInstance()->hdel($v,$k); } } } } public function oncloses($ser, $fd) { print_r(这个是client{$fd}\n); } /** * $serv 服务 * $task_id 任务ID，由swoole扩展内自动生成，用于区分不同的任务 * $src_worker_id $task_id和$src_worker_id组合起来才是全局唯一的，不同的worker进程投递的任务ID可能会有相同 * $data 是任务的内容 */ public function onTask($serv,$task_id,$src_worker_id,$data) { //引入任务 $obj = new Task; $method = $data[data]; $arr = $data[arr]; //发布具体的任务 $flag = $obj->$method($arr, $serv); return $flag; // 告诉worker } /** * $task_id 是任务的ID * $data 是任务处理的结果内容 */ public function onFinish($serv,$task_id,$data) { print_r($data)./n; } } new Ws();

　　分发任务task.php

　　 <?php /** * 代表的是 swoole里面 后续 所有 task异步 任务 都放这里来 * Date: 18/3/27 * Time: 上午1:20 */ namespace app\common; // include Predis.php; class Task { //异步创建房间 public function chuangjian($data,$serv) { $time=$data[time]*1000; swoole_timer_after($time, function() use($data){ //创建房间(修改拍卖商品状态) self::post(进入房间并缓存信息 public function jingru($data,$serv) { $fd=Predis::getInstance()->get(fd); //加入分组 Predis::getInstance()->hset($data[name],$data[uid],$fd); //加入组集合 Predis::getInstance()->sadd(group,$data[name]); } public function post($url,$params=false,$ispost=0) { $httpInfo = array(); $ch = curl_init(); curl_setopt( $ch, CURLOPT_HTTP_VERSION , CURL_HTTP_VERSION_1_1 ); curl_setopt( $ch, CURLOPT_USERAGENT , Mozilla/5.0 (Windows NT 5.1) AppleWebKit/537.22 (KHTML, like Gecko) Chrome/25.0.1364.172 Safari/537.22 ); curl_setopt( $ch, CURLOPT_CONNECTTIMEOUT , 30 ); curl_setopt( $ch, CURLOPT_TIMEOUT , 30); curl_setopt( $ch, CURLOPT_RETURNTRANSFER , true ); if( $ispost ) { curl_setopt( $ch , CURLOPT_POST , true ); curl_setopt( $ch , CURLOPT_POSTFIELDS , $params ); curl_setopt( $ch , CURLOPT_URL , $url ); } else { if($params){ curl_setopt( $ch , CURLOPT_URL , $url.?.$params ); }else{ curl_setopt( $ch , CURLOPT_URL , $url); } } //执行 $response = curl_exec( $ch ); if ($response === FALSE) { //echo cURL Error: . curl_error($ch); return false; } $httpCode = curl_getinfo( $ch , CURLINFO_HTTP_CODE ); $httpInfo = array_merge( $httpInfo , curl_getinfo( $ch ) ); //关闭url请求 curl_close( $ch ); return json_decode($response,1); } }

　　客户端 client.php

　　 <?php namespace app\common; class Client { public $msg=; public $data=[]; public function lianjie(){ $cli = new \swoole_client(SWOOLE_SOCK_TCP); //判断连接状态（同步连接模式） $res=$cli->connect(127.0.0.1, 9502); if (empty($res)) { return 连接失败; } if (!empty($this->data)) { //发送消息给server $rel=$cli->send(json_encode($this->data)); }else{ //发送消息给server $rel=$cli->send($this->msg); } if (!empty($rel)) { return $rel; }else{ return flash; } } }

　　控制器index.php

　　 <?php namespace app\index\controller; use app\common\Client; use app\common\Predis; use app\common\Sql; use app\index\model\User; class Index { //创建房间(添加拍卖倒计时) public function chuangjian() { $data[time]=input(time); $data[id]=input(id); $cli = new Client(); $cli->data = [ data => chuangjian, arr => $data ]; return $cli->lianjie(); } //点击添加哈希(进入房间) public function jingru() { $data[name]=input(name); $data[uid]=input(uid); $cli = new Client(); $cli->data = [ data => jingru, arr => $data ]; return $cli->lianjie(); } //本房间推送(出价格成功并推送) public function pushfan() { $data[fan]=input(fan); $cli = new Client(); $cli->data = [ data => $data[fan], msg => 恭喜用户111,喜当爹!!!! ]; return $cli->lianjie(); } //时间结束并指定推送 public function zhiding() { $data[fan]=input(fan); $cli = new Client(); $cli->data = [ data => $data[fan], msg => 恭喜用户111,喜当爹!!!! ]; return $cli->lianjie(); } }

　　以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。