PHP+swoole实现聊天群发功能

2021-05-02 17:28

阅读:644

YPE html>

标签:one   优化   ofo   follow   tor   并发   swoole   laravel   new   

本篇文章主要介绍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

昵称:

总结:以上就是本篇文的全部内容,希望能对大家的学习有所帮助。

以上内容希望帮助到大家,很多PHPer在进阶的时候总会遇到一些问题和瓶颈,业务代码写多了没有方向感,不知道该从那里入手去提升,对此我整理了一些资料,包括但不限于:分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6,laravel,YII2,Redis,Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货需要的可以免费分享给大家,需要的可以加入我的官方群点击此处。

PHP+swoole实现聊天群发功能

标签:one   优化   ofo   follow   tor   并发   swoole   laravel   new   

原文地址:https://www.cnblogs.com/a609251438/p/12127505.html


评论


亲,登录后才可以留言!