下面本篇文章主要给大家介绍一下PHP+swoole如何实现简单多人在线聊天群发，有一定的参考价值，有需要的朋友可以参考一下，希望对你有所帮助。

由于本文的能力有限，有好多聊天逻辑的细节没有实现，只实现了群发，具体代码如下所示：

php代码：$serv = new swoole_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:$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('open', function($server, $req) {

// echo "server#{$server->worker_pid}: handshake success with fd#{$req->fd}".PHP_EOL;;

// echo PHP_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;

// echo PHP_EOL;

});

$serv->on("task","on_task");

$serv->on("finish",function($serv,$task_id,$data){

return ;

});

$serv->on('close', 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['type']){

case 'login':

$send_msg="说:我来了~";

break;

default:

$send_msg="说:{$data['msg']['speak']}";

break;

}

foreach ($serv->connections as $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;

}

function on_finish($serv,$task_id,$data){

return true;

}

前端代码：

WebSocket测试

WebSocket Test

昵称：

发送

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='{"name":"'+name+'","speak":\"'+speak+'"}';

return json_msg;

}

function pack_msg(type,msg){

return '{"type":"'+type+'","msg":'+msg+'}';

}

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('message').scrollTop = document.getElementById('message').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();

相关视频教程推荐：《PHP教程》

本文转载于：脚本之家，如有侵犯，请联系a@php.cn删除