Heim >PHP-Framework >Workerman >So implementieren Sie einen Online-Chat mit Workerman
So implementieren Sie einen Online-Chat mit Workerman
- 尚nach vorne
- 2019-12-26 17:00:533417Durchsuche
workerman ist ein in PHP geschriebener Kommunikationsdienst. Frühere Projekte haben es für Datenschnittstellendienste verwendet
Dieses Mal habe ich es verwendet, um einen einfachen Online-Chatroom zu erstellen~
1 Laden Sie die neueste Version von Workerman herunter
Sie können loslegen http://www.workerman.net Zum Download gehen
Ich habe Service und Client in zwei Ordner getrennt, um die Verwaltung zu erleichtern
Die allgemeine Projektstruktur ist wie folgt.
Kunde:
Der Kunde ist einfach. Ein einfacher HTML-Code. Eingebettet in einen Websocket-Listening-Dienst
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("出现错误");
};
}, um das Öffnen, die Nachrichtenüberwachung und das Schließen von Websockets zu realisieren
1 Wenn ein Client geöffnet wird, wird sofort ein Dialogfeld zur Eingabe eines Namens angezeigt
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);
}und pushe die Daten an den Server. Typ = 1 steht für Login.
2. Bestimmen Sie beim Empfang einer Nachricht den Nachrichtentyp, ob es sich um eine Gruppennachricht oder eine private Nachricht handelt. Und dann verarbeiten.
Darüber hinaus wird jedes Mal, wenn sich ein neuer Benutzer anmeldet, eine Benutzerliste an jeden Client gesendet. Rendern Sie
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);
}
}und dann gibt es den Code für jeden Benutzer zum Senden von Nachrichten. Es kann ein privater Chat oder eine Gruppennachricht sein
$('#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",'');
});Das ist so ziemlich alles auf dem Client.
Der Client hat mehrere Fallstricke,
Pit 1. Wenn der Variablenname name ist, wird er beim Aktualisieren der Webseite nicht zurückgesetzt, andernfalls wird er zurückgesetzt. (Nachdem ich die Informationen überprüft hatte, stellte ich fest, dass die Namensvariable window.name ist. Daher wird der Wert beim Aktualisieren der Webseite nicht aktualisiert.)
Pit 2. Für das JS-Gruppenarray sollte die Variable „ " und die äußerste Ebene ist '' Zum Beispiel: data='{"type":"1","user":"'+name+'"}'; Andernfalls kommt es zu Problemen beim Parsen. Andersherum geht es nicht!
Serverseite:
Die Serverseite ist hauptsächlich die Worker-Komponente und verwendet die verteilte Kommunikationskomponente des Kanals, um Abonnements, Cluster-Push, Gruppen-Push und privaten Chat zu implementieren.
Zunächst geht es natürlich um die Überwachung, um die Websocket-Überwachung eines Arbeiters zu aktivieren.
// 创建一个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";Wenn die Arbeiter-Mann-Überwachung aktiviert ist, registrieren Sie die Kanalkommunikation.
$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);
}
});
};Registrieren Sie zwei Ereignisse, ein Broadcast-Ereignis, ein privates Chat-Ereignis, eine Übertragung zur Online-Benachrichtigung und eine Gruppennachricht. Privater Chat ist privater Chat. . Hier können Sie auch Gruppenversand durchführen. Diese Version wurde jedoch noch nicht implementiert.
Dann gibt es einen Rückruf für den Client-Link.
$ws_worker->onConnect=function($connection){
$connection->id = md5($connection->id."_".time()."_".rand(10000,99999));
};Hier ruft der Client zurück und ich werde die Verbindungs-ID des Clients ändern. Ein einfacher MD5 dient hauptsächlich dazu, zu verhindern, dass serielle IDs zu leicht ausgenutzt werden. .
Dann der Hauptteil des gesamten Projekts, der Rückruf für die serverseitige Nachrichtenverarbeitung.
Weisen Sie für jeden eingehenden Kunden eine eindeutige ID zu.
Behalten Sie eine Beziehungstabelle mit connectid=>Benutzer bei.
Da mehrere Prozesse geöffnet werden, wird sie in der Sitzung gespeichert ungültig, daher ist eine Speicherung in der Datenbank geplant
Wenn die Verbindung getrennt wird, löschen Sie die Daten
$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
));
};Hier wird der connectid=>name jedes Benutzers in der Datenbank gespeichert. .
Wenn Sie eine Online-Nachricht erhalten, senden Sie diese an alle Benutzer.
Eine Gruppennachricht erhalten. . An alle Kunden senden.
Private Nachricht erhalten. Schicken Sie es dann einzeln an sich selbst und die Person, die es gesendet hat.
Hören Sie sich das Client-Schließereignis an und löschen Sie die relevanten Datensätze in der Benutzertabelle.
// 关闭链接 将数据库中的该数据删除
$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);
};Für weitere Workerman-Kenntnisse beachten Sie bitte das Workerman-Tutorial Spalte.
Das obige ist der detaillierte Inhalt vonSo implementieren Sie einen Online-Chat mit Workerman. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!