php使用swoole的应用场景有哪些？-PHP问题

php使用swoole的应用场景有：1、实时收集定位数据并实时输出，需要将所有的定位设备实时的接收，将实时的轨迹记录显示在地图上；2、只收集定位设备入库，需要把所有的定位设备上传的数据入库。

场景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[&＃39;server&＃39;][&＃39;host&＃39;], $config[&＃39;server&＃39;][&＃39;port&＃39;]);
    // 连接redis
    $this->redis = new Predis\Client($config[&＃39;redis&＃39;]);
    $this->storage = new Storage($this->config);
    $this->serv->set([
        &＃39;worker_num&＃39;      => $this->config[&＃39;server&＃39;][&＃39;workerNum&＃39;],   //工作进程数量
        &＃39;daemonize&＃39;       => $this->config[&＃39;server&＃39;][&＃39;daemonize&＃39;], //是否作为守护进程
        &＃39;task_worker_num&＃39; => $this->config[&＃39;server&＃39;][&＃39;taskWorkerNum&＃39;],
    ]);
    $this->serv->on(&＃39;connect&＃39;, function ($serv, $fd){
        $this->onConnect($fd, $serv);
    });
    
    $this->serv->on(&＃39;receive&＃39;, function ($serv, $fd, $from_id, $data)  {
        $this->onReceive($fd, $serv, $data);
    });
    $this->serv->on(&＃39;Close&＃39;, function($server, $fd) {
        $this->onClose($fd, $server);
        
    });
    $this->serv->on(&＃39;Task&＃39;, function($server, $task_id, $from_id, $data) {
        $this->onTask($server, $task_id, $from_id, $data);
        
    });
    $this->serv->on(&＃39;Finish&＃39;, 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(&＃39;message:&＃39;.$data);
    $data = $this->formatData($data, $fd);
    $serv->task($data);
}
public function onClose($fd, $serv) 
{
    // writeLog 方法是写入log
    $this->storage->writeLog(&＃39;close fd:&＃39;.$fd);
}
public function onFinish($serv, $task_id, $data)
{
    return &＃39;&＃39;;
}

相关学习推荐：PHP编程从入门到精通

以上就是php使用swoole的应用场景有哪些？的详细内容，更多请关注 第一PHP社区 其它相关文章！