如何实现PHP调用分布式缓存接口_PHP分布式缓存(Redis/Cluster)接口调用教程

$redis = new Redis();
$connected = $redis->connect('127.0.0.1', 6379, 3); // host, port, timeout
if (!$connected) {
    die("无法连接到Redis服务器");
}
$redis->auth('your_password'); // 若启用了密码认证
$redis->select(0); // 选择数据库

// 基本操作
$redis->set('key:1', 'Hello Redis');
$value = $redis->get('key:1');
echo $value; // 输出: Hello Redis

$redis = new Redis();
// 提供多个节点地址，客户端自动发现整个集群拓扑
$clusterNodes = [
    'tcp://192.168.1.10:7000',
    'tcp://192.168.1.11:7001',
    'tcp://192.168.1.12:7002'
];

$options = [
    'cluster' => 'redis', // 必须设置为'redis'
    'timeout' => 2.0,
    'read_timeout' => 2.0
];

$redis->connect($clusterNodes, 0, $options);

// 集群环境下仍可使用标准命令
$redis->set('user:1001', json_encode(['name' => 'Alice', 'age' => 28]));
$userData = $redis->get('user:1001');
print_r(json_decode($userData, true));

class CacheClient {
    private $handler;

    public function __construct($servers, $isCluster = false) {
        $this->handler = new Redis();

        if ($isCluster) {
            $this->handler->connect($servers, 0, ['cluster' => 'redis']);
        } else {
            $host = $servers[0]['host'];
            $port = $servers[0]['port'];
            $this->handler->connect($host, $port, 3);
            if (!empty($servers[0]['auth'])) {
                $this->handler->auth($servers[0]['auth']);
            }
        }
    }

    public function set($key, $value, $ttl = 3600) {
        return $this->handler->set($key, $value, $ttl);
    }

    public function get($key) {
        return $this->handler->get($key);
    }

    public function del($key) {
        return $this->handler->del($key);
    }

    public function exists($key) {
        return $this->handler->exists($key);
    }
}

// 使用示例：连接集群
$servers = [
    'tcp://192.168.1.10:7000',
    'tcp://192.168.1.11:7001'
];
$cache = new CacheClient($servers, true);
$cache->set('token:abc123', 'logged_in_user_556', 600);
echo $cache->get('token:abc123');