实现Workerman文档中的分布式缓存功能

sudo apt-get install redis-server

composer require workerman/workerman

<?php
require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;
use WorkermanWebServer;

$worker = new Worker();
$worker->count = 4;

// 创建一个Redis连接
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 处理客户端连接
$worker->onConnect = function ($connection) use ($redis) {
    // 设置connection的缓存对象为redis
    $connection->cache = $redis;
};

// 处理客户端消息
$worker->onMessage = function ($connection, $data) {
    // 解析请求数据
    $request = json_decode($data, true);
    
    // 根据请求类型执行相应的操作
    switch ($request['type']) {
        case 'get':
            // 从缓存中取出数据
            $value = $connection->cache->get($request['key']);
            // 将结果返回给客户端
            $connection->send($value);
            break;
        case 'set':
            // 将数据写入缓存
            $connection->cache->set($request['key'], $request['value']);
            // 返回给客户端操作成功的消息
            $connection->send('OK');
            break;
        default:
            // 返回给客户端未知的请求类型
            $connection->send('Unknown request type');
            break;
    }
};

// 运行worker
Worker::runAll();
?>

<?php
require_once __DIR__ . '/vendor/autoload.php';

$client = stream_socket_client('tcp://127.0.0.1:8080', $errno, $errmsg);
if (!$client) {
    exit("Stream socket client create failed. Errno=$errno, errmsg=$errmsg");
}

// 发送请求消息到缓存服务器
function sendRequest($type, $key, $value = '')
{
    global $client;
    
    $request = json_encode(['type' => $type, 'key' => $key, 'value' => $value]);
    
    // 发送请求消息
    fwrite($client, $request . "
");
    
    // 读取服务器响应
    $response = fgets($client);
    
    return $response;
}

// 示例：向缓存服务器写入数据
$result = sendRequest('set', 'my_cache_key', 'Hello, Workerman!');
echo "Set cache result: $result
";

// 示例：从缓存服务器读取数据
$result = sendRequest('get', 'my_cache_key');
echo "Get cache result: $result
";

fclose($client);
?>

php DistributedCacheServer.php start -d
php DistributedCacheClient.php