如果你有一批数据需要调用远程接口处理,而远程接口处理时间很长,比如需要1秒左右,那10条数据就是10秒,你的程序就要10S才能结束,而这样的话一旦接口提供方有点问题,就需要20秒 30秒甚至更久,这样就给我们带来了极大隐患,虽然我们可以使用设置超时来避免这样的长久等待,但是如果串行化不解决的话,程序始终是要长时间等所有任务都结束才能继续判断后面的结果的。
所以这里引入异步概念,用 composer require spatie/async 安装后的 Pool 里面的create 和 async 以及await来解决问题。
例子如下:
我们接口提供方是这样的代码
<?php
sleep(1);
echo json_encode(range(1,15));
exit;
以往我们的调用是这样的
foreach (range(1, 10) as $v) {
$list[] = file_get_contents("http://localhost/index.php?act=" . $v);
}
那就是按顺序调用接口,统计下来耗时 10021 ms 也就是10秒
现在我们可以这样做
<?php
include "vendor/autoload.php";
use Spatie\Async\Pool;
$pool = Pool::create();
foreach (range(1, 10) as $item) {
$pool[] = async(function () use ($item) {
return file_get_contents("http://localhost/index.php?act=" . $item);
})->then(function (string $output) use(&$list) {
$list[] = $output;
});
}
await($pool);
发现耗时 1341 ms,也就是说基本上是9-10个在同时并行请求,节省了很多时间。
我测试了一下如果不是在循环里面调用接口,而是简单的做一个item*2的数学运算,那同步可快多了,异步可慢多了。
<?php
include "vendor/autoload.php";
use Spatie\Async\Pool;
$pool = Pool::create();
foreach (range(1, 10) as $item) {
$pool[] = async(function () use ($item) {
return $item * 2;
})->then(function (string $output) use(&$list) {
$list[] = $output;
});
}
await($pool);
耗时 324 ms
而同步的嘛,只要 0.0019 ms
<?php
foreach (range(1, 10) as $v) {
$list[] = 2 * $v;
}
毕竟这种情况下多余的异步开销反而不如同步啊。
适用场景就是多数据量,长耗时任务被阻塞等待,那这个时候用这个东西缓解一下压力,提高一下速度还是不错的。