登录/注册

缓存

hyperf/cache 提供了基于 Aspect 实现的切面缓存,也提供了实现 PsrSimpleCacheCacheInterface 的缓存类。

安装

composer require hyperf/cache

默认配置

配置 默认值 备注
driver HyperfCacheDriverRedisDriver 缓存驱动,默认为 Redis
packer HyperfUtilsPackerPhpSerializer 打包器
prefix c: 缓存前缀
<?php

return [
    'default' => [
        'driver' => HyperfCacheDriverRedisDriver::class,
        'packer' => HyperfUtilsPackerPhpSerializer::class,
        'prefix' => 'c:',
    ],
];

使用

Simple Cache 方式

Simple Cache 也就是 PSR-16 规范,本组件适配了该规范,如果您希望使用实现 PsrSimpleCacheCacheInterface 缓存类,比如要重写 EasyWeChat 的缓存模块,可以直接从依赖注入容器中获取 PsrSimpleCacheCacheInterface 即可,如下所示:

$cache = $container->get(PsrSimpleCacheCacheInterface::class);

注解方式

组件提供 HyperfCacheAnnotationCacheable 注解,作用于类方法,可以配置对应的缓存前缀、失效时间、监听器和缓存组。例如,UserService 提供一个 user 方法,可以查询对应 id 的用户信息。当加上 HyperfCacheAnnotationCacheable 注解后,会自动生成对应的 Redis 缓存,key 值为 user:id ,超时时间为 9000 秒。首次查询时,会从数据库中查,后面查询时,会从缓存中查。

缓存注解基于 aop 和 di,所以只有在 Container 中获取到的对象实例才有效,比如通过 $container->get 和 make 方法所获得的对象,直接 new 出来的对象无法使用。

<?php

namespace AppServices;

use AppModelsUser;
use HyperfCacheAnnotationCacheable;

class UserService
{
    /**
     * @Cacheable(prefix="user", ttl=9000, listener="user-update")
     */
    public function user($id)
    {
        $user = User::query()->where('id',$id)->first();

        if($user){
            return $user->toArray();
        }

        return null;
    }
}

清理 @Cacheable 生成的缓存

当然,如果我们数据库中的数据改变了,如何删除缓存呢?这里就需要用到后面的监听器。下面新建一个 Service 提供一方法,来帮我们处理缓存。

<?php

declare(strict_types=1);

namespace AppService;

use HyperfDiAnnotationInject;
use HyperfCacheListenerDeleteListenerEvent;
use PsrEventDispatcherEventDispatcherInterface;

class SystemService
{
    /**
     * @Inject
     * @var EventDispatcherInterface
     */
    protected $dispatcher;

    public function flushCache($userId)
    {
        $this->dispatcher->dispatch(new DeleteListenerEvent('user-update', [$userId]));

        return true;
    }
}

当我们自定义了 Cacheablevalue 时,比如以下情况。

<?php

declare(strict_types=1);

namespace AppServiceCache;

use HyperfCacheAnnotationCacheable;

class DemoService
{
    /**
     * @Cacheable(prefix="cache", value="_#{id}", listener="DemoServiceDelete")
     */
    public function getCache(int $id)
    {
        return $id . '_' . uniqid();
    }
}

则需要对应修改 DeleteListenerEvent 构造函数中的 $arguments 变量,具体代码如下。

<?php

declare(strict_types=1);

namespace AppService;

use HyperfDiAnnotationInject;
use HyperfCacheListenerDeleteListenerEvent;
use PsrEventDispatcherEventDispatcherInterface;

class SystemService
{
    /**
     * @Inject
     * @var EventDispatcherInterface
     */
    protected $dispatcher;

    public function flushCache($userId)
    {
        $this->dispatcher->dispatch(new DeleteListenerEvent('user-update', ['id' => $userId]));

        return true;
    }
}

注解介绍

Cacheable

例如以下配置,缓存前缀为 user, 超时时间为 7200, 删除事件名为 USER_CACHE。生成对应缓存 KEY 为 c:user:1

use AppModelsUser;
use HyperfCacheAnnotationCacheable;

/**
 * @Cacheable(prefix="user", ttl=7200, listener="USER_CACHE")
 */
public function user(int $id): array
{
    $user = User::query()->find($id);

    return [
        'user' => $user->toArray(),
        'uuid' => $this->unique(),
    ];
}

当设置 value 后,框架会根据设置的规则,进行缓存 KEY 键命名。如下实例,当 $user->id = 1 时,缓存 KEYc:userBook:_1

use AppModelsUser;
use HyperfCacheAnnotationCacheable;

/**
 * @Cacheable(prefix="userBook", ttl=6666, value="_#{user.id}")
 */
public function userBook(User $user): array
{
    return [
        'book' => $user->book->toArray(),
        'uuid' => $this->unique(),
    ];
}

CachePut

CachePut 不同于 Cacheable,它每次调用都会执行函数体,然后再对缓存进行重写。所以当我们想更新缓存时,可以调用相关方法。

use AppModelsUser;
use HyperfCacheAnnotationCachePut;

/**
 * @CachePut(prefix="user", ttl=3601)
 */
public function updateUser(int $id)
{
    $user = User::query()->find($id);
    $user->name = 'HyperfDoc';
    $user->save();

    return [
        'user' => $user->toArray(),
        'uuid' => $this->unique(),
    ];
}

CacheEvict

CacheEvict 更容易理解了,当执行方法体后,会主动清理缓存。

use HyperfCacheAnnotationCacheEvict;

/**
 * @CacheEvict(prefix="userBook", value="_#{id}")
 */
public function updateUserBook(int $id)
{
    return true;
}

缓存驱动

Redis 驱动

HyperfCacheDriverRedisDriver 会把缓存数据存放到 Redis 中,需要用户配置相应的 Redis 配置。此方式为默认方式。

协程内存驱动

本驱动乃 Beta 版本,请谨慎使用。

如果您需要将数据缓存到 Context 中,可以尝试此驱动。例如以下应用场景 Demo::get 会在多个地方调用多次,但是又不想每次都到 Redis 中进行查询。

<?php
use HyperfCacheAnnotationCacheable;

class Demo {

    public function get($userId, $id)
    {
        return $this->getArray($userId)[$id] ?? 0;
    }

    /**
     * @Cacheable(prefix="test", group="co")
     */
    public function getArray(int $userId): array
    {
        return $this->redis->hGetAll($userId);
    }
}

对应配置如下:

<?php

return [
    'co' => [
        'driver' => HyperfCacheDriverCoroutineMemoryDriver::class,
        'packer' => HyperfUtilsPackerPhpSerializerPacker::class,
    ],
];
原文地址:https://blog.csdn.net/q7825103/article/details/105379906
文章来源与用户投稿或网络采集,如果您是本文的作者,发现版权或转载方式问题请右侧邮箱联系管理员。

抢沙发

共同学习,写下你的评论
姓名
电子邮件
个人主页