并发
并发 ​
介绍 ​
Laravel 的 Concurrency
门面目前处于测试阶段,我们正在收集社区反馈。
有时您可能需要执行几个相互独立的慢任务。在许多情况下,通过并发执行任务可以实现显著的性能提升。Laravel 的 Concurrency
门面提供了一个简单、方便的 API,用于并发执行闭包。
并发兼容性 ​
如果您从 Laravel 10.x 升级到 Laravel 11.x 应用程序,您可能需要将 ConcurrencyServiceProvider
添加到应用程序的 config/app.php
配置文件中的 providers
数组中:
'providers' => ServiceProvider::defaultProviders()->merge([
/*
* 包服务提供者...
*/
Illuminate\Concurrency\ConcurrencyServiceProvider::class,
/*
* 应用服务提供者...
*/
App\Providers\AppServiceProvider::class,
App\Providers\AuthServiceProvider::class,
// App\Providers\BroadcastServiceProvider::class,
App\Providers\EventServiceProvider::class,
App\Providers\RouteServiceProvider::class,
])->toArray(),
工作原理 ​
Laravel 通过序列化给定的闭包并将其分派到一个隐藏的 Artisan CLI 命令来实现并发,该命令在其自己的 PHP 进程中反序列化闭包并调用它。在闭包被调用后,结果值会被序列化回父进程。
Concurrency
门面支持三种驱动程序:process
(默认)、fork
和 sync
。
fork
驱动程序相比于默认的 process
驱动程序提供了更好的性能,但只能在 PHP 的 CLI 上下文中使用,因为 PHP 不支持在 Web 请求期间进行分叉。在使用 fork
驱动程序之前,您需要安装 spatie/fork
包:
composer require spatie/fork
sync
驱动程序主要在测试期间有用,当您希望禁用所有并发并简单地在父进程中顺序执行给定的闭包时。
运行并发任务 ​
要运行并发任务,您可以调用 Concurrency
门面的 run
方法。run
方法接受一个闭包数组,这些闭包应该在子 PHP 进程中同时执行:
use Illuminate\Support\Facades\Concurrency;
use Illuminate\Support\Facades\DB;
[$userCount, $orderCount] = Concurrency::run([
fn () => DB::table('users')->count(),
fn () => DB::table('orders')->count(),
]);
要使用特定的驱动程序,您可以使用 driver
方法:
$results = Concurrency::driver('fork')->run(...);
或者,要更改默认的并发驱动程序,您应该通过 config:publish
Artisan 命令发布 concurrency
配置文件,并在文件中更新 default
选项:
php artisan config:publish concurrency
延迟并发任务 ​
如果您希望并发执行一组闭包,但对这些闭包返回的结果不感兴趣,您应该考虑使用 defer
方法。当调用 defer
方法时,给定的闭包不会立即执行。相反,Laravel 会在 HTTP 响应发送给用户后并发执行这些闭包:
use App\Services\Metrics;
use Illuminate\Support\Facades\Concurrency;
Concurrency::defer([
fn () => Metrics::report('users'),
fn () => Metrics::report('orders'),
]);