模型缓存

在高频的业务场景下，我们可能会频繁的查询数据库获取业务数据，虽然有主键索引的加持，但也不可避免的对数据库性能造成了极大的考验。而对于这种 kv 的查询方式，我们可以很方便的通过使用 模型缓存 来减缓数据库的压力。本组件实现了 Model 数据自动缓存的功能，且当删除和修改模型数据时，自动删除和修改对应的缓存。执行累加、累减操作时，缓存数据自动进行对应累加、累减变更。

模型缓存暂时只支持 Redis 存储驱动，其他存储引擎欢迎社区提交对应的实现。

安装

  1. composer require hyperf/model-cache

配置

模型缓存的配置默认存放在 config/autoload/databases.php 中。配置的属性如下：

配置 类型 默认值 备注
handler string Hyperf\ModelCache\Handler\RedisHandler::class 无
cache_key string mc:%s:m:%s:%s:%s mc:缓存前缀:m:表名:主键 KEY:主键值
prefix string db connection name 缓存前缀
pool string default 缓存池
ttl int 3600 超时时间
empty_model_ttl int 60 查询不到数据时的超时时间
load_script bool true Redis 引擎下 是否使用 evalSha 代替 eval
use_default_value bool false 是否使用数据库默认值 
  1. <?php
  2. return [
  3.     'default' => [
  4.         'driver' => env('DB_DRIVER', 'mysql'),
  5.         'host' => env('DB_HOST', 'localhost'),
  6.         'database' => env('DB_DATABASE', 'hyperf'),
  7.         'username' => env('DB_USERNAME', 'root'),
  8.         'password' => env('DB_PASSWORD', ''),
  9.         'charset' => env('DB_CHARSET', 'utf8'),
  10.         'collation' => env('DB_COLLATION', 'utf8_unicode_ci'),
  11.         'prefix' => env('DB_PREFIX', ''),
  12.         'pool' => [
  13.             'min_connections' => 1,
  14.             'max_connections' => 10,
  15.             'connect_timeout' => 10.0,
  16.             'wait_timeout' => 3.0,
  17.             'heartbeat' => -1,
  18.             'max_idle_time' => (float)env('DB_MAX_IDLE_TIME', 60),
  19.         ],
  20.         'cache' => [
  21.             'handler' => \Hyperf\ModelCache\Handler\RedisHandler::class,
  22.             'cache_key' => 'mc:%s:m:%s:%s:%s',
  23.             'prefix' => 'default',
  24.             'ttl' => 3600 * 24,
  25.             'empty_model_ttl' => 3600,
  26.             'load_script' => true,
  27.             'use_default_value' => false,
  28.         ]
  29.     ],
  30. ];

使用

模型缓存的使用十分简单，只需要在对应 Model 中实现 Hyperf\ModelCache\CacheableInterface 接口，当然，框架已经提供了对应实现，只需要引入 Hyperf\ModelCache\Cacheable Trait 即可。

  1. <?php
  2. declare(strict_types=1);
  4. namespace App\Models;
  6. use Hyperf\DbConnection\Model\Model;
  7. use Hyperf\ModelCache\Cacheable;
  8. use Hyperf\ModelCache\CacheableInterface;
  10. /**
  11.  * @property $id
  12.  * @property $name
  13.  * @property $gender
  14.  * @property $created_at
  15.  * @property $updated_at
  16.  */
  17. class User extends Model implements CacheableInterface
  18. {
  19.     use Cacheable;
  21.     /**
  22.      * The table associated with the model.
  23.      *
  24.      * @var string
  25.      */
  26.     protected $table = 'user';
  28.     /**
  29.      * The attributes that are mass assignable.
  30.      *
  31.      * @var array
  32.      */
  33.     protected $fillable = ['id', 'name', 'gender', 'created_at', 'updated_at'];
  35.     protected $casts = ['id' => 'integer', 'gender' => 'integer'];
  36. }
  38. // 查询单个缓存
  39. /** @var int|string $id */
  40. $model = User::findFromCache($id);
  42. // 批量查询缓存，返回 Hyperf\Database\Model\Collection
  43. /** @var array $ids */
  44. $models = User::findManyFromCache($ids);

对应 Redis 数据如下，其中 HF-DATA:DEFAULT 作为占位符存在于 HASH 中，所以用户不要使用 HF-DATA 作为数据库字段。

  1. 127.0.0.1:6379> hgetall "mc:default:m:user:id:1"
  2.  1) "id"
  3.  2) "1"
  4.  3) "name"
  5.  4) "Hyperf"
  6.  5) "gender"
  7.  6) "1"
  8.  7) "created_at"
  9.  8) "2018-01-01 00:00:00"
  10.  9) "updated_at"
  11. 10) "2018-01-01 00:00:00"
  12. 11) "HF-DATA"
  13. 12) "DEFAULT"

另外一点需要注意的就是，缓存的更新机制，框架内实现了对应的 Hyperf\ModelCache\Listener\DeleteCacheListener 监听器，每当数据修改时，框架会主动删除对应的缓存数据。 如果您不希望由框架来自动删除对应的缓存，可以通过主动覆写 Model 的 deleteCache 方法，然后自行实现对应监听即可。

批量修改或删除

Hyperf\ModelCache\Cacheable 会自动接管 Model::query 方法，只需要用户通过以下方式进行数据的删除，就可以自动清理对应的缓存数据。

  1. <?php
  2. // 从数据库删除用户数据，框架会自动删除对应的缓存数据
  3. User::query(true)->where('gender', '>', 1)->delete();

使用默认值

当生产环境使用了模型缓存时，如果已经建立了对应缓存数据，但此时又因为逻辑变更，添加了新的字段，并且默认值不是 0、空字符、null 这类数据时，就会导致在数据查询时，从缓存中查出来的数据与数据库中的数据不一致。

对于这种情况，我们可以修改 use_default_value 为 true，并添加 Hyperf\DbConnection\Listener\InitTableCollectorListener 到 listener.php 配置中，使 Hyperf 应用在启动时主动去获取数据库的字段信息，并在获取缓存数据时与之比较并进行缓存数据修正。

控制模型中缓存时间

除了 database.php 中配置的默认缓存时间 ttl 外，Hyperf\ModelCache\Cacheable 支持对模型配置更细的缓存时间：

  1. class User extends Model implements CacheableInterface
  2. {
  3.     use Cacheable;
  5.     /**
  6.      * 缓存 10 分钟，返回 null 则使用配置文件中设置的超时时间
  7.      * @return int|null
  8.      */
  9.     public function getCacheTTL(): ?int
  10.     {
  11.         return 600;
  12.     }
  13. }

EagerLoad

当我们使用模型关系时，可以通过 load 解决 N+1 的问题，但仍然需要查一次数据库。模型缓存通过重写了 ModelBuilder，可以让用户尽可能的从缓存中拿到对应的模型。

本功能不支持 morphTo 和不是只有 whereIn 查询的关系模型。

以下提供两种方式：

  1. 配置 EagerLoadListener，直接使用 loadCache 方法。

修改 listeners.php 配置

  1. return [
  2.     Hyperf\ModelCache\Listener\EagerLoadListener::class,
  3. ];

通过 loadCache 方法，加载对应的模型关系。

  1. $books = Book::findManyFromCache([1,2,3]);
  2. $books->loadCache(['user']);
  4. foreach ($books as $book){
  5.     var_dump($book->user);
  6. }
  1. 使用 EagerLoader
  1. use Hyperf\ModelCache\EagerLoad\EagerLoader;
  2. use Hyperf\Utils\ApplicationContext;
  4. $books = Book::findManyFromCache([1,2,3]);
  5. $loader = ApplicationContext::getContainer()->get(EagerLoader::class);
  6. $loader->load($books, ['user']);
  8. foreach ($books as $book){
  9.     var_dump($book->user);
  10. }

缓存适配器

您可以根据自己的实际情况实现缓存适配器，只需要实现接口 Hyperf\ModelCache\Handler\HandlerInterface 即可。

框架提供了两个 Handler 可供选择：

  • Hyperf\ModelCache\Handler\RedisHandler

使用 HASH 存储缓存，可以有效的处理 Model::increament()，不足是因为数据类型只有 String，所以对 null 支持较差。

  • Hyperf\ModelCache\Handler\RedisStringHandler

使用 String 存储缓存，因为是序列化的数据，所以支持所有数据类型，不足是无法有效处理 Model::increament()，当模型调用累加时，通过删除缓存，解决一致性的问题。