hyperf 数据库模型缓存

安装模型缓存组件

composer require hyperf/model-cache

控制器 app/Controller/IndexController.php

<?php
namespace App\Controller;

use Hyperf\HttpServer\Contract\RequestInterface;
use Hyperf\HttpServer\Annotation\AutoController;
use App\Model\User;

/**
 * @AutoController();
 */
class IndexController
{
        public function index(RequestInterface $request){
                $id = $request->input(‘id‘,1);
                $user = User::findFromCache($id);
                return $user->toArray();
        }
}

User模型 app/Model/User.php

<?php

declare (strict_types=1);
namespace App\Model;

use Hyperf\DbConnection\Model\Model;
use Hyperf\ModelCache\CacheableInterface;
use Hyperf\ModelCache\Cacheable;

class User extends Model implements CacheableInterface
{
        use Cacheable;

    /**
     * The table associated with the model.
     *
     * @var string
     */
    protected $table = ‘user‘;
    /**
     * The attributes that are mass assignable.
     *
     * @var array
     */
    protected $fillable = [];
    /**
     * The attributes that should be cast to native types.
     *
     * @var array
     */
    protected $casts = [];

    /**
     * 不自动维护时间戳
     * @var bool
     */
    public  $timestamps = false;

}

模型缓存配置 config/autoload/databases.php

<?php

declare(strict_types=1);

return [
    ‘default‘ => [
        ‘driver‘ => env(‘DB_DRIVER‘, ‘mysql‘),
        ‘host‘ => env(‘DB_HOST‘, ‘mysql‘),
        ‘database‘ => env(‘DB_DATABASE‘, ‘hyperf‘),
        ‘port‘ => env(‘DB_PORT‘, 3306),
        ‘username‘ => env(‘DB_USERNAME‘, ‘root‘),
        ‘password‘ => env(‘DB_PASSWORD‘, ‘123456‘),
        ‘charset‘ => env(‘DB_CHARSET‘, ‘utf8‘),
        ‘collation‘ => env(‘DB_COLLATION‘, ‘utf8_unicode_ci‘),
        ‘prefix‘ => env(‘DB_PREFIX‘, ‘‘),
        ‘pool‘ => [
            ‘min_connections‘ => 1,
            ‘max_connections‘ => 10,
            ‘connect_timeout‘ => 10.0,
            ‘wait_timeout‘ => 3.0,
            ‘heartbeat‘ => -1,
            ‘max_idle_time‘ => (float) env(‘DB_MAX_IDLE_TIME‘, 60),
        ],
        ‘commands‘ => [
            ‘gen:model‘ => [
                ‘path‘ => ‘app/Model‘,
                ‘force_casts‘ => true,
                ‘inheritance‘ => ‘Model‘,
            ],
        ],
        //模型缓存配置
        ‘cache‘ => [
            ‘handler‘ => \Hyperf\ModelCache\Handler\RedisHandler::class,
            ‘cache_key‘ => ‘mc:%s:m:%s:%s:%s‘,
            ‘prefix‘ => ‘default‘,
            ‘ttl‘ => 3600 * 24,
            ‘empty_model_ttl‘ => 3600,
            ‘load_script‘ => true,
            ‘use_default_value‘ => false,
        ]
    ],
];

测试

curl 118.195.173.53:9501/index/index?id=1

返回结果

{
    "id": 1,
    "name": "xiaohong",
    "age": 24,
    "role_id": 1,
    "status": 1
}

mysql命令修改id=1的记录age=30

mysql> update user set age=30 where id=1;
Query OK, 1 row affected (0.01 sec)
Rows matched: 1  Changed: 1  Warnings: 0

mysql命令查看user表记录

mysql> select * from user;
+----+------------------+------+---------+--------+
| id | name             | age  | role_id | status |
+----+------------------+------+---------+--------+
|  1 | xiaohong         |   30 |       1 |      1 |
|  2 | huyongjian2      |   24 |       2 |      0 |
|  4 | xiaoming         |   28 |       2 |      1 |
|  5 | xiaoming5        |   30 |       2 |      1 |
|  6 | huyongjian1      |   30 |       2 |      1 |
|  7 | huyongjian2      |   31 |       2 |      1 |
|  8 | xiaohong         |   24 |       1 |      1 |
| 11 | model_event_test |   20 |       1 |      1 |
+----+------------------+------+---------+--------+
8 rows in set (0.00 sec)

重新访问

curl 118.195.173.53:9501/index/index?id=1

返回结果

{
    "id": 1,
    "name": "xiaohong",
    "age": 24,
    "role_id": 1,
    "status": 1
}

进入redis 查看是否存在类似：mc:default:m:user:id:1 的key

root@e78217bbda35:/data# redis-cli
127.0.0.1:6379> keys *
 1) "mc:default:m:user:id:1"

注：说明已经成功使用了缓存功能

访问update控制器

curl 118.195.173.53:9501/index/update

结果返回

1

重新访问

curl 118.195.173.53:9501/index/index?id=1

结果返回

{
    "id": 1,
    "name": "xiaohong",
    "age": 30,
    "role_id": 2,
    "status": 1
}

注：age,role_id已变成最新数据

缓存获取方法

// 查询单个缓存
/** @var int|string $id */
$model = User::findFromCache($id);

// 批量查询缓存，返回 Hyperf\Database\Model\Collection
/** @var array $ids */
$models = User::findManyFromCache($ids);

hyperf 数据库模型缓存

原文：https://www.cnblogs.com/hu308830232/p/15350917.html