TP6 Think-Swoole RPC服务的分布式缓存管理实践

<?php
namespace appdriver;
use thinkCache;
use thinkacadeConfig;
use thinkacadeLog;
use thinkacadeEnv;

class DistributedCache extends Cache
{
    public function __construct($options = [])
    {
        // 获取RPC服务配置
        $rpcConfig = Config::get('rpc');
        // 获取当前节点信息
        $currentNode = $rpcConfig['nodes'][Env::get('APP_HOST')];
    
        // 根据配置创建RPC客户端
        $rpc = new RpcClient($currentNode['ip'], $currentNode['port']);
    
        parent::__construct($options);
    }
    
    public function get($name, $default = false)
    {
        // 通过RPC调用远程节点的缓存读取方法
        $value = $rpc->call('Cache', 'get', [$name]);
    
        if ($value === false) {
            return $default;
        } else {
            return $value;
        }
    }

    public function set($name, $value, $expire = null)
    {
        // 通过RPC调用远程节点的缓存写入方法
        $result = $rpc->call('Cache', 'set', [$name, $value, $expire]);
    
        return $result;
    }
    
    // 其他操作方法的实现
}

<?php

return [
    // 默认缓存驱动
    'default' => 'distributed',

    // 分布式缓存驱动
    'distributed' => [
        'type' => 'appdriverDistributedCache'
    ],
];

<?php
namespace appcontroller;
use thinkacadeCache;

class Index
{
    public function index()
    {
        $value = Cache::get('key');
        // ...
    }
}