利用PHP实现RPC的代码示例

<?php
interface MyAPI {
    public function myMethod($param1, $param2);
}
?>

<?php
class MyAPIImpl implements MyAPI {
    public function myMethod($param1, $param2) {
        // 在这里实现方法的具体逻辑
        return $param1 + $param2;
    }
}
?>

<?php
class MyServer {
    private $obj;
    public function __construct($obj) {
        $this->obj = $obj;
    }
    public function handleRequest() {
        $request = json_decode(file_get_contents('php://input'), true);
        if(isset($request['method']) && isset($request['params'])) {
            $method = $request['method'];
            $params = $request['params'];
            if(method_exists($this->obj, $method)) {
                $result = call_user_func_array([$this->obj, $method], $params);
                $response = [
                    'result' => $result
                ];
            } else {
                $response = [
                    'error' => 'Method not found'
                ];
            }
        } else {
            $response = [
                'error' => 'Invalid request'
            ];
        }
        header('Content-Type: application/json');
        echo json_encode($response);
    }
}
// 创建服务器，并传入实现接口的类对象
$server = new MyServer(new MyAPIImpl());
// 处理请求
$server->handleRequest();
?>

<?php
class MyClient {
    private $url;
    public function __construct($url) {
        $this->url = $url;
    }
    public function callMethod($method, $params) {
        $data = [
            'method' => $method,
            'params' => $params
        ];
        $json = json_encode($data);
        $curl = curl_init();
        curl_setopt_array($curl, [
            CURLOPT_URL => $this->url,
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_POST => true,
            CURLOPT_POSTFIELDS => $json,
            CURLOPT_HTTPHEADER => [
                'Content-Type: application/json',
                'Content-Length: ' . strlen($json)
            ]
        ]);
        $response = curl_exec($curl);
        curl_close($curl);
        return json_decode($response, true);
    }
}
// 创建客户端，并指定服务器地址
$client = new MyClient('http://localhost/api.php');
// 调用远程方法
$result = $client->callMethod('myMethod', [1, 2]);
echo $result['result']; // 输出3
?>