PHP+swoole实现简单多人在线聊天群发
由于本文的能力有限，有好多聊天逻辑的细节没有实现，只实现了群发，具体代码如下所示：
php代码：
$serv=newswoole_websocket_server("127.0.0.1",3999);
//服务的基本设置
$serv->set(array(
'worker_num'=>2,
'reactor_num'=>8,
'task_worker_num'=>1,
'dispatch_mode'=>2,
'debug_mode'=>1,
'daemonize'=>true,
'log_file'=>__DIR__.'/log/webs_swoole.log',
'heartbeat_check_interval'=>60,
'heartbeat_idle_time'=>600,
));
$serv->on('connect',function($serv,$fd){
//echo"client:$fdConnect.".PHP_EOL;
});
//测试receive
$serv->on("receive",function(swoole_server$serv,$fd,$from_id,$data){
//echo"receive#{$from_id}:receive$data".PHP_EOL;
});
$serv->on('open',function($server,$req){
//echo"server#{$server->worker_pid}:handshakesuccesswithfd#{$req->fd}".PHP_EOL;;
//echoPHP_EOL;
});
$serv->on('message',function($server,$frame){
//echo"message:".$frame->data.PHP_EOL;
$msg=json_decode($frame->data,true);
switch($msg['type']){
case'login':
$server->push($frame->fd,"欢迎欢迎~");
break;
default:
break;
}
$msg['fd']=$frame->fd;
$server->task($msg);
});
$serv->on("workerstart",function($server,$workerid){
//echo"workerstart:".$workerid.PHP_EOL;
//echoPHP_EOL;
});
$serv->on("task","on_task");
$serv->on("finish",function($serv,$task_id,$data){
return;
});
$serv->on('close',function($server,$fd,$from_id){
//echo"connectionclose:".$fd.PHP_EOL;
//echoPHP_EOL;
});
$serv->start();
functionon_task($serv,$task_id,$from_id,$data){
switch($data['type']){
case'login':
$send_msg="说:我来了~";
break;
default:
$send_msg="说:{$data['msg']['speak']}";
break;
}
foreach($serv->connectionsas$conn){
if($conn!=$data['fd']){
if(strpos($data['msg']['name'],"游客")===0){
$name=$data['msg']['name']."_".$data['fd'];
}else{
$name=$data['msg']['name'];
}
}else{
$name="我";
}
$serv->push($conn,$name.$send_msg);
}
return;
}
functionon_finish($serv,$task_id,$data){
returntrue;
}
前端代码：
<!DOCTYPEhtmlPUBLIC"-//W3C//DTDHTML4.01Transitional//EN""http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<metahttp-equiv="Content-Type"content="text/html;charset=UTF-8">
<title>WebSocket测试</title>
<scriptlanguage="javascript"type="text/javascript"src="jquery-1.12.0.min.js">
</script>
</head>
<body>
<h2>WebSocketTest</h2>
昵称：<inputtype="text"id="name"size="5"value="游客"/><inputtype="text"id="content">
<buttononclick="speak_to_all()">发送</button>
<br/><br/>
<textareaid="message"style="overflow-x:hidden"rows="10"cols="50"></textarea>
<divid="output"></div>
</body>
<scriptlanguage="javascript"type="text/javascript">
varwsUri="ws://127.0.0.1:3999/";
varoutput;
functioninit(){
output=document.getElementById("output");
testWebSocket();
}
functiontestWebSocket(){
websocket=newWebSocket(wsUri);
websocket.onopen=function(evt){
onOpen(evt)
};
websocket.onclose=function(evt){
onClose(evt)
};
websocket.onmessage=function(evt){
onMessage(evt)
};
websocket.onerror=function(evt){
onError(evt)
};
}
functionget_speak_msg(){
varname=document.getElementById("name").value;
varspeak=document.getElementById("content").value;
varjson_msg='{"name":"'+name+'","speak":\"'+speak+'"}';
returnjson_msg;
}
functionpack_msg(type,msg){
return'{"type":"'+type+'","msg":'+msg+'}';
}
functiononOpen(evt){
append_speak("已经联通服务器.........");
speak_msg=get_speak_msg();
send_msg=pack_msg("login",speak_msg);
doSend(send_msg);
}
functiononClose(evt){
append_speak("俺老孙去也！");
}
functiononMessage(evt){
append_speak(evt.data);
}
functiononError(evt){
alert(evt.data);
}
functiondoSend(message){
websocket.send(message);
}
functionappend_speak(new_msg){
document.getElementById("message").value=document.getElementById("message").value+new_msg+"\n";
document.getElementById('message').scrollTop=document.getElementById('message').scrollHeight;
}
functionspeak_to_all(){
send_msg=pack_msg("speak",get_speak_msg());
if(document.getElementById("content").value==""){
return;
}
doSend(send_msg);
document.getElementById("content").value="";
}
init();
</script>
</html>
推荐文章：php安装swoole扩展的方法 使用swoole扩展phpwebsocket示例
以上代码给大家分享了PHP+swoole实现简单多人在线聊天群发的相关代码，希望本文所述对大家有所帮助。