
workerman 是一个php编写的通信效劳。之前的项目都是用它做数据接口效劳
此次用它做一个简朴的在线谈天室~
1.下载最新版本的workerman
能够去http://www.workerman.net 去下载
我这里将service 和 client 分开了两个文件夹,轻易治理
大抵的项目构造以下。
客户端:
客户端就简朴了。一个简朴的html代码。嵌入了一个 websocket 监听效劳
var ws, name, client_list={}; function connect() { // 建立websocket ws = new WebSocket("ws://192.168.0.88:2345"); // 当socket衔接翻开时,输入用户名 ws.onopen = onopen; // 当有音讯时依据音讯范例显现差别信息 ws.onmessage = onmessage; ws.onclose = function() { console.log("衔接封闭,定时重连"); connect(); }; ws.onerror = function() { console.log("涌现毛病"); }; }
完成websocket的 翻开,message的监听,以及close
1、当翻开一个客户端,则立马弹出一个输入姓名的对话框
function onopen(){ //console.log(name); //var username=connect_id=""; if(!name) { name=prompt("请输入您的名字",""); if(!name || name=='null'){ name = '咕哒子'; } } $('#curuser').text(name); data='{"type":"1","user":"'+name+'"}'; ws.send(data); }
并将数据推送给效劳端。type =1 代表上岸。
2、当收到音讯时,推断音讯范例,是群发音讯 照样私聊音讯。进而处置惩罚。
别的,每次用户有新用户上岸上来,都邑 给各个客户端推送,用户列表。举行衬着
function onmessage(e){ //console.log(e.data); var data = eval("("+e.data+")"); var info=$('#chatinfo').html(); if(data.type==1) $('#chatinfo').html(info+'<br/>'+data.data); else if(data.type==2) { // 在线用户列表 userinfo $('#userinfo').html(data.data); } else if(data.type==3) { // 在线用户列表 个人信息 name=data.data.userinfo; //console.log(data.data); } }
然后别的就是 每一个用户发送音讯的代码了。能够是私聊 ,也能够是群发
$('#send').click(function(e){ var msg=$('#msg').val(); var tofriend=$('#tofriend').val(); var tofriendname=$('#tofriendname').val(); if(tofriend!="") { data='{"type":"3","user":"'+name+'","msg":"'+msg+'","friend_id":"'+tofriend+'","friendname":"'+tofriendname+'"}'; }else{ data='{"type":"2","user":"'+name+'","msg":"'+msg+'"}'; } ws.send(data); $('#msg').attr("value",''); });
客户端差不多就是如许的了。
客户端,有几个坑 ,
坑1、变量名是 name 则革新网页不会被重置,不然就会被重置。(背面查资料发明,这个name变量 是 window.name 。所以革新网页 该值也不会被革新掉)
坑2、js组数组,变量要用"" 最外层为'' 如:data='{"type":"1","user":"'+name+'"}'; 不然剖析出问题。不能倒过来!
效劳端:
效劳端主如果workerman 组件 以及 运用 Channel分布式通信组件 完成定阅 和集群推送 分组推送 以及私聊。
起首,当然是监听,启用一个worker的websocket监听
// 建立一个Worker监听2346端口,运用websocket协定通信 $ws_worker = new Worker("websocket://0.0.0.0:2345"); $channel_server = new Channel\Server('0.0.0.0', 2206); // 启动4个历程对外供应效劳 $ws_worker->count = 4; $ws_worker->name="kinmoschat";
在workerman 监听启用的时刻,举行 channel通信的注册。
$ws_worker->onWorkerStart=function($ws_worker) { // channel 客户端链接上 效劳器 Channel\Client::connect('127.0.0.1',2206); $event_name='私聊'; // 定阅 worker-<id 事宜,并注册事宜处置惩罚函数 Channel\Client::on($event_name,function($event_data)use($ws_worker){ //print_r($event_data); //print_r($ws_worker->connections); $to_connect_id=$event_data['to_connection_id']; $message=$event_data['content']; foreach ($ws_worker->connections as $connection) { if($connection->id==$to_connect_id) { $connection->send($message); } } // if(!isset($ws_worker->connections[$to_connect_id])) // { // echo 'connect is not exist\n'; // return; // } // $to_connection=$ws_worker->connections[$to_connect_id]; // $to_connection->send($message); }); // 定阅播送事宜 $event_name = '播送'; // 收到播送 向一切客户端发送音讯 Channel\Client::on($event_name,function($event_data)use($ws_worker){ //print_r($event_data); $message=$event_data['content']; foreach ($ws_worker->connections as $connection) { $connection->send($message); } }); };
注册两个事宜,一个播送事宜,一个私聊事宜,用以上线关照的播送,以及群发音讯。私聊 就是私聊了。。这里,还能够做 分组的群发。不过,这个版本还未完成。
然后是针对,客户端链接的回调。
$ws_worker->onConnect=function($connection){ $connection->id = md5($connection->id."_".time()."_".rand(10000,99999)); };
这里,客户端回调,我会将客户端的 connectid修改掉。一个简朴的md5 主如果为了防备 流水id太轻易被应用吧。。
然后,全部项目的主体,效劳端音讯的处置惩罚回调。
针对每一个进来的客户端,分派一个唯一 id
保护一个 connectid=>user 的关联表
因为开启了多个历程致使 存到 session中无效,故而 盘算存到 数据库中
断开链接的时刻,删除数据
$ws_worker->onMessage = function($connection, $data) { $res=array('code'=>200, 'msg'=>'ok', 'data'=>null,'type'=>1); // 向客户端发送hello $data //print_r($data); $data=json_decode($data,true); //print_r($data); if(!isset($data['type'])||empty($data['type']))// type 1 2 { $res=array('code'=>301, 'msg'=>'音讯包花样毛病', 'data'=>null); }else{ switch ($data['type']) { case '1': // 客户端上线音讯 //print_r($connection->id); if(!isset($data['user'])||empty($data['user'])) { $res=array('code'=>301, 'msg'=>'音讯包花样毛病', 'data'=>null); break; } // 保护一个数组 保留 用户 connection_id => user $dsn='mysql:host=127.0.0.1;dbname=kinmoschat;'; $pdo=new PDO($dsn,'root','123456'); //预备SQL语句 $sql = "INSERT INTO `user`(`connect_id`,`username`) VALUES (:connect_id,:username)"; //挪用prepare要领预备查询 $stmt = $pdo->prepare($sql); //通报一个数组为预处置惩罚查询中的定名参数绑定值,并实行SQL $stmt->execute(array(':connect_id' => $connection->id,':username' => $data['user'])); //猎取末了一个插进去数据的ID值 //echo $pdo->lastInsertId() . '<br />'; // 向本身推送一条音讯 $res2['type']=3;// 体系信息 $res2['data']=array('userinfo' =>$data['user']);// 体系信息 $connection->send(json_encode($res2)); $msg="用户 ".$data['user']." 上线了~~"; $res['data']=$msg; break; case '2': // 客户端群发送音讯 if(!isset($data['user'])||empty($data['user'])||!isset($data['msg'])||empty($data['msg'])) { $res=array('code'=>301, 'msg'=>'音讯包花样毛病', 'data'=>null); break; } $msg="用户 ".$data['user']."说:".$data['msg']; $res['data']=$msg; break; case '3': // 客户端私聊 if(!isset($data['user'])||empty($data['user'])||!isset($data['msg'])||empty($data['msg'])||!isset($data['friend_id'])||empty($data['friend_id'])) { $res=array('code'=>301, 'msg'=>'音讯包花样毛病', 'data'=>null); break; } $msg="用户 ".$data['user']."对您说:".$data['msg']; $res['data']=$msg; $res['type']=1;// 谈天音讯 $res1=json_encode($res); // 推送给单个用户 $event_name = '私聊'; Channel\Client::publish($event_name, array( 'content' => $res1, 'to_connection_id' =>$data['friend_id'] )); // 别的还要给本身推条音讯 $msg="您对 ".$data['friendname']."说:".$data['msg']; $res['data']=$msg; $res['type']=1;// 谈天音讯 $res2=json_encode($res); Channel\Client::publish($event_name, array( 'content' => $res2, 'to_connection_id' =>$connection->id )); return; break; default: # code... break; } } $res['type']=1;// 谈天音讯 $res=json_encode($res); // 播送给一切客户端 $event_name = '播送'; Channel\Client::publish($event_name, array( 'content' => $res )); $dsn='mysql:host=127.0.0.1;dbname=kinmoschat;'; $dbh=new PDO($dsn,'root','123456'); $stmt=$dbh->query('SELECT connect_id,username FROM user'); $row=$stmt->fetchAll(); $uerHtml=""; foreach ($row as $key => $value) { $uerHtml.='<a class="user" onclick="userclick(\''.$value['username'].'\',\''.$value['connect_id'].'\');" value="'.$value['connect_id'].'" href="javascript:void(0);">'.$value['username'].'</a><br/>'; } //print_r($row); $res1['type']=2;// 用户音讯 $res1['data']=$uerHtml; $res1=json_encode($res1); $event_name = '播送'; Channel\Client::publish($event_name, array( 'content' => $res1 )); };
这里会将每一个用户的 connectid=>name 存入数据库。。
当收到一条 上线音讯的时刻,播送给一切用户。
收到一条群发音讯。。播送给一切客户端。
收到一条私聊音讯。则单个推送给本身以及发送的人。
监听 客户端封闭事宜,当客户端封闭,删除用户表相干纪录
// 封闭链接 将数据库中的该数据删除 $ws_worker->onClose=function($connection) { //echo 3233; $dsn='mysql:host=127.0.0.1;dbname=kinmoschat;'; $pdo=new PDO($dsn,'root','123456'); $sql="delete from user where connect_id='".$connection->id."'"; //print_r($sql); $pdo->exec($sql); };
更多workerman学问请关注workerman教程栏目。
以上就是运用workerman完成在线谈天的要领的细致内容,更多请关注ki4网别的相干文章!