使用TCP Client 调用Swoft RPC 服务

$client = new \swoole_client(SWOOLE_SOCK_TCP);

if (!$client->connect('10.10.10.15', 18307, 0.5))
{
    return "connect failed. Error: {$client->errCode}\n";
}

$client->send(json_encode([
                "jsonrpc" => '2.0',
                "method" => sprintf("%s::%s::%s", "1.2",  \App\Rpc\Lib\UserInterface::class, 'getList'),
                'params' => [1,2],
                'id' => '',
                'ext' => []
            ])."\r\n\r\n");// 旧版不需要追加\r\n

//或者使用字符串传递接口类名 ，上边的还可以写为，如下
$client->send(json_encode([
        "jsonrpc" => '2.0',
        "method" => sprintf("%s::%s::%s", "1.2",  'App\Rpc\Lib\UserInterface', 'getList'),
        'params' => [1,2],
        'id' => '',
        'ext' => []
    ])."\r\n\r\n");// 旧版不需要追加\r\n

$result = $client->recv();
$client->close();
return json_decode($result,true);

$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_connect($client, '127.0.0.1', 18307);
socket_write($client, json_encode([
        "jsonrpc" => '2.0',
        "method" => sprintf("%s::%s::%s", "1.2", \App\Rpc\Lib\UserInterface::class, 'getList'),
        'params' => [1, 2],
        'id' => '',
        'ext' => []
    ]) . "\r\n\r\n");

$buf = socket_read($client, 8024);

$response = json_decode($buf, true);
return $response;

<?php
const RPC_EOL = "\r\n\r\n";
function request($host, $class, $method, $param, $version = '1.0', $ext = []) {
    $fp = stream_socket_client($host, $errno, $errstr);
    if (!$fp) {
        throw new Exception("stream_socket_client fail errno={$errno} errstr={$errstr}");
    }
    $req = [
        "jsonrpc" => '2.0',
        "method" => sprintf("%s::%s::%s", $version, $class, $method),
        'params' => $param,
        'id' => '',
        'ext' => $ext,
    ];
    $data = json_encode($req) . RPC_EOL;
    fwrite($fp, $data);
    $result = '';
    while (!feof($fp)) {
        $tmp = stream_socket_recvfrom($fp, 1024);
        if ($pos = strpos($tmp, RPC_EOL)) {
            $result .= substr($tmp, 0, $pos);
            break;
        } else {
            $result .= $tmp;
        }
    }
    fclose($fp);
    return json_decode($result, true);
}
$ret = request('tcp://127.0.0.1:18307', \App\Rpc\Lib\UserInterface::class, 'getList',  [1, 2], "1.0");
var_dump($ret);