Yii2如何将MySQL表镜像至Redis以实现高速ActiveRecord查询？

嘿，针对你要把那张极少变更的10万条记录MySQL表缓存到Redis、还要自动同步变更的需求，我给你整理几个靠谱的方案，都是实际项目里验证过的：

一、现成的CDC工具库 #

这些工具都是基于MySQL binlog来捕获变更，稳定性和可靠性都不错：

• Canal：阿里开源的老牌binlog解析工具，专门用来做MySQL到其他存储的同步。你可以简单配置监听目标表的binlog事件，然后写个处理逻辑——比如新增记录时把数据写入Redis，更新/删除时直接失效对应缓存键或者更新缓存内容。它轻量易部署，完全适配你这种变更少的场景。
• Debezium：这是一个基于Kafka Connect的CDC工具，能把MySQL的变更事件推送到Kafka，再通过消费者来同步Redis。虽然多了Kafka这一层，但如果以后你有其他数据同步需求，扩展性会很强，适合中长期的架构规划。
• MySQL触发器+脚本：如果不想搞复杂的中间件，也可以给目标表加个触发器，当有增删改操作时，调用外部脚本（比如Python或Shell）去操作Redis更新缓存。不过要注意触发器的异常处理，避免影响主业务操作，但你的表变更极少，这个问题几乎可以忽略。

二、结合Yii框架的轻量实现 #

你提到在Yii相关页面看到过评论，其实在Yii里完全可以通过ActiveRecord的事件来搞定，不用额外工具库：

You can override the afterSave() and afterDelete() methods in your ActiveRecord model. When a record is saved or deleted, you can update or invalidate the corresponding Redis cache entries directly in these methods.

给你举个实际代码例子，在你的模型里这么写：

public function afterSave($insert, $changedAttributes)
{
    parent::afterSave($insert, $changedAttributes);
    // 调用Yii的Redis组件
    $redis = Yii::$app->redis;
    $cacheKey = "your_table:record:{$this->id}";
    
    if ($insert) {
        // 新增记录时写入Redis缓存
        $redis->set($cacheKey, json_encode($this->attributes));
        // 如果维护了全表缓存集合，也要把键加进去
        $redis->sAdd("your_table:all_records", $cacheKey);
    } else {
        // 更新记录时覆盖缓存
        $redis->set($cacheKey, json_encode($this->attributes));
    }
}

public function afterDelete()
{
    parent::afterDelete();
    $redis = Yii::$app->redis;
    $cacheKey = "your_table:record:{$this->id}";
    
    // 删除对应缓存键
    $redis->del($cacheKey);
    // 从全表集合中移除
    $redis->sRem("your_table:all_records", $cacheKey);
}

这种方式直接在业务代码层面处理，不用依赖外部服务，对于你这种变更极少的表来说，性能开销几乎可以忽略，非常适合快速落地。

三、全表缓存的初始化 #

第一次把10万条数据导入Redis的话，写个简单脚本就行，比如用MySQL客户端导出数据再批量写入：

# 替换成你的数据库信息和表名
mysql -u your_username -p your_database -e "SELECT id, json_object('id', id, 'column1', column1, 'column2', column2) FROM your_table" | while read id json_str; do redis-cli SET "your_table:record:$id" "$json_str"; done

初始化完成后，日常的变更就交给上面的工具或Yii事件来处理，就能保证Redis缓存和MySQL数据的一致性了。

内容的提问来源于stack exchange，提问作者Chizuoka