TASK异步进程处理场景

如消息队列&＃xff0c;可以把复杂任务异步交给swoole的task进程处理。
大数据处理&＃xff0c;如发送10000个EMAIL&＃xff0c;可以异步交给swoole的task进程处理。

CLI 挂载启动服务端程序&＃xff1a;php server.php

$serv &＃61; new swoole_server(&＃39;127.0.0.1&＃39;, 9501);// 配置多少进程处理&＃xff0c;传递给task函数是异步的
// 如果配置的是1&＃xff0c;task会单进程方式把所有授予的任务依次处理完毕
$serv->set([&＃39;task_worker_num&＃39; &＃61;> 1,
]);$serv->on(&＃39;Connect&＃39;, function ($serv, $fd) {echo "new client connected." . PHP_EOL;
});$serv->on(&＃39;Receive&＃39;, function ($serv, $fd, $fromId, $data) {echo "worker received data: {$data}" . PHP_EOL;// 投递一个任务到task进程中$serv->task($data);// 通知客户端server收到数据了$serv->send($fd, &＃39;This is a message from server.&＃39;);// 为了校验task是否是异步的&＃xff0c;这里和task进程内都输出内容&＃xff0c;看看谁先输出echo "worker continue run." . PHP_EOL;
});/*** $serv swoole_server* $taskId 投递的任务id,因为task进程是由worker进程发起&＃xff0c;所以多worker多task下&＃xff0c;该值可能会相同* $fromId 来自那个worker进程的id* $data 要投递的任务数据*/
$serv->on(&＃39;Task&＃39;, function ($serv, $taskId, $fromId, $data) {echo "task start. --- from worker id: {$fromId}." . PHP_EOL;for ($i&＃61;0; $i <100; $i&＃43;&＃43;) {sleep(1);echo "task runing. --- {$i}" . PHP_EOL;}echo "task end." . PHP_EOL;
});/*** 只有在task进程中调用了finish方法或者return了结果&＃xff0c;才会触发finish*/
$serv->on(&＃39;Finish&＃39;, function ($serv, $taskId, $data) {echo "finish received data &＃39;{$data}&＃39;" . PHP_EOL;
});$serv->start();
客户端应用程序

客户端启动发送数据&＃xff1a;php client.php

$client &＃61; new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_SYNC);// 随后建立连接&＃xff0c;连接失败直接退出并打印错误码
$client->connect(&＃39;127.0.0.1&＃39;, 9501) || exit("connect failed. Error: {$client->errCode}\n");
// 向服务端发送数据
$client->send("hello server.");
// 从服务端接收数据
$response &＃61; $client->recv();
// 输出接受到的数据
echo $response . PHP_EOL;// 关闭连接
$client->close();
本篇总结&＃xff1a;

1. 没有耗时任务的情况下&＃xff0c;worker直接运行&＃xff0c;无需开启task

2. 对于耗时的任务&＃xff0c;可以在worker内调用task函数&＃xff0c;把异步任务投递给task进程进行处理&＃xff0c;task进程的数量取决于task_worker_num的配置

3. task进程内可以选择调用finish方法或者return&＃xff0c;来通知worker进程此任务已完成&＃xff0c;worker进程会在onFinish回调中对task的执行结果进一步处理。如果worker进程不关心任务的结果&＃xff0c;finish就不需要了。