php使用swoole的应用场景有：1、实时收集定位数据并实时输出，需要将所有的定位设备实时的接收，将实时的轨迹记录显示在地图上；2、只收集定位设备入库，需要把所有的定位设备上传的数据入库。
场景1 - 实时收集定位数据实时输出（例 滴滴司机行驶轨迹）
说明：
需要将所有的定位设备实时的接收，将实时的轨迹记录显示在地图上
立即学习“PHP免费学习笔记（深入）”；
注意点：
第一点：
web1服务器 连接的用户1,2,3，web1广播信息时只能广播用户1，2，3,不能广播web2连接的用户4，5，6，假设场景是聊天，用户1发送一消息，只有web1 服务器的用户能看到，web2的用户全部不能收到
第二点：消息的频率控制，例：100个设备，100个用户， 100个设备每秒上传一条数据，需要实时广播给每个用户，就是每秒要100*100 = 1W次，所以可以汇总每秒数据广播给所有用户等等方法
phpweb1.0基于php+mysql+smarty开发的企业解决方案,总体感觉简洁快速,适合小型企业的建站方案，也适合初学者学习。 之前发布过phpweb1.0的原始版本,仅提供大家交流和学习,但很多的爱好者提出了一些不足和好评,本不想继续开发1.0,因为2.0已经开发完毕而且构架与1.0完全不同,但是有些使用者喜欢这种简洁和简便，应大家的要求,美化和优化了一些不足之处。后台更加简洁美观。
场景2 - 只收集定位设备入库
说明：需要把所有的定位设备上传的数据入库，设备7个，每秒一条数据，个人使用swoole 的task 函数（投递一个异步的任务到 task_worker池中，此函数是非阻塞的， worker进程数同样可以配置） 后调用接口方式入库
服务器内存报警问题
原因： 在于swoole_server->task 函数
官方介绍task底层使用Unix Socket管道通信，是全内存的，没有IO消耗。单进程读写性能可达100万/s，不同的进程使用不同的管道通信，可以最大化利用多核。
但这任务如果是调用程序接口时，由于网络的延迟，增加的任务大于消费的任务时，内存占用会不断的增加，导致服务器的内存被占满。
解决方法：消息针对入任务的频率控制，可以根据自己的业务场景定义这个时间与是否可延迟等情况，汇总1秒内的所有数据再调用程序接口（汇总时个人使用redis），最好能直接入库，不必调用接口
简单代码片段
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 '';
}相关学习推荐：PHP编程从入门到精通
