跳到内容

并发

简介

Laravel 的 Concurrency facade 目前处于 beta 阶段,我们正在收集社区反馈。

有时您可能需要执行多个互不依赖的慢任务。在许多情况下,通过并发执行任务可以实现显着的性能提升。Laravel 的 Concurrency facade 提供了一个简单、方便的 API 来并发执行闭包。

并发兼容性

如果您从 Laravel 10.x 应用程序升级到 Laravel 11.x,您可能需要在应用程序的 config/app.php 配置文件中的 providers 数组中添加 ConcurrencyServiceProvider

1'providers' => ServiceProvider::defaultProviders()->merge([
2 /*
3 * Package Service Providers...
4 */
5 Illuminate\Concurrency\ConcurrencyServiceProvider::class,
6 
7 /*
8 * Application Service Providers...
9 */
10 App\Providers\AppServiceProvider::class,
11 App\Providers\AuthServiceProvider::class,
12 // App\Providers\BroadcastServiceProvider::class,
13 App\Providers\EventServiceProvider::class,
14 App\Providers\RouteServiceProvider::class,
15])->toArray(),

它是如何工作的

Laravel 通过序列化给定的闭包并将它们分派到一个隐藏的 Artisan CLI 命令来实现并发,该命令反序列化闭包并在其自己的 PHP 进程中调用它。在调用闭包后,结果值被序列化回父进程。

Concurrency facade 支持三个驱动程序:process(默认)、forksync

与默认的 process 驱动程序相比,fork 驱动程序提供了更高的性能,但它只能在 PHP 的 CLI 上下文中使用,因为 PHP 不支持在 Web 请求期间进行 fork 操作。在使用 fork 驱动程序之前,您需要安装 spatie/fork 软件包

1composer require spatie/fork

当您想要禁用所有并发并仅在父进程中按顺序执行给定的闭包时,sync 驱动程序主要在测试期间很有用。

运行并发任务

要运行并发任务,您可以调用 Concurrency facade 的 run 方法。run 方法接受一个闭包数组,这些闭包应该在子 PHP 进程中同时执行

1use Illuminate\Support\Facades\Concurrency;
2use Illuminate\Support\Facades\DB;
3 
4[$userCount, $orderCount] = Concurrency::run([
5 fn () => DB::table('users')->count(),
6 fn () => DB::table('orders')->count(),
7]);

要使用特定的驱动程序,您可以使用 driver 方法

1$results = Concurrency::driver('fork')->run(...);

或者,要更改默认的并发驱动程序,您应该通过 config:publish Artisan 命令发布 concurrency 配置文件,并更新文件中的 default 选项

1php artisan config:publish concurrency

延迟并发任务

如果您想并发执行一个闭包数组,但对这些闭包返回的结果不感兴趣,您应该考虑使用 defer 方法。当调用 defer 方法时,给定的闭包不会立即执行。相反,Laravel 将在 HTTP 响应发送给用户后并发执行这些闭包

1use App\Services\Metrics;
2use Illuminate\Support\Facades\Concurrency;
3 
4Concurrency::defer([
5 fn () => Metrics::report('users'),
6 fn () => Metrics::report('orders'),
7]);

Laravel 是构建最高效的方式,用于
构建、部署和监控软件。