• 技术文章 >后端开发 >PHP问题

    php使用swoole的应用场景有哪些?

    coldplay.xixicoldplay.xixi2020-07-01 16:41:57原创88

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

    php使用swoole的应用场景有:

    场景1 - 实时收集定位数据实时输出(例 滴滴司机行驶轨迹)

    说明:

    需要将所有的定位设备实时的接收,将实时的轨迹记录显示在地图上

    注意点:

    第一点:

    web1服务器 连接的用户1,2,3,web1广播信息时只能广播用户1,2,3,不能广播web2连接的用户4,5,6,假设场景是聊天,用户1发送一消息,只有web1 服务器的用户能看到,web2的用户全部不能收到

    第二点:消息的频率控制,例:100个设备,100个用户, 100个设备每秒上传一条数据,需要实时广播给每个用户,就是每秒要100*100 = 1W次,所以可以汇总每秒数据广播给所有用户等等方法

    2f08f5f6a61d57579d2158fbf7309f5.png

    场景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编程从入门到精通

    以上就是php使用swoole的应用场景有哪些?的详细内容,更多请关注php中文网其它相关文章!

    本文原创发布php中文网,转载请注明出处,感谢您的尊重!
    专题推荐:php swoole
    上一篇:traits与interfaces有什么区别? 下一篇:PHP数组的底层实现原理是什么?
    第12期线上周末培训班

    相关文章推荐

    • PHP swoole怎么用• php Swoole实现毫秒级定时任务• PHP Swoole长连接常见问题总结• PHP Swoole 基本使用

    全部评论我要评论

  • 取消发布评论发送
  • 1/1

    PHP中文网