面试官问我swoole的应用场景,我懵了!
应用场景简介
- 与硬件设备连接通讯(定位设备)
- IM系统(用于直播页面的聊天通讯)
场景1 - 实时收集定位数据实时输出(例 滴滴司机行驶轨迹)
说明:
需要将所有的定位设备实时的接收,将实时的轨迹记录显示在地图上
注意点:
第一点:
web1服务器 连接的用户1,2,3,web1广播信息时只能广播用户1,2,3,不能广播web2连接的用户4,5,6,假设场景是聊天,用户1发送一消息,只有web1 服务器的用户能看到,web2的用户全部不能收到
在这里插入图片描述第二点:消息的频率控制,例:100个设备,100个用户, 100个设备每秒上传一条数据,需要实时广播给每个用户,就是每秒要100*100 = 1W次,所以可以汇总每秒数据广播给所有用户等等方法
数据传输的流程图:
不包含业务逻辑,将web1,web2,接收的消息汇总然后再广播给web1,web2,再广播给用户
image场景2 - 只收集定位设备入库
说明: 需要把所有的定位设备上传的数据入库,设备7个,每秒一条数据,个人使用swoole 的task 函数(投递一个异步的任务到 task_worker池中,此函数是非阻塞的, worker进程数同样可以配置) 后调用接口方式入库
服务器内存报警问题
原因: 在于swoole_server->task 函数
官方介绍task底层使用Unix Socket管道通信,是全内存的,没有IO消耗。单进程读写性能可达100万/s,不同的进程使用不同的管道通信,可以最大化利用多核。
但这任务如果是调用程序接口时,由于网络的延迟,增加的任务大于消费的任务时,内存占用会不断的增加,导致服务器的内存被占满。
解决方法:消息针对入任务的频率控制,可以根据自己的业务场景定义这个时间与是否可延迟等情况,汇总1秒内的所有数据再调用程序接口(汇总时个人使用redis),最好能直接入库,不必调用接口
简单代码片段,不全(供初学者了解,官方网站demo相似)
function __construct($config)
{
$this->config = $config;
$this->serv = new Swoole\Server($config['server']['host'], $config['server']['port']);
// 连接redis
$this->redis = new Predis\Client($config['redis']);
$this->storage = new Storage($this->config);
$this->serv->set([
'worker_num' => $this->config['server']['workerNum'], //工作进程数量
'daemonize' => $this->config['server']['daemonize'], //是否作为守护进程
'task_worker_num' => $this->config['server']['taskWorkerNum'],
]);
$this->serv->on('connect', function ($serv, $fd){
$this->onConnect($fd, $serv);
});
$this->serv->on('receive', function ($serv, $fd, $from_id, $data) {
$this->onReceive($fd, $serv, $data);
});
$this->serv->on('Close', function($server, $fd) {
$this->onClose($fd, $server);
});
$this->serv->on('Task', function($server, $task_id, $from_id, $data) {
$this->onTask($server, $task_id, $from_id, $data);
});
$this->serv->on('Finish', function($server, $task_id, $data) {
$this->onFinish($server, $task_id, $data);
});
$this->serv->start();
}
public function onTask($serv, $task_id, $from_id, $data){
// insert 方法是通过接口入库
$this->storage->insert($data);
}
public function onReceive($fd, $serv, $data)
{
$this->storage->writeLog('message:'.$data);
$data = $this->formatData($data, $fd);
$serv->task($data);
}
public function onClose($fd, $serv)
{
// writeLog 方法是写入log
$this->storage->writeLog('close fd:'.$fd);
}
public function onFinish($serv, $task_id, $data)
{
return '';
}
场景-IM系统
参考官方github: webim系统.
官方wiki: swoole 框架wiki
好处:
- 封装了数据库的model类,数据库的ORM接口
- redis的封装,可以实现多实例访问
- 框架有一些常用的方法,像log 等等(我只用到了log)
- webim 官方有demon,可以参考
坏处:
- 文档特别不全,一个简单的实现会折腾半天
点关注,不迷路
好了各位,以上就是这篇文章的全部内容了,能看到这里的人呀,都是人才。之前说过,PHP方面的技术点很多,也是因为太多了,实在是写不过来,写过来了大家也不会看的太多,所以我这里把它整理成了PDF和文档,如果有需要的可以
在这里插入图片描述 在这里插入图片描述更多学习内容可以访问【对标大厂】精品PHP架构师教程目录大全,只要你能看完保证薪资上升一个台阶(持续更新)
以上内容希望帮助到大家,很多PHPer在进阶的时候总会遇到一些问题和瓶颈,业务代码写多了没有方向感,不知道该从那里入手去提升,对此我整理了一些资料,包括但不限于:分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6,laravel,YII2,Redis,Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货需要的可以免费分享给大家,需要的可以加入我的 PHP技术交流群