PHP+swoole implémente la fonction de discussion de groupe-tutoriel php-php.cn

PHP+swoole implémente la fonction de discussion de groupe

墨辰丷

Libérer： 2023-03-29 19:38:01

original

2871 Les gens l'ont consulté

Cet article présente principalement PHP+swoole pour implémenter la fonction de discussion de groupe. Les amis intéressés peuvent s'y référer. J'espère qu'il sera utile à tout le monde.

Code 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;
}

Copier après la connexion

Code frontal :

<!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>

Copier après la connexion

Résumé : Ce qui précède est l'intégralité du contenu de cet article, j'espère qu'il sera utile à l'étude de chacun.

Recommandations associées :

Tutoriel détaillé étape par étape sur l'installation modulaire PHP

PHP Explication détaillée des exemples de vérification des e-mails

Explication détaillée des méthodes et exemples de fonctionnement des fichiers php

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!