怎么使用workerman實(shí)現(xiàn)在線聊天
這篇文章主要介紹怎么使用workerman實(shí)現(xiàn)在線聊天，文中介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們一定要看完！
按需網(wǎng)站建設(shè)可以根據(jù)自己的需求進(jìn)行定制，網(wǎng)站制作、做網(wǎng)站構(gòu)思過程中功能建設(shè)理應(yīng)排到主要部位公司網(wǎng)站制作、做網(wǎng)站的運(yùn)用實(shí)際效果公司網(wǎng)站制作網(wǎng)站建立與制做的實(shí)際意義
workerman 是一個php編寫的通訊服務(wù)。之前的項(xiàng)目都是用它做數(shù)據(jù)接口服務(wù)
這次用它做一個簡單的在線聊天室~
1.下載最新版本的workerman
可以去http://www.workerman.net 去下載
我這里將service 和 client 分開了兩個文件夾，方便管理
大致的項(xiàng)目結(jié)構(gòu)如下。
客戶端：
客戶端就簡單了。一個簡單的html代碼。嵌入了一個 websocket 監(jiān)聽服務(wù)
var ws, name, client_list={};
function connect() {
// 創(chuàng)建websocket
ws = new WebSocket("ws://192.168.0.88:2345");
// 當(dāng)socket連接打開時，輸入用戶名
ws.onopen = onopen;
// 當(dāng)有消息時根據(jù)消息類型顯示不同信息
ws.onmessage = onmessage;
ws.onclose = function() {
console.log("連接關(guān)閉，定時重連");
connect();
};
ws.onerror = function() {
console.log("出現(xiàn)錯誤");
};
}實(shí)現(xiàn)websocket的 打開，message的監(jiān)聽，以及close
1、當(dāng)打開一個客戶端，則立馬彈出一個輸入姓名的對話框
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);
}并將數(shù)據(jù)推送給服務(wù)端。type =1 代表登陸。
2、當(dāng)收到消息時，判斷消息類型，是群發(fā)消息 還是私聊消息。進(jìn)而處理。
另外，每次用戶有新用戶登陸上來，都會 給各個客戶端推送，用戶列表。進(jìn)行渲染
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);
}
}然后另外就是 每個用戶發(fā)送消息的代碼了?？梢允撬搅?，也可以是群發(fā)
$('#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 則刷新網(wǎng)頁不會被重置，否則就會被重置。（后面查資料發(fā)現(xiàn)，這個name變量 是 window.name 。所以刷新網(wǎng)頁 該值也不會被刷新掉）
坑2、js組數(shù)組，變量要用"" 最外層為'' 如：data='{"type":"1","user":"'+name+'"}'; 否則解析出問題。不能倒過來！
服務(wù)端：
服務(wù)端主要是workerman 組件 以及 使用 Channel分布式通訊組件 實(shí)現(xiàn)訂閱 和集群推送 分組推送 以及私聊。
首先，當(dāng)然是監(jiān)聽，啟用一個worker的websocket監(jiān)聽
// 創(chuàng)建一個Worker監(jiān)聽2346端口，使用websocket協(xié)議通訊
$ws_worker = new Worker("websocket://0.0.0.0:2345");
$channel_server = new Channel\Server('0.0.0.0', 2206);
// 啟動4個進(jìn)程對外提供服務(wù)
$ws_worker->count = 4;
$ws_worker->name="kinmoschat";在workerman 監(jiān)聽啟用的時候，進(jìn)行 channel通訊的注冊。
$ws_worker->onWorkerStart=function($ws_worker)
{
// channel 客戶端鏈接上 服務(wù)器
Channel\Client::connect('127.0.0.1',2206);
$event_name='私聊';
// 訂閱 worker-<id 事件，并注冊事件處理函數(shù)
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 = '廣播';
// 收到廣播 向所有客戶端發(fā)送消息
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);
}
});
};注冊兩個事件，一個廣播事件，一個私聊事件，用以上線通知的廣播，以及群發(fā)消息。私聊 就是私聊了。。這里，還可以做 分組的群發(fā)。不過，這個版本還未實(shí)現(xiàn)。
然后是針對，客戶端鏈接的回調(diào)。
$ws_worker->onConnect=function($connection){
$connection->id = md5($connection->id."_".time()."_".rand(10000,99999));
};這里，客戶端回調(diào)，我會將客戶端的 connectid修改掉。一個簡單的md5 主要是為了防止 流水id太容易被利用吧。。
然后，整個項(xiàng)目的主體，服務(wù)端消息的處理回調(diào)。
針對每個進(jìn)來的客戶端，分配一個唯一 id
維護(hù)一個 connectid=>user 的關(guān)系表
由于開啟了多個進(jìn)程導(dǎo)致 存到 session中無效，故而 打算存到 數(shù)據(jù)庫中
斷開鏈接的時候，刪除數(shù)據(jù)
$ws_worker->onMessage = function($connection, $data)
{
$res=array('code'=>200, 'msg'=>'ok', 'data'=>null,'type'=>1);
// 向客戶端發(fā)送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;
}
// 維護(hù)一個數(shù)組 保存 用戶 connection_id => user
$dsn='MySQL:host=127.0.0.1;dbname=kinmoschat;';
$pdo=new PDO($dsn,'root','123456');
//準(zhǔn)備SQL語句
$sql = "INSERT INTO `user`(`connect_id`,`username`) VALUES (:connect_id,:username)";
//調(diào)用prepare方法準(zhǔn)備查詢
$stmt = $pdo->prepare($sql);
//傳遞一個數(shù)組為預(yù)處理查詢中的命名參數(shù)綁定值，并執(zhí)行SQL
$stmt->execute(array(':connect_id' => $connection->id,':username' => $data['user']));
//獲取最后一個插入數(shù)據(jù)的ID值
//echo $pdo->lastInsertId() . '<br />';
// 向自己推送一條消息
$res2['type']=3;// 系統(tǒng)信息
$res2['data']=array('userinfo' =>$data['user']);// 系統(tǒng)信息
$connection->send(json_encode($res2));
$msg="用戶 ".$data['user']." 上線了~~";
$res['data']=$msg;
break;
case '2': // 客戶端群發(fā)送消息
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 存入數(shù)據(jù)庫。。
當(dāng)收到一條 上線消息的時候，廣播給所有用戶。
收到一條群發(fā)消息。。廣播給所有客戶端。
收到一條私聊消息。則單個推送給自己以及發(fā)送的人。
監(jiān)聽 客戶端關(guān)閉事件，當(dāng)客戶端關(guān)閉，刪除用戶表相關(guān)記錄
// 關(guān)閉鏈接 將數(shù)據(jù)庫中的該數(shù)據(jù)刪除
$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實(shí)現(xiàn)在線聊天”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對大家有幫助，更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！
網(wǎng)站欄目：怎么使用workerman實(shí)現(xiàn)在線聊天
網(wǎng)頁鏈接：http://bm7419.com/article0/phdsoo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站建設(shè)、網(wǎng)站維護(hù)、品牌網(wǎng)站建設(shè)、服務(wù)器托管、全網(wǎng)營銷推廣、
聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)
- 手機(jī)網(wǎng)站建設(shè)如何留住用戶？ 2022-05-25
- 手機(jī)端網(wǎng)頁設(shè)計需要注意哪些細(xì)節(jié)問題 2016-08-06
- 手機(jī)網(wǎng)站建設(shè)的幾個注意事項(xiàng) 2021-05-27
- 手機(jī)端網(wǎng)站推廣開啟速度慢的原因分析 2016-08-30
- 手機(jī)網(wǎng)站——企業(yè)建站的不二之選 2016-10-07
- 成都網(wǎng)站建設(shè)公司讓手機(jī)網(wǎng)站和電腦網(wǎng)站數(shù)據(jù)同步的方法有哪些？ 2016-11-01
- 建設(shè)手機(jī)網(wǎng)站和電腦端網(wǎng)站有何不同 2016-11-07
- 創(chuàng)建手機(jī)網(wǎng)站應(yīng)該需要注意什么 2016-05-01
- 也許你的手機(jī)網(wǎng)站建設(shè)就出了這些問題！ 2022-06-09
- 華為開發(fā)自有系統(tǒng)是怎么回事? 華為自有手機(jī)系統(tǒng)有什么特點(diǎn)？ 2016-08-19
- 建站大神帶你了解手機(jī)網(wǎng)站建設(shè)技巧 2021-05-29
- 合肥手機(jī)網(wǎng)站建設(shè)（移動端）需要考慮哪些問題？ 2022-05-01