使用workerman實現線上聊天的方法
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實現線上聊天的方法的詳細內容。更多資訊請關注PHP中文網其他相關文章！
熱AI工具
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Undress AI Tool
免費脫衣圖片
Clothoff.io
AI脫衣器
Video Face Swap
使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！
熱門文章
熱工具
記事本++7.3.1
好用且免費的程式碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
強大的PHP整合開發環境
Dreamweaver CS6
視覺化網頁開發工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
實作Workerman文件中的文件上傳與下載
Nov 08, 2023 pm 06:02 PM
實現Workerman文件中的文件上傳與下載，需要具體程式碼範例引言：Workerman是一款高效能的PHP非同步網路通訊框架，具備簡潔、高效、易用等特點。在實際開發中，文件上傳和下載是常見的功能需求，本文將介紹如何使用Workerman框架實現文件的上傳和下載，並給出具體的程式碼範例。一、檔案上傳：檔案上傳是指將本機上的檔案傳輸至伺服器端的操作。下面是使用
如何實作Workerman文件的基本使用方法
Nov 08, 2023 am 11:46 AM
如何實現Workerman文件的基本使用方法簡介：Workerman是一個高效能的PHP開發框架，它可以幫助開發者輕鬆建立高並發的網路應用程式。本文將介紹Workerman的基本使用方法，包括安裝和設定、建立服務和監聽連接埠、處理客戶端請求等。並給出相應的程式碼範例。一、安裝並設定Workerman在命令列中輸入以下命令來安裝Workerman：c
swoole和workerman哪個好
Apr 09, 2024 pm 07:00 PM
Swoole 和 Workerman 都是高效能 PHP 伺服器框架。 Swoole 以其非同步處理、出色的效能和可擴展性而聞名，適用於需要處理大量並發請求和高吞吐量的專案。 Workerman 提供了非同步和同步模式的靈活性，具有直覺的 API，更適合易用性和處理較低並發量的專案。
Workerman開發：如何實現基於UDP協定的即時視訊通話
Nov 08, 2023 am 08:03 AM
Workerman開發：基於UDP協議的即時視訊通話摘要：本文將介紹如何使用Workerman框架實現基於UDP協議的即時視訊通話功能。我們將深入了解UDP協議的特點，並透過程式碼範例展示如何建立一個簡單但完整的即時視訊通話應用程式。引言：在網路通訊中，即時視訊通話是一項非常重要的功能。傳統的TCP協定在實現即時性較高的視訊通話時，可能會有傳輸延遲等問題。而UDP
如何實作Workerman文件中的定時器功能
Nov 08, 2023 pm 05:06 PM
如何實現Workerman文件中的定時器功能Workerman是一款強大的PHP非同步網路通訊框架，它提供了豐富的功能，其中就包括定時器功能。使用定時器可以在指定的時間間隔內執行程式碼，非常適合定時任務、輪詢等應用程式場景。接下來，我將詳細介紹如何在Workerman中實現定時器功能，並提供具體的程式碼範例。第一步：安裝Workerman首先，我們需要安裝Worker
如何使用Workerman建構高可用性負載平衡系統
Nov 07, 2023 pm 01:16 PM
如何使用Workerman建立高可用性負載平衡系統，需要具體程式碼範例在現代技術領域中，隨著網路的快速發展，越來越多的網站和應用程式需要處理大量的並發請求。為了實現高可用性和高效能，負載平衡系統成為了必不可少的組件之一。本文將介紹如何使用PHP開源框架Workerman建構一個高可用性的負載平衡系統，並提供具體的程式碼範例。一、Workerman簡介Worke
如何實現Workerman文件中的反向代理功能
Nov 08, 2023 pm 03:46 PM
如何實現Workerman文件中的反向代理功能，需要具體程式碼範例簡介：Workerman是一款高效能的PHP多進程網路通訊框架，提供了豐富的功能和強大的效能，廣泛應用於Web即時通訊、長連接服務等場景。其中，Workerman也支援反向代理功能，可實現伺服器對外提供服務時的負載平衡和靜態資源快取等功能。本篇文章將介紹如何使用Workerman實現反向代理功
如何實現Workerman文件中的TCP/UDP通信
Nov 08, 2023 am 09:17 AM
如何實現Workerman文件中的TCP/UDP通信，需要具體程式碼範例Workerman是一款高效能的PHP非同步事件驅動框架，廣泛用於實現TCP和UDP通訊。本文將介紹如何使用Workerman實現基於TCP和UDP的通信，並提供相應的程式碼範例。一、TCP通訊創建TCP伺服器使用Workerman建立TCP伺服器十分簡單，只需寫如下程式碼：<?ph
