资讯专栏INFORMATION COLUMN

Swoole Task 的应用

邹立鹏 / 1642人阅读

摘要:概述这是关于学习的第二篇文章的应用。第一篇的应用异步,主要实现调用异步任务的执行。的实现方式是进程处理数据请求,分配给进程执行。单进程读写性能可达万,不同的进程使用不同的管道通信,可以最大化利用多核。

概述

这是关于 Swoole 学习的第二篇文章:Swoole Task 的应用。

第一篇:Swoole Timer 的应用

Swoole 异步Task,主要实现调用异步任务的执行。

常用的场景:异步支付处理、异步订单处理、异步日志处理、异步发送邮件/短信等。

Swoole 的实现方式是 worker 进程处理数据请求,分配给 task 进程执行。

官方介绍:

task 底层使用Unix Socket管道通信,是全内存的,没有IO消耗。单进程读写性能可达100万/s,不同的进程使用不同的管道通信,可以最大化利用多核。

本地版本:PHP 7.2.6、Swoole 4.3.1。

不多说,先看效果图:

代码 server.php
serv = new swoole_server("0.0.0.0", 9501);
        $this->serv->set([
            "worker_num"      => 2, //开启2个worker进程
            "max_request"     => 4, //每个worker进程 max_request设置为4次
            "task_worker_num" => 4, //开启4个task进程
            "dispatch_mode"   => 2, //数据包分发策略 - 固定模式
        ]);

        $this->serv->on("Start", [$this, "onStart"]);
        $this->serv->on("Connect", [$this, "onConnect"]);
        $this->serv->on("Receive", [$this, "onReceive"]);
        $this->serv->on("Close", [$this, "onClose"]);
        $this->serv->on("Task", [$this, "onTask"]);
        $this->serv->on("Finish", [$this, "onFinish"]);

        $this->serv->start();
    }

    public function onStart($serv) {
        echo "#### onStart ####".PHP_EOL;
        echo "SWOOLE ".SWOOLE_VERSION . " 服务已启动".PHP_EOL;
        echo "master_pid: {$serv->master_pid}".PHP_EOL;
        echo "manager_pid: {$serv->manager_pid}".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onConnect($serv, $fd) {
        echo "#### onConnect ####".PHP_EOL;
        echo "客户端:".$fd." 已连接".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onReceive($serv, $fd, $from_id, $data) {
        echo "#### onReceive ####".PHP_EOL;
        echo "worker_pid: {$serv->worker_pid}".PHP_EOL;
        echo "客户端:{$fd} 发来的Email:{$data}".PHP_EOL;
        $param = [
            "fd"    => $fd,
            "email" => $data
        ];
        $rs = $serv->task(json_encode($param));
        if ($rs === false) {
            echo "任务分配失败 Task ".$rs.PHP_EOL;
        } else {
            echo "任务分配成功 Task ".$rs.PHP_EOL;
        }
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onTask($serv, $task_id, $from_id, $data) {
        echo "#### onTask ####".PHP_EOL;
        echo "#{$serv->worker_id} onTask: [PID={$serv->worker_pid}]: task_id={$task_id}".PHP_EOL;

        //业务代码
        for($i = 1 ; $i <= 5 ; $i ++ ) {
            sleep(2);
            echo "Task {$task_id} 已完成了 {$i}/5 的任务".PHP_EOL;
        }

        $data_arr = json_decode($data, true);
        $serv->send($data_arr["fd"] , "Email:".$data_arr["email"].",发送成功");
        $serv->finish($data);
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onFinish($serv,$task_id, $data) {
        echo "#### onFinish ####".PHP_EOL;
        echo "Task {$task_id} 已完成".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onClose($serv, $fd) {
        echo "Client Close.".PHP_EOL;
    }
}

$server = new Server();
client.php
client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);

        $this->client->on("Connect", [$this, "onConnect"]);
        $this->client->on("Receive", [$this, "onReceive"]);
        $this->client->on("Close", [$this, "onClose"]);
        $this->client->on("Error", [$this, "onError"]);
    }

    public function connect() {
        if(!$fp = $this->client->connect("127.0.0.1", 9501 , 1)) {
            echo "Error: {$fp->errMsg}[{$fp->errCode}]".PHP_EOL;
            return;
        }
    }

    public function onConnect($cli) {
        fwrite(STDOUT, "输入Email:");
        swoole_event_add(STDIN, function() {
            fwrite(STDOUT, "输入Email:");
            $msg = trim(fgets(STDIN));
            $this->send($msg);
        });
    }

    public function onReceive($cli, $data) {
        echo PHP_EOL."Received: ".$data.PHP_EOL;
    }

    public function send($data) {
        $this->client->send($data);
    }

    public function onClose($cli) {
        echo "Client close connection".PHP_EOL;
    }

    public function onError() {

    }
}

$client = new Client();
$client->connect();
小结

一、上面的配置总共开启了几个进程?

总共8个进程(1个master进程、1个manager进程、4个task进程、2个worker进程)

重新运行的可能与上图进程号不一致:

master进程:22481

manager进程:22485

task进程:22488、22489、22490、22491

worker进程:22492、22493

参考官方提供的进程图:

二、为什么执行了5次后,worker进程号发生了改变?

因为我们设了置worker进程的max_request=4,一个worker进程在完成最大请求次数任务后将自动退出,进程退出会释放所有的内存和资源,这样的机制主要是解决PHP进程内存溢出的问题。

三、当task执行任务异常,我们kill一个task进程,会再新增一个吗?

会。

四、如何设置 task_worker_num ?

最大值不得超过 SWOOLE_CPU_NUM * 1000。

查看本机 CPU 核数:

echo "swoole_cpu_num:".swoole_cpu_num().PHP_EOL;

根据项目的任务量决定的,比如:1秒会产生200个任务,执行每个任务需要500ms。

想在1s中执行完成200个任务,需要100个task进程。

100 = 200/(1/0.5)

五、如何设置 worker_num ?

默认设置为本机的CPU核数,最大不得超过 SWOOLE_CPU_NUM * 1000。

比如:1个请求耗时10ms,要提供1000QPS的处理能力,那就必须配置10个进程。

10 = 0.01*1000

假设每个进程占用40M内存,10个进程就需要占用400M的内存。

扩展

Server->taskwait

Server->taskWaitMulti

Server->taskCo

参考文档

https://wiki.swoole.com/wiki/...

推荐阅读

系统的讲解 - SSO 单点登录

系统的讲解 - PHP WEB 安全防御

系统的讲解 - PHP 缓存技术

系统的讲解 - PHP 接口签名验证

系统的讲解 - PHP 浮点数高精度运算

本文欢迎转发,转发请注明作者和出处,谢谢!

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/31461.html

相关文章

  • php使用swoole应用场景

    摘要:单进程读写性能可达万,不同的进程使用不同的管道通信,可以最大化利用多核。但这任务如果是调用程序接口时,由于网络的延迟,增加的任务大于消费的任务时,内存占用会不断的增加,导致服务器的内存被占满。 应用场景简介 与硬件设备连接通讯(定位设备) IM系统(用于直播页面的聊天通讯) 场景1 - 实时收集定位数据实时输出(例 滴滴司机行驶轨迹) 说明:需要将所有的定位设备实时的接收,将实时的...

    jsliang 评论0 收藏0
  • swoole学习手记(四)异步任务task

    摘要:目录初识创建服务器上创建服务器下异步任务持续更新中。。。什么是异步任务把当前的任务异步投递到进程池中执行,不影响接下来的事务。 目录 初识Swoole 创建服务器(上) 创建服务器(下) 异步任务task 持续更新中。。。 什么是异步任务? 1.把当前的任务异步投递到TaskWorker进程池中执行,不影响接下来的事务。举个栗子: showImg(https://segmentfa...

    vincent_xyb 评论0 收藏0
  • Swoole笔记(五)

    摘要:超过此数量后,新进入的连接将被拒绝。表示连接最大允许空闲的时间。当出错时底层会认为是恶意连接,丢弃数据并强制关闭连接。在启动时自动将进程的写入到文件,在关闭时自动删除文件。 配置说明 $server->set(array( daemonize => true, log_file => /www/log/swoole.log, reactor_num => 2, ...

    zgbgx 评论0 收藏0
  • Swoole RPC 实现

    摘要:概述这是关于学习的第七篇文章的实现。还有一些大佬加了微信,可能是出于对晚辈的提携吧,偷偷告诉你,从大佬的朋友圈能学到很多东西。就到这了,上面的需要源码的,加我微信。 概述 这是关于 Swoole 学习的第七篇文章:Swoole RPC 的实现。 第六篇:Swoole 整合成一个小框架 第五篇:Swoole 多协议 多端口 的应用 第四篇:Swoole HTTP 的应用 第三篇:Swo...

    FWHeart 评论0 收藏0
  • Swoole-Task:简单高效异步任务处理框架

    摘要:地址欢迎提用法示例路由说明对应目录下的文件中的名称也必须是继承对应文件中的的最后必须返回即最后一句等同于启动后发起请求假定监控的和端口是或者投递任务到进行处理目录结构说明具体处理业务逻辑的地方配置文件目录,根据环境来加载配 Swoole-Task github 地址:https://github.com/luxixing/swoole-task欢迎 star 提 issues Swoo...

    姘搁『 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<