缓存系统 11个月前

简介

在某些应用中，一些查询数据或处理任务的操作会在某段时间里短时间内大量进行，或是一个操作花费好几秒钟。当出现这种情况时，通常会将检索到的数据缓存起来，从而为后面请求同一数据的请求迅速返回结果。这些缓存数据通常会储存在极快的存储系统中，例如 Memcached 和 Redis。

Laravel 为各种缓存后端提供了富有表现力且统一的 API，以便你利用它们极快的查询数据来加快你的应用。

配置

缓存配置文件位于 config/cache.php。在这个文件中，你可以指定应用默认使用哪个缓存驱动。Laravel 支持的缓存后端包括 Memcached、Redis、DynamoDB，以及现成的关系型数据库。此外，还支持基于文件的缓存驱动，以及方便自动化测试的缓存驱动 array 和 null 。

缓存配置文件还包含文件中记录的各种其他选项，因此请务必阅读这些选项。 默认情况下，Laravel 配置为使用 file 缓存驱动，它将序列化的缓存对象存储在服务器的文件系统中。 对于较大的应用程序，建议你使用更强大的驱动，例如 Memcached 或 Redis。 你甚至可以为同一个驱动配置多个缓存配置。

驱动先决条件

使用 database 缓存驱动时，你需要设置一个表来包含缓存项。你将在下表中找到 Schema 声明的示例：

copy
Schema::create('cache', function (Blueprint $table) { $table->string('key')->unique(); $table->text('value'); $table->integer('expiration'); });

使用 Memcached 驱动程序需要安装 Memcached PECL 包。你可以在 config/cache.php 配置文件中列出所有的 Memcached 服务器。该文件已经包含一个 memcached.servers 来帮助你入门：

copy
'memcached' => [ 'servers' => [ [ 'host' => env('MEMCACHED_HOST', '127.0.0.1'), 'port' => env('MEMCACHED_PORT', 11211), 'weight' => 100, ], ], ],

如果需要，你可以将 host 选项设置为 UNIX socket path。 如果这样做， port 选项应设置为 0：

copy
'memcached' => [ [ 'host' => '/var/run/memcached/memcached.sock', 'port' => 0, 'weight' => 100 ], ],

在将 Redis 缓存与 Laravel 一起使用之前，您需要通过 PECL 安装 PhpRedis PHP 扩展或通过 Composer 安装 predis/predis 包（~1.0）。Laravel Vapor 也默认安装了 PhpRedis 扩展。

有关配置 Redis 的更多信息，请参阅其 Laravel documentation page.

在使用 DynamoDB 缓存驱动程序之前，您必须创建一个 DynamoDB 表来存储所有缓存的数据。通常，此表应命名为cache。但是，您应该根据应用程序的缓存配置文件中的 stores.dynamodb.table 配置值来命名表。

该表还应该有一个字符串分区键，其名称对应于应用程序的缓存配置文件中的 stores.dynamodb.attributes.key 配置项的值。 默认情况下，分区键应命名为 key。

缓存用法

获取缓存实例

要获取缓存存储实例，您可以使用 Cache 门面类，我们将在本文档中使用它。Cache 门面类提供了对 Laravel 缓存底层实现的方便、简单的访问：

copy
<?php namespace App\Http\Controllers; use Illuminate\Support\Facades\Cache; class UserController extends Controller { /** * Show a list of all users of the application. */ public function index(): array { $value = Cache::get('key'); return [ // ... ]; } }

使用 Cache 门面类, 您可以通过 store 方法访问各种缓存存储。传递给 store 方法的键应该对应于 cache 配置文件中的 stores 配置数组中列出的存储之一：

copy
$value = Cache::store('file')->get('foo'); Cache::store('redis')->put('bar', 'baz', 600); // 10 Minutes

从缓存中检索项目

Cache 门面的 get 方法用于从缓存中检索项目。如果缓存中不存在该项目，则将返回 null。如果您愿意，您可以将第二个参数传递给 get 方法，指定您希望在项目不存在时返回的默认值：

copy
$value = Cache::get('key'); $value = Cache::get('key', 'default');

您甚至可以将闭包作为默认值传递。如果指定的项在缓存中不存在，则返回闭包的结果。传递闭包允许您推迟从数据库或其他外部服务中检索默认值：

copy
$value = Cache::get('key', function () { return DB::table(/* ... */)->get(); });

has 方法可用于确定缓存中是否存在项目。如果项目存在但其值为 null，此方法也将返回 false：

copy
if (Cache::has('key')) { // ... }

increment 和 decrement 方法可用于调整缓存中整数项的值。这两种方法都接受一个可选的第二个参数，指示增加或减少项目值的数量：

copy
Cache::increment('key'); Cache::increment('key', $amount); Cache::decrement('key'); Cache::decrement('key', $amount);

有时你可能希望从缓存中检索一个项目，但如果请求的项目不存在，则存储一个默认值。 例如， 你可能希望从缓存中检索所有用户，如果用户不存在，则从数据库中检索并将它们添加到缓存中。 你可以使用 Cache::remember 方法执行此操作：

copy
$value = Cache::remember('users', $seconds, function () { return DB::table('users')->get(); });

如果该项不存在于缓存中，将执行传递给 remember 方法的闭包，并将其结果放入缓存中。

你可以使用 rememberForever 方法从缓存中检索一个项目，如果它不存在则永久存储它：

copy
$value = Cache::rememberForever('users', function () { return DB::table('users')->get(); });

如果你需要从缓存中检索一项后并删除该项，你可以使用 pull 方法。 与 get 方法一样，如果该项不存在于缓存中，将返回 null：

copy
$value = Cache::pull('key');

在缓存中存储项目

你可以使用 Cache Facade上的 put 方法将项目存储在缓存中：

copy
Cache::put('key', 'value', $seconds = 10);

如果存储时间没有传递给 put 方法，则该项目将无限期存储：

copy
Cache::put('key', 'value');

除了将秒数作为整数传递之外，你还可以传递一个代表缓存项所需过期时间的 DateTime 实例：

copy
Cache::put('key', 'value', now()->addMinutes(10));

add 方法只会将缓存存储中不存在的项目添加到缓存中。如果项目实际添加到缓存中，该方法将返回 true。 否则，该方法将返回 false。 add 方法是一个原子操作：

copy
Cache::add('key', 'value', $seconds);

forever 方法可用于将项目永久存储在缓存中。由于这些项目不会过期，因此必须使用 forget 方法手动将它们从缓存中删除：

copy
Cache::forever('key', 'value');

从缓存中删除项目

您可以使用 forget 方法从缓存中删除项目：

copy
Cache::forget('key');

您还可以通过提供零或负数的过期秒数来删除项目：

copy
Cache::put('key', 'value', 0); Cache::put('key', 'value', -5);

您可以使用 flush 方法清除整个缓存：

copy
Cache::flush();

缓存助手函数

除了使用 Cache 门面之外，您还可以使用全局 cache 函数通过缓存检索和存储数据。当使用单个字符串参数调用 cache 函数时，它将返回给定键的值：

copy
$value = cache('key');

如果您向函数提供键 / 值对数组和过期时间，它将在指定的持续时间内将值存储在缓存中：

copy
cache(['key' => 'value'], $seconds); cache(['key' => 'value'], now()->addMinutes(10));

当不带任何参数调用 cache 函数时，它会返回 Illuminate\Contracts\Cache\Factory 实现的实例，允许您调用其他缓存方法：

copy
cache()->remember('users', $seconds, function () { return DB::table('users')->get(); });

缓存标签

存储缓存标签

缓存标签允许您在缓存中标记相关项目，然后刷新所有已分配给定标签的缓存值。您可以通过传入标记名称的有序数组来访问标记缓存。例如，让我们访问一个标记的缓存并将一个值put缓存中：

copy
Cache::tags(['people', 'artists'])->put('John', $john, $seconds); Cache::tags(['people', 'authors'])->put('Anne', $anne, $seconds);

访问缓存标签

要检索标记的缓存项，请将相同的有序标签列表传递给 tags 方法，然后使用您要检索的键调用 get 方法：

copy
$john = Cache::tags(['people', 'artists'])->get('John'); $anne = Cache::tags(['people', 'authors'])->get('Anne');

删除被标记的缓存数据

你可以刷新所有分配了标签或标签列表的项目。 例如，此语句将删除所有标记有 people, authors或两者的缓存。因此，Anne 和 John 都将从缓存中删除：

copy
Cache::tags(['people', 'authors'])->flush();

相反，此语句将仅删除带有 authors 标记的缓存，因此将删除 Anne，但不会删除 John：

copy
Cache::tags('authors')->flush();

清理过期的缓存标记

为了在使用 Redis 缓存驱动程序时正确清理过期的缓存标记，Laravel 的 Artisan 命令 cache:prune-stale-tags 应该被添加到 任务调度 中，在应用程序的 App\Console\Kernel 类里：

copy
$schedule->command('cache:prune-stale-tags')->hourly();

原子锁

驱动程序先决条件

使用“数据库”缓存驱动程序时，您需要设置一个表来包含应用程序的缓存锁。您将在下表中找到一个示例 Schema 声明：

copy
Schema::create('cache_locks', function (Blueprint $table) { $table->string('key')->primary(); $table->string('owner'); $table->integer('expiration'); });

管理锁

原子锁允许操作分布式锁而不用担心竞争条件。例如，Laravel Forge 使用原子锁来确保服务器上一次只执行一个远程任务。您可以使用 Cache::lock 方法创建和管理锁：

copy
use Illuminate\Support\Facades\Cache; $lock = Cache::lock('foo', 10); if ($lock->get()) { // Lock acquired for 10 seconds... $lock->release(); }

get 方法也接受一个闭包。闭包执行后，Laravel 会自动释放锁：

copy
Cache::lock('foo', 10)->get(function () { // Lock acquired for 10 seconds and automatically released... });

如果在您请求时锁不可用，您可以指示 Laravel 等待指定的秒数。如果在指定的时间限制内无法获取锁，则会抛出 Illuminate\Contracts\Cache\LockTimeoutException：

copy
use Illuminate\Contracts\Cache\LockTimeoutException; $lock = Cache::lock('foo', 10); try { $lock->block(5); // Lock acquired after waiting a maximum of 5 seconds... } catch (LockTimeoutException $e) { // Unable to acquire lock... } finally { $lock?->release(); }

上面的例子可以通过将闭包传递给 block 方法来简化。当一个闭包被传递给这个方法时，Laravel 将尝试在指定的秒数内获取锁，并在闭包执行后自动释放锁：

copy
Cache::lock('foo', 10)->block(5, function () { // Lock acquired after waiting a maximum of 5 seconds... });

跨进程管理锁

有时，您可能希望在一个进程中获取锁并在另一个进程中释放它。例如，您可能在 Web 请求期间获取锁，并希望在由该请求触发的排队作业结束时释放锁。在这种情况下，您应该将锁的作用域owner token传递给排队的作业，以便作业可以使用给定的令牌重新实例化锁。

在下面的示例中，如果成功获取锁，我们将调度一个排队的作业。 此外，我们将通过锁的owner方法将锁的所有者令牌传递给排队的作业：

copy
$podcast = Podcast::find($id); $lock = Cache::lock('processing', 120); if ($lock->get()) { ProcessPodcast::dispatch($podcast, $lock->owner()); }

在我们应用程序的ProcessPodcast作业中，我们可以使用所有者令牌恢复和释放锁：

copy
Cache::restoreLock('processing', $this->owner)->release();

如果你想释放一个锁而不考虑它的当前所有者，你可以使用forceRelease方法：

copy
Cache::lock('processing')->forceRelease();

添加自定义缓存驱动

编写驱动

要创建我们的自定义缓存驱动程序，我们首先需要实现Illuminate\Contracts\Cache\Storecontract。 因此，MongoDB 缓存实现可能如下所示：

copy
<?php namespace App\Extensions; use Illuminate\Contracts\Cache\Store; class MongoStore implements Store { public function get($key) {} public function many(array $keys) {} public function put($key, $value, $seconds) {} public function putMany(array $values, $seconds) {} public function increment($key, $value = 1) {} public function decrement($key, $value = 1) {} public function forever($key, $value) {} public function forget($key) {} public function flush() {} public function getPrefix() {} }

我们只需要使用 MongoDB 连接来实现这些方法中的每一个。有关如何实现这些方法的示例，请查看 Laravel 框架源代码中的Illuminate\Cache\MemcachedStore。 一旦我们的实现完成，我们可以通过调用Cache 门面的extend方法来完成我们的自定义驱动程序注册：

copy
Cache::extend('mongo', function (Application $app) { return Cache::repository(new MongoStore); });

注册驱动

要向 Laravel 注册自定义缓存驱动程序，我们将使用Cache门面的extend方法。 由于其他服务提供者可能会尝试在他们的boot方法中读取缓存值，我们将在booting回调中注册我们的自定义驱动程序。 通过使用booting回调，我们可以确保在应用程序的服务提供者调用boot方法之前但在所有服务提供者调用register方法之后注册自定义驱动程序。 我们将在应用程序的App\Providers\AppServiceProvider类的register方法中注册我们的booting回调：

copy
<?php namespace App\Providers; use App\Extensions\MongoStore; use Illuminate\Contracts\Foundation\Application; use Illuminate\Support\Facades\Cache; use Illuminate\Support\ServiceProvider; class CacheServiceProvider extends ServiceProvider { /** * 注册任何应用程序服务。 */ public function register(): void { $this->app->booting(function () { Cache::extend('mongo', function (Application $app) { return Cache::repository(new MongoStore); }); }); } /** * 引导任何应用程序服务。 */ public function boot(): void { // ... } }

传递给extend方法的第一个参数是驱动程序的名称。这将对应于config/cache.php配置文件中的 driver选项。 第二个参数是一个闭包，它应该返回一个Illuminate\Cache\Repository实例。闭包将传递一个$app实例，它是服务容器的一个实例。

注册扩展程序后，将config/cache.php配置文件的driver选项更新为扩展程序的名称。

事件

要在每个缓存操作上执行代码，你可以侦听缓存触发的 events 。 通常，你应该将这些事件侦听器放在应用程序的App\Providers\EventServiceProvider类中：