zhamao-robot/zhamao-framework
1
0
Fork 0
mirror of https://github.com/zhamao-robot/zhamao-framework.git synced 2026-07-20 15:15:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

change to psr-16

Browse Source
This commit is contained in:
crazywhalecc
2022-12-31 19:02:41 +08:00
parent ab83194bbe
commit a2404482a3
5 changed files with 59 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/ZM/Store/KV/KVInterface.php
View File

@@ -1,47 +1,10 @@
<?php
declare(strict_types=1);
namespace ZM\Store\KV;
use Psr\SimpleCache\CacheInterface;
interface KVInterface
{
/**
* 打开一个 KV 库
*
* @param string $name KV 的库名称
*/
public static function open(string $name = ''): KVInterface;
/**
* 返回一个 KV 键值对的数据
*
* @param string $key 键名
* @param null|mixed $default 如果不存在时返回的默认值
*/
public function get(string $key, mixed $default = null): mixed;
/**
* 设置一个 KV 键值对的数据
*
* @param string $key 键名
* @param mixed $value 键值
* @param int $ttl 超时秒数（如果等于 0 代表永不超时）
*/
public function set(string $key, mixed $value, int $ttl = 0): bool;
/**
* 强制删除一个 KV 键值对数据
*
* @param string $key 键名
* @return bool 当键存在并被删除时返回 true
*/
public function unset(string $key): bool;
/**
* 键值对数据是否存在
*
* @param string $key 键名
*/
public function isset(string $key): bool;
public static function open(string $name = ''): CacheInterface;
}

65
src/ZM/Store/KV/LightCache.php
View File

@@ -4,6 +4,7 @@ declare(strict_types=1);
namespace ZM\Store\KV;
use Psr\SimpleCache\CacheInterface;
use ZM\Exception\InvalidArgumentException;
use ZM\Process\ProcessStateManager;
use ZM\Store\FileSystem;
@@ -11,7 +12,7 @@ use ZM\Store\FileSystem;
/**
* 轻量、基于本地 JSON 文件的 KV 键值对缓存
*/
class LightCache implements KVInterface
class LightCache implements CacheInterface, KVInterface
{
/** @var array 存放库对象的列表 */
private static array $objs = [];
@@ -49,7 +50,7 @@ class LightCache implements KVInterface
/**
* @throws InvalidArgumentException
*/
public static function open(string $name = ''): KVInterface
public static function open(string $name = ''): CacheInterface
{
if (!isset(self::$objs[$name])) {
self::$objs[$name] = new LightCache($name);
@@ -82,18 +83,6 @@ class LightCache implements KVInterface
], JSON_THROW_ON_ERROR));
}
/**
* 删除该 KV 库的所有数据，并且永远无法恢复
*/
public function removeSelf(): bool
{
if (file_exists($this->find_dir . '/' . $this->name . '.json')) {
unlink($this->find_dir . '/' . $this->name . '.json');
}
unset(self::$caches[$this->name], self::$ttys[$this->name], self::$objs[$this->name]);
return true;
}
public function get(string $key, mixed $default = null): mixed
{
// 首先判断在不在缓存变量里
@@ -115,24 +104,62 @@ class LightCache implements KVInterface
/**
* @throws InvalidArgumentException
*/
public function set(string $key, mixed $value, int $ttl = 0): bool
public function set(string $key, mixed $value, null|int|\DateInterval $ttl = null): bool
{
$this->validateKey($key);
self::$caches[$this->name][$key] = $value;
if ($ttl > 0) {
if ($ttl !== null) {
if ($ttl instanceof \DateInterval) {
$ttl = $ttl->days * 86400 + $ttl->h * 3600 + $ttl->i * 60 + $ttl->s;
}
self::$ttys[$this->name][$key] = time() + $ttl;
}
return true;
}
public function unset(string $key): bool
public function delete(string $key): bool
{
unset(self::$caches[$this->name][$key], self::$ttys[$this->name][$key]);
return true;
}
public function isset(string $key): bool
public function clear(): bool
{
if (file_exists($this->find_dir . '/' . $this->name . '.json')) {
unlink($this->find_dir . '/' . $this->name . '.json');
}
unset(self::$caches[$this->name], self::$ttys[$this->name], self::$objs[$this->name]);
return true;
}
public function getMultiple(iterable $keys, mixed $default = null): iterable
{
foreach ($keys as $v) {
yield $v => $this->get($v, $default);
}
}
public function setMultiple(iterable $values, \DateInterval|int|null $ttl = null): bool
{
foreach ($values as $k => $v) {
if (!$this->set($k, $v, $ttl)) {
return false;
}
}
return true;
}
public function deleteMultiple(iterable $keys): bool
{
foreach ($keys as $v) {
if (!$this->delete($v)) {
return false;
}
}
return true;
}
public function has(string $key): bool
{
if (!isset(self::$caches[$this->name][$key])) {
return false;