PHP實現遠程過程調用RPC

一、初識RPC

RPC（Remote Procedure Call）—遠程過程調用，它是一種通過網絡從遠程計算機程序上請求服務，而不需要了解底層網絡技術的協議。

二、工作原理

運行時,一次客戶機對服務器的RPC調用,其內部操作大致有如下十步：

• 1.調用客戶端句柄；執行傳送參數
• 2.調用本地系統內核發送網絡消息
• 3.消息傳送到遠程主機
• 4.服務器句柄得到消息并取得參數
• 5.執行遠程過程
• 6.執行的過程將結果返回服務器句柄
• 7.服務器句柄返回結果，調用遠程系統內核
• 8.消息傳回本地主機
• 9.客戶句柄由內核接收消息
• 10.客戶接收句柄返回的數據
  (以上信息來自百度百科)

三、在PHP中的實現

• 文件結構

zrj@zrj:~/www/zhangrenjie_test/test/rpc$ tree
├── Client.php
└── Provider
    ├── index.php
    └── Services
        └── UserService.php

• 客戶端Client.php

class Client
{
    private $serviceUrl;
    private $serviceName;
    private $rpcConfig = [
        'UserService' => 'http://127.0.0.1:8081',
    ];

    public function __construct($serviceName)
    {
        if (array_key_exists($serviceName, $this->rpcConfig)) {
            $this->serviceUrl = $this->rpcConfig[$serviceName];
            $this->serviceName = $serviceName;
        }
    }

    // __call() is triggered when invoking inaccessible methods in an object context.
    //調用不可訪問的方法
    public function __call($actionName, $arguments)
    {
        $content = json_encode($arguments);
        $options['http'] = [
            'timeout' => 5,
            'method' => 'POST',
            'header' => 'Content-type:applicaion/x-www-form-urlencoode',
            'content' => $content,
        ];
        //創建資源流上下文
        $context = stream_context_create($options);

        $get = [
            'service_name' => $this->serviceName,
            'action_name' => $actionName
        ];

        $serviceUrl = $this->serviceUrl . '?' . http_build_query($get);
        $result = file_get_contents($serviceUrl, false, $context);
        return json_decode($result, true);
    }
}

$userService = new Client('UserService');
$result=$userService->getUserInfo(random_int(1,10));
var_dump($result);

步驟：

• 1.注冊服務$rpcConfig。
• 2.實例化客戶端時，指定服務名稱。
• 3.訪問對象不可訪問的方法getUserInfo，自動調用__call魔術方法。
• 4.在__call魔術方法中想指定的遠程服務發送請求（http://127.0.0.1:8081）

• 服務提供者(Service Provider)的實現

Provider目錄為演示的服務提供者的總目錄,index.php為管理調度服務的入口。
Provider\Services目錄為所有服務類目錄。

服務調度入口：index.php

namespace rpc\Provider;

require_once './Services/UserService.php';

use rpc\Provider\Services\{
    UserService
};

$serviceName = trim($_GET['service_name']);
$serviceAction = trim($_GET['action_name']);
$argv = file_get_contents("php://input");
if (empty($serviceName) || empty($serviceAction)) die('paramas is missing');
if (!empty($argv)) {
    $argv = json_decode($argv, true);
}

$result = call_user_func_array([$serviceName, $serviceAction], $argv);
echo  json_encode($result);

User服務：UserService.php

namespace rpc\Provider\Services;

class UserService
{
    public static function getUserInfo(int $uid): array
    {
        return [
            'id' => $uid,
            'user_name' => 'jack_' . $uid,
        ];
    }
}

開啟服務：對外提供服務遠程調用地址(http://127.0.0.1:8081)。

#這里我們利用PHP自帶的cli模式開啟服務
php -S 127.0.0.1:8080 -t /www/zhangrenjie_test/test/rpc/Provider

至此，大功告成。

了解php開啟服務，請參照沒有第三方web服務，怎么運行php？