Swoole? ???? ??? ?? ?????? ???? ???? ??

??:
??? ??? ???? ???? ?? ?? ???? ??? ??? ??? ??????? ??????? ?? ??? ??? ? ?? ??? ????. . ??????? ??? ???? ????? ?? ?? ?????? ???? ?? ?? ??? ?????. ? ????? Swoole ??? ???? ??? ?? ?????? ???? ???? ??? ???? ???? ?? ??? ?????.

1.?????
Swoole? ?? PHP-FPM? ???? ? ?? ??? ? ?? ??? ??? ??? ? ?? PHP ?? ??? ????????. Swoole? ??? ???? ?? ??? ??? ??? ???? ???, ?? ???, ??? ???? ?????? ??? ?????.

2. ?? ?????? ???? ???? ??
?? ?????? ???? ??? ? ?? ??? ???? ???.

1. ??? ??? ? ??: ?? ??? ?? ???? ???? ? ?? ?? ?????. ??, ???? ?? ??? ?????.
2. ??? ?? ? ???: ??? ???? ????? ????? ???-???? ?? ?? ?? ??? ??? ???? ???? ???? ????? ???.
3. ??? ?? ? ???: ?? ????? ??? ???? ???? ??? ?? ??? ??? ???? ??? ????, ????? ?? ????? ??? ? ????.
4. ??? ??? ? ???: ???? ???? ???? ???? ?? ?? ??????? ?? ???? ?? ? ??? ?? ?? ??? ???? ???.

3. Swoole? ???? ?? ?????? ???? ???? ?
????? ??? KV ???? ???? ?? ?? Swoole? ???? ??? ?? ???? ???? ?? ?? ?????? ???? ?????.

1. ?? ?? ??
   ?? ?? ??? ?????? ??? 3?? Swoole ?? ??? ?????. ? ??? ??? ??? ?????.

$nodes = [
    ['host' => 'node1', 'port' => 9501],
    ['host' => 'node2', 'port' => 9502],
    ['host' => 'node3', 'port' => 9503],
];

foreach ($nodes as $node) {
    $server = new SwooleServer($node['host'], $node['port'], SWOOLE_PROCESS, SWOOLE_SOCK_TCP);
    $server->set([
        'worker_num' => 4,
        'dispatch_mode' => 2,
        'open_eof_check' => true,
        'package_eof' => "
",
    ]);
    // 注冊(cè)事件回調(diào)函數(shù)
    $server->on('connect', function ($server, $fd) {
        echo "Client {$fd}: connected
";
    });
    $server->on('receive', function ($server, $fd, $from_id, $data) {
        // 處理客戶端請(qǐng)求
        $response = handleRequest($data);
        // 返回響應(yīng)給客戶端
        $server->send($fd, $response);
    });
    $server->start();
}

2. ?? ??? ??
   ??? ???? ???? ????? ?? ??? ?? ????? ???? ???? ?????.

$router = new ConsistentHashRouter($nodes);

function handleRequest($data)
{
    // 解析請(qǐng)求數(shù)據(jù)
    $request = parseRequest($data);
    // 根據(jù)請(qǐng)求的數(shù)據(jù)找到對(duì)應(yīng)的節(jié)點(diǎn)
    $node = $router->route($request['key']);
    // 發(fā)送請(qǐng)求到對(duì)應(yīng)的節(jié)點(diǎn)
    $response = sendRequest($node, $request);
    // 返回響應(yīng)給客戶端
    return $response;
}

3. ??? ?? ? ??
   ? ??? ??? KV ?? ???? ???? ???? ???? ?????.

$storage = new KVStorage();

function sendRequest($node, $request)
{
    // 連接節(jié)點(diǎn)
    $client = new SwooleClient(SWOOLE_TCP);
    $client->connect($node['host'], $node['port']);
    // 發(fā)送請(qǐng)求
    $client->send($request);
    // 接收響應(yīng)
    $response = $client->recv();
    // 關(guān)閉連接
    $client->close();
    return $response;
}

function handleRequest($data)
{
    // 解析請(qǐng)求數(shù)據(jù)
    $request = parseRequest($data);
    // 根據(jù)請(qǐng)求類型執(zhí)行相應(yīng)的操作
    if ($request['type'] == 'get') {
        return $storage->get($request['key']);
    } elseif ($request['type'] == 'set') {
        $storage->set($request['key'], $request['value']);
        return 'OK';
    } else {
        return 'Unknown command';
    }
}

class KVStorage
{
    private $data = [];
    
    public function get($key)
    {
        if (isset($this->data[$key])) {
            return $this->data[$key];
        } else {
            return 'Not found';
        }
    }
    
    public function set($key, $value)
    {
        $this->data[$key] = $value;
    }
}

IV.Summary
? ???? Swoole Extension? ???? ??? ?? ?????? ???? ???? ??? ???? ??? ?? ??? ?????. ?? ????? ??? ???, ?? ?? ?? ?? ? ?? ??? ???? ???. ? ?? ?? ?????? ???? ??? Swoole? ??? ???? ? ??? ??? ????.

? ??? Swoole? ???? ??? ?? ?????? ???? ???? ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!