workerman은 PHP로 작성된 커뮤니케이션 서비스입니다. 이전 프로젝트에서는 데이터 인터페이스 서비스용으로 사용했습니다
이번에는 간단한 온라인 채팅방을 만드는 데 사용했습니다~
1.workererman 최신 버전을 다운로드하세요
http://www.workerman.net에서 다운로드하실 수 있습니다.
관리를 용이하게 하기 위해 서비스와 클라이언트를 두 개의 폴더로 분리했습니다.
일반적인 프로젝트 구조는 다음과 같습니다.
클라이언트:
클라이언트는 간단합니다. 간단한 HTML 코드입니다. 웹소켓 열기, 메시지 모니터링 및 닫기를 구현하기 위해 웹소켓 수신 서비스
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("出现错误");
};
}가 내장되어 있습니다.
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);
}데이터가 다음으로 푸시됩니다. 서버. 유형 =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",'');
});클라이언트가 거의 이렇습니다.
클라이언트에는 여러 가지 함정이 있습니다.
Pit 1. 변수 이름이 name인 경우 웹 페이지를 새로 고칠 때 재설정되지 않고, 그렇지 않으면 재설정됩니다. (정보를 확인해보니 name변수가 window.name이라는 것을 알았습니다. 따라서 웹페이지 새로고침시 값이 갱신되지 않습니다.)
Pit 2. JS 그룹 배열, 변수는 ""를 사용하고 가장 바깥쪽 레이어를 사용해야 합니다. data= '{"type":"1","user":"'+name+'"}'와 같이 ''입니다. 그렇지 않으면 구문 분석 문제가 발생합니다. 다른 방법으로는 할 수 없습니다!
서버:
서버는 주로 작업자 구성 요소이며 채널 분산 통신 구성 요소를 사용하여 구독, 클러스터 푸시, 그룹 푸시 및 개인 채팅을 구현합니다.
첫 번째는 모니터링입니다. 작업자의 웹소켓 모니터링을 활성화합니다.
// 创建一个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";작업자 모니터링이 활성화되면 채널 통신을 등록합니다.
$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));
};여기서 클라이언트가 다시 전화하면 클라이언트의 연결 ID를 수정하겠습니다. 간단한 md5는 주로 일련 ID가 너무 쉽게 악용되는 것을 방지하는 것입니다. .
그 다음은 전체 프로젝트의 본체인 서버측 메시지 처리 콜백입니다.
각 수신 클라이언트에 고유한 ID를 할당합니다
connectid=>user로 관계 테이블을 유지합니다
여러 프로세스가 시작되어 세션에 저장하는 것이 유효하지 않으므로 데이터베이스에 저장할 계획입니다
링크를 열 때 데이터를 삭제하세요
$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=>각 사용자의 이름이 데이터베이스에 저장됩니다. .
온라인 메시지를 받으면 모든 사용자에게 방송됩니다.
그룹 메시지를 받았습니다. . 모든 클라이언트에게 방송합니다.
비공개 메시지를 받았습니다. 그런 다음 자신과 보낸 사람에게 개별적으로 푸시하세요.
클라이언트 종료 이벤트를 들어보세요. 클라이언트가 종료되면 사용자 테이블과 관련된 레코드를 삭제하세요.
// 关闭链接 将数据库中的该数据删除
$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 tutorial 칼럼을 주목해주세요.
위 내용은 Workerman을 사용하여 온라인 채팅을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
