企业🤖AI Agent构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
[TOC] ## 安装 `composer require easyswoole/fast-cache` ## 注册,支持落地重启恢复数据 在`easyswooleEvent.php` 的` mainServerCreate` 方法中注册 ``` use EasySwoole\FastCache\Cache; use EasySwoole\FastCache\CacheProcessConfig; use EasySwoole\FastCache\SyncData; use EasySwoole\Utility\File; // 每隔5秒将数据存回文件 Cache::getInstance()->setTickInterval(5 * 1000);//设置定时频率 Cache::getInstance()->setOnTick(function (SyncData $SyncData, CacheProcessConfig $cacheProcessConfig) { $data = [ 'data' => $SyncData->getArray(), 'queue' => $SyncData->getQueueArray(), 'ttl' => $SyncData->getTtlKeys(), // queue支持 'jobIds' => $SyncData->getJobIds(), 'readyJob' => $SyncData->getReadyJob(), 'reserveJob' => $SyncData->getReserveJob(), 'delayJob' => $SyncData->getDelayJob(), 'buryJob' => $SyncData->getBuryJob(), ]; $path = EASYSWOOLE_TEMP_DIR . '/FastCacheData/' . $cacheProcessConfig->getProcessName(); File::createFile($path,serialize($data)); }); // 启动时将存回的文件重新写入 Cache::getInstance()->setOnStart(function (CacheProcessConfig $cacheProcessConfig) { $path = EASYSWOOLE_TEMP_DIR . '/FastCacheData/' . $cacheProcessConfig->getProcessName(); if(is_file($path)){ $data = unserialize(file_get_contents($path)); $syncData = new SyncData(); $syncData->setArray($data['data']); $syncData->setQueueArray($data['queue']); $syncData->setTtlKeys(($data['ttl'])); // queue支持 $syncData->setJobIds($data['jobIds']); $syncData->setReadyJob($data['readyJob']); $syncData->setReserveJob($data['reserveJob']); $syncData->setDelayJob($data['delayJob']); $syncData->setBuryJob($data['buryJob']); return $syncData; } }); // 在守护进程时,php easyswoole stop 时会调用,落地数据 Cache::getInstance()->setOnShutdown(function (SyncData $SyncData, CacheProcessConfig $cacheProcessConfig) { $data = [ 'data' => $SyncData->getArray(), 'queue' => $SyncData->getQueueArray(), 'ttl' => $SyncData->getTtlKeys(), // queue支持 'jobIds' => $SyncData->getJobIds(), 'readyJob' => $SyncData->getReadyJob(), 'reserveJob' => $SyncData->getReserveJob(), 'delayJob' => $SyncData->getDelayJob(), 'buryJob' => $SyncData->getBuryJob(), ]; $path = EASYSWOOLE_TEMP_DIR . '/FastCacheData/' . $cacheProcessConfig->getProcessName(); File::createFile($path,serialize($data)); }); Cache::getInstance()->setTempDir(EASYSWOOLE_TEMP_DIR)->attachToServer(ServerManager::getInstance()->getSwooleServer()); ``` ## 使用 ``` use EasySwoole\FastCache\Cache; Cache::getInstance()->set('get','a'); var_dump(Cache::getInstance()->get('get')); ```