PHP+swoole은 그룹 채팅 기능을 구현합니다.-PHP 튜토리얼-php.cn

PHP+swoole은 그룹 채팅 기능을 구현합니다.

墨辰丷

풀어 주다： 2023-03-29 19:38:01

원래의

2879명이 탐색했습니다.

이 글은 그룹 채팅 기능을 구현하기 위해 주로 PHP+swoole을 소개합니다. 관심 있는 친구들이 참고하면 도움이 될 것입니다.

php 코드:

$serv = new swoole_websocket_server("127.0.0.1",3999);
//服务的基本设置
$serv->set(array(
&#39;worker_num&#39; => 2,
&#39;reactor_num&#39;=>8,
&#39;task_worker_num&#39;=>1,
&#39;dispatch_mode&#39; => 2,
&#39;debug_mode&#39;=> 1,
&#39;daemonize&#39; => true,
&#39;log_file&#39; => __DIR__.&#39;/log/webs_swoole.log&#39;,
&#39;heartbeat_check_interval&#39; => 60,
&#39;heartbeat_idle_time&#39; => 600,
));
$serv->on(&#39;connect&#39;, function ($serv,$fd){
// echo "client:$fd Connect.".PHP_EOL;
});
//测试receive
$serv->on("receive",function(swoole_server $serv,$fd,$from_id,$data){
// echo "receive#{$from_id}: receive $data ".PHP_EOL;
});
$serv->on(&#39;open&#39;, function($server, $req) {
// echo "server#{$server->worker_pid}: handshake success with fd#{$req->fd}".PHP_EOL;;
// echo PHP_EOL;
});
$serv->on(&#39;message&#39;,function($server,$frame) {
// echo "message: ".$frame->data.PHP_EOL;
$msg=json_decode($frame->data,true);
switch ($msg[&#39;type&#39;]){
case &#39;login&#39;:
$server->push($frame->fd,"欢迎欢迎~");
break;
default:
break;
}
$msg[&#39;fd&#39;]=$frame->fd;
$server->task($msg);
});
$serv->on("workerstart",function($server,$workerid){
// echo "workerstart: ".$workerid.PHP_EOL;
// echo PHP_EOL;
});
$serv->on("task","on_task");
$serv->on("finish",function($serv,$task_id,$data){
return ;
});
$serv->on(&#39;close&#39;, function($server,$fd,$from_id) {
// echo "connection close: ".$fd.PHP_EOL;
// echo PHP_EOL;
});
$serv->start();
function on_task($serv,$task_id,$from_id,$data) {
switch ($data[&#39;type&#39;]){
case &#39;login&#39;:
$send_msg="说:我来了~";
break;
default:
$send_msg="说:{$data[&#39;msg&#39;][&#39;speak&#39;]}";
break;
}
foreach ($serv->connections as $conn){
if ($conn!=$data[&#39;fd&#39;]){
if (strpos($data[&#39;msg&#39;][&#39;name&#39;],"游客")===0){
$name=$data[&#39;msg&#39;][&#39;name&#39;]."_".$data[&#39;fd&#39;];
}else{
$name=$data[&#39;msg&#39;][&#39;name&#39;];
}
}else{
$name="我";
}
$serv->push($conn,$name.$send_msg);
}
return;
}
function on_finish($serv,$task_id,$data){
return true;
}

로그인 후 복사

프런트 엔드 코드:

<!DOCTYPE html>
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>WebSocket测试</title> 
<script language="javascript"type="text/javascript" src="jquery-1.12.0.min.js"> 
</script>
</head>
<body>
<h2>WebSocket Test</h2> 
昵称：<input type="text" id="name" size="5" value="游客"/> <input type="text" id="content"> 
<button onclick="speak_to_all()">发送</button>
<br/><br/>
<textarea id="message" style="overflow-x:hidden" rows="10" cols="50"></textarea> 
<p id="output"></p>
</body> 
<script language="javascript"type="text/javascript"> 
var wsUri ="ws://127.0.0.1:3999/"; 
var output; 
function init() { 
output = document.getElementById("output"); 
testWebSocket();
}
function testWebSocket() { 
websocket = new WebSocket(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) 
}; 
}
function get_speak_msg(){
var name=document.getElementById("name").value;
var speak=document.getElementById("content").value;
var json_msg=&#39;{"name":"&#39;+name+&#39;","speak":\"&#39;+speak+&#39;"}&#39;;
return json_msg;
}
function pack_msg(type,msg){
return &#39;{"type":"&#39;+type+&#39;","msg":&#39;+msg+&#39;}&#39;;
}
function onOpen(evt) {
append_speak("已经联通服务器.........");
speak_msg=get_speak_msg();
send_msg=pack_msg("login",speak_msg);
doSend(send_msg);
}
function onClose(evt) { 
append_speak("俺老孙去也！");
} 
function onMessage(evt) {
append_speak(evt.data);
}
function onError(evt) {
alert(evt.data);
}
function doSend(message) { 
websocket.send(message);
}
function append_speak(new_msg){
document.getElementById("message").value=document.getElementById("message").value+new_msg+"\n";
document.getElementById(&#39;message&#39;).scrollTop = document.getElementById(&#39;message&#39;).scrollHeight;
}
function speak_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 모듈 설치에 대한 자세한 단계별 튜토리얼

PHP 이메일 확인 예제에 대한 자세한 설명

PHP 파일 작업 방법 및 예제에 대한 자세한 설명

위 내용은 PHP+swoole은 그룹 채팅 기능을 구현합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!