您的位置 首页 技术

swoole task怎么用

Swoole Task 的应用。 Swoole 异步Task,主要实现调用异步任务的执行。 (推荐学习: swoole视频教程) 常用的场景:异步支付处理、异步订单处理、异步日志处…

Swoole Task 的应用。

Swoole 异步Task,主要实现调用异步任务的执行。 (推荐学习: swoole视频教程)

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

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

官方介绍:

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

本地版本:PHP 7.2.6、Swoole 4.3.1。

不多说,先看效果图:

代码

server.php

class Server{    private $serv;    public function __construct() {        $this->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

<?phpclass Client{    private $client;    public function __construct() {        $this->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();

以上就是swoole task怎么用的详细内容,更多请关注24课堂在线网其它相关文章!

本文来自网络,不代表24小时课堂在线立场,转载请注明出处:https://www.24ketang.cn/20958.html

为您推荐

返回顶部