thinkphp6 redis 哈希存储方式以及操作函数（笔记）

逻辑：如果redis里没有指定表数据就进行存储再输出，如果有就直接输出，代码优化后几万条数据从数据库入redis也是三四秒的时间，数据以json方式存储：key用于数据ID 跟数据库数据ID同步，value用于存储整个字段包括数据，这样数据多不会占用多余内存

$name参数是数据库表名，跟数据库表名是同步一样的，直接调用即可

/**
 * 缓存指定表全部数据
 * @Author Xven　<270988107@qq.com>
 * @return [type]                  [description]
 */
function redis_data($name) {
$redis = Cache::store('redis');
$data = [];
// 尝试从 Redis 获取数据
$lists = $redis->hGetAll($name . ':list');
if (!empty($lists)) {
// Redis 中有数据，直接解码并返回
foreach ($lists as $key => $value) {
$data[$key] = json_decode($value, true);
}
} else {
// Redis 中没有数据，从数据库获取并写入 Redis
$list = Db::name($name)->cursor();
$encodedData = [];
// 开始一个多重操作
$redis->multi();
foreach ($list as $item) {
$encoded = json_encode($item, JSON_UNESCAPED_UNICODE);
$redis->hSet($name . ':list', $item['id'], $encoded);
$data[] = $item; // 直接将数据库查询结果添加到 $data 数组中
}
// 执行多重操作中的所有命令
$redis->exec();
}

return $data;
}

/**
 * 查询指定ID单条数据
 * @Author Xven　<270988107@qq.com>
 * @param  [type]                  $name [description]
 * @param  [type]                  $id   [description]
 * @return [type]                        [description]
 */
function find_redis($name, $id) {
$redis = Cache::store('redis');
$info = $redis->hMget($name . ':list', [$id]);
if (!empty($info)) {
$info = json_decode($info[$id], true);
return $info;
} else {
return '';
}
}

/**
 * 指定ID数据重存更新
 * @Author Xven　<270988107@qq.com>
 * @param  [type]                  $id   [description]
 * @param  [type]                  $name [description]
 * @return [type]                        [description]
 */
function update_redis($name, $id, $field) {
$redis = Cache::store('redis');
$cursor = Db::name($name)->where('id', $id)->limit(1)->cursor();
foreach ($cursor as $v) {
if (!empty($v)) {
$sela = $redis->hSet($field, $id, json_encode($v));
if ($sela) {
return true;
} else {
return false;
}
}
}
}

/**
 * 指定ID数据重存更新
 * @Author Xven　<270988107@qq.com>
 * @param  [type]                  $id   [description]
 * @param  [type]                  $name [description]
 * @return [type]                        [description]
 */
function del_redis($field, $id) {
$redis = Cache::store('redis');
$info = $redis->hDel($field, $id);
if ($info) {
return true;
} else {
return false;
}
}

原文地址：https://blog.csdn.net/qq_35748913/article/details/143338502

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！