??: TP6 Think-Swoole

??:
?? ???? ??? ??? ?? ??????? ??? ???? ?? ????? ????. ? ? ?? ???? ??? ??? ???? ????? ?? ?? ? ?????. ? ????? ThinkPHP6 ? Swoole ??? ???? ?? ???? RPC ???? ???? ??? ???? ???? ?? ??? ?????.

1. ?? ??
1.1 ?? ???
?? ???? ??? ?? ??? ???? ??? ??? ???? ????? ????. ??? ???? ???? ?? ??? ???? ?? ???? ?? ?? ? ??? ??? ??? ??? ? ????.

1.2 ThinkPHP6
ThinkPHP6? ???? ?? ???? ??? ??? PHP ?? ????????. ??? ???? ??? ???? ??? ???? ???? ??? ??? ?????? ??? ?????.

1.3 Swoole ??
Swoole? ??? ??? ???? ?? ??? ???? ??? ??? ?????? ????? ??? ? ?? PHP? ?? ?????.

2. ?? ????
2.1 ???? ??
? ?? ??? RPC ???? ?? ???? ??? ???? ?????? ?? RPC ??? ?????. ?????? ?? ??? ????? ?? ?? ??? ?? RPC ??? ???? ?? ???? ?????.

2.2 Swoole ??
Swoole ?? ???? Swoole? ??? TCP ??? ???? RPC ??? ??? ? ????. ??? ??? ?? ????? ?? ? ??? ???? RPC ??? ?? ??? ?????. ??? ?? ?????? ??? ??? ???? ?? ??? ???? ??? ? ????.

2.3 ?? ??? ????
? ???? ?? ???? ???? ?? ?? ???? ?? ????? ?????. ??? ????, ?? ?? ???? ?? ?? ?? ?? ??? ?? ?? ?? ??? ????? ??? ?? ????.

3. ?? ??
??? ThinkPHP6 ? Swoole? ???? ?? ??? RPC ???? ???? ?? ?????.

1. ????? ??

use SwooleCoroutineHttpClient;

function rpcRequest($servers, $method, $params = [])
{
    $server = selectServer($servers); // 根據(jù)負(fù)載均衡算法選擇一個(gè)RPC服務(wù)器

    $client = new Client($server['host'], $server['port']);

    $client->post('/rpc', [
        'method' => $method,
        'params' => $params,
    ]);

    $response = $client->recv();

    return $response->getBody();
}

function selectServer($servers)
{
    // 輪詢算法
    static $index = 0;
    $server = $servers[$index];
    $index = ($index + 1) % count($servers);

    return $server;
}

$servers = [
    ['host' => '127.0.0.1', 'port' => 9501],
    ['host' => '127.0.0.1', 'port' => 9502],
    ['host' => '127.0.0.1', 'port' => 9503],
];

$result = rpcRequest($servers, 'hello', ['name' => 'John']);

echo $result;

2. ?? ? ??

use SwooleHttpServer;
use SwooleHttpRequest;
use SwooleHttpResponse;

$server = new Server('0.0.0.0', 9501);

$server->on('Request', function (Request $request, Response $response) {
    $data = $request->post();
    $method = $data['method'] ?? '';
    $params = $data['params'] ?? [];

    // TODO: 根據(jù)method調(diào)用對(duì)應(yīng)的RPC服務(wù)處理方法，并返回結(jié)果

    $response->header('Content-Type', 'application/json');
    $response->end(json_encode($result));
});

$server->start();

4. ThinkPHP6 ?? ?? Swoole ??? ???? ?? ??? ?? RPC ???? ?????. ???? ???? ??? ?? ??? ????? ?? ???? ??? ???? ???? ? ????. ?? ?? ??? ?? ?????? RPC ??? ?????? ?? ????? ??? ? ???, ?? ??? ?? ??? ? ?? ?????.

? ?? ??? ?? ???? TP6 Think-Swoole?? ???? ?? ??? RPC ???? ?? ???? ?? ????? ???? ??? ? ??? ????.

? ??? TP6 Think-Swoole? ??? ?? ??? RPC ???? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!