How to use swoole task

# Application of Swoole Task.

Swoole Asynchronous Task mainly implements the execution of calling asynchronous tasks.(Recommended learning:swoole video tutorial)

Commonly used scenarios: asynchronous payment processing, asynchronous order processing, asynchronous log processing, asynchronous sending of emails/SMS messages, etc.

The implementation of Swoole is that the worker process handles the data request and is assigned to the task process for execution.

Official introduction:

task The bottom layer uses Unix Socket pipe communication, which is full memory and has no IO consumption. The read and write performance of a single process can reach 1 million/s. Different processes use different pipelines to communicate, which can maximize the use of multiple cores.

Local version: PHP 7.2.6, Swoole 4.3.1.

Without further ado, let’s look at the renderings first:

Code

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

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();

The above is the detailed content of How to use swoole task. For more information, please follow other related articles on the PHP Chinese website!