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;

// 創(chuàng)建一個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);
    
    // 根據請求類型執(zhí)行相應的操作
    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");
}

// 發(fā)送請求消息到緩存服務器
function sendRequest($type, $key, $value = '')
{
    global $client;
    
    $request = json_encode(['type' => $type, 'key' => $key, 'value' => $value]);
    
    // 發(fā)送請求消息
    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