ThinkPHP6 ? Swoole? ???? ??? ??? RPC ???

???? ??? ??? ?? ?? ? ?? ???? ??(RPC)? ?? ????? ??? ??? ???. ???? RPC ??????? ????? HTTP ?? TCP ????? ???? ????? ? ??? ?? ? ??? ???? ??? ??? ?????.

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

1. ThinkPHP6 ??

ThinkPHP? ?? ?? ???? ??? ???? ??? PHP ?? ????????. MVC ??? ??? ??? ???, ????, ?? ?? ?? ?? ??? ??? ??? ????. ?? 6? ThinkPHP5? ???? ???? ? ????? ?? ???? ???? ??? ?????.

2. Swoole ??

Swoole? C ??? ??? ???? ??? ???? ?? ????????. ?? PHP? ??? ???? ? ?? ?? ?? ??? ???? ??? ??? ?? ???? ? ????. ???, TCP/UDP/HTTP/WebSocket? ?? ?? ????? ???? ???? ??? ? ?? ??? API? ?????.

3. RPC ??? ??

1. ThinkPHP6 ??

?? Composer? ?? ThinkPHP6? ???? ???.

composer create-project topthink/think=6.* project_name

2. Swoole ??

???? Pecl? ?? Swoole ?? ????? ???? ???.

pecl install swoole

??? ???? php.ini ??? ?? ???? ???? ???:

extension=swoole

3. RPC ?? ??

?????? RpcServer ???? ???? SwooleServer ????? ???? ??????. onReceive ???.

namespace appserver;

use SwooleServer;

class RpcServer extends Server
{
    public function onReceive($server, $fd, $reactor_id, $data)
    {
        // 解析請(qǐng)求數(shù)據(jù)
        $request = unserialize($data);
        
        // 調(diào)用對(duì)應(yīng)的方法
        $result = $this->callMethod($request['class'], $request['method'], $request['params']);
        
        // 發(fā)送響應(yīng)數(shù)據(jù)
        $server->send($fd, serialize($result));
        
        // 關(guān)閉連接
        $server->close($fd);
    }
    
    private function callMethod($class, $method, $params)
    {
        // 實(shí)例化類
        $obj = new $class();
        
        // 調(diào)用方法
        return call_user_func_array([$obj, $method], $params);
    }
}

4. RPC ????? ???

????? RpcClient ???? ??? RPC ??? ??? ????.

namespace appclient;

use SwooleClient;

class RpcClient
{
    public static function call($serverIp, $serverPort, $class, $method, $params)
    {
        $client = new Client(SWOOLE_SOCK_TCP);
        if (!$client->connect($serverIp, $serverPort)) {
            throw new Exception("Failed to connect to server");
        }
        
        // 構(gòu)建請(qǐng)求數(shù)據(jù)
        $request = serialize([
            'class' => $class,
            'method' => $method,
            'params' => $params,
        ]);
        
        // 發(fā)送請(qǐng)求數(shù)據(jù)
        $client->send($request);
        
        // 接收響應(yīng)數(shù)據(jù)
        $result = unserialize($client->recv());
        
        // 關(guān)閉連接
        $client->close();
        
        return $result;
    }
}

5. RPC ??? ??

RPC ???? ????? ????? TestController ???? ?????.

namespace appcontroller;

use appclientRpcClient;

class TestController
{
    public function index()
    {
        // 調(diào)用RPC服務(wù)
        $result = RpcClient::call('127.0.0.1', 9501, 'appserviceTestService', 'hello', ['ThinkPHP']);
        
        echo $result;
    }
}

4. ??

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

? ??? ThinkPHP6? Swoole? ???? ??? ??? RPC ???? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!