# 5.7 RPC
RPC(Remote Procedure Call)即遠程過程調用,是指網絡計算機之間相互調用過程函數,而不需要關心底層的網絡通信。MSF的RPC 目前是基于Http協議,當然使用者不需要關心,因為后續有可能會有調整。
MSF實現的RPC具體的基本原則是:
1. 任何類可導出并提供服務
2. RPC Client與RPC Server的類名與方法名一致
3. 任何服務可以很方便的導出自己的類與類方法
## 服務配置
```php
<?php
/**
* RPC服務配置
*
* @author camera360_server@camera360.com
* @copyright Chengdu pinguo Technology Co.,Ltd.
*/
$config['service']['demo']['host'] = 'http://127.0.0.1:8000';
$config['service']['demo']['timeout'] = 2000;
return $config;
```
示例配置代碼:
[https://github.com/pinguo/php-msf-demo/config/docker/rpc.php](https://github.com/pinguo/php-msf-demo/blob/master/config/docker/rpc.php)
## 導出服務
```php
<?php
/**
* RPC示例Handler
*/
namespace App\Models\Handlers;
use PG\MSF\Models\Model;
class Sum extends Model
{
public $a;
public function __construct($a = 0)
{
$this->a = $a;
}
/**
* 求和
*
* @param array ...$args
* @return float|int
*/
public function multi(...$args)
{
return array_sum($args);
}
}
```
示例配置代碼:
[https://github.com/pinguo/php-msf-demo/app/Models/Handlers/Sum.php](https://github.com/pinguo/php-msf-demo/blob/master/app/Models/Handlers/Sum.php)
## 調用服務
```php
<?php
/**
* RPC示例控制器
*
* @author camera360_server@camera360.com
* @copyright Chengdu pinguo Technology Co.,Ltd.
*/
namespace App\Controllers;
use PG\MSF\Controllers\Controller;
use PG\MSF\Client\RpcClient;
class RpcTest extends Controller
{
public function actionGetSum()
{
/**
* @var RpcClient $client
*/
$client = $this->getObject(RpcClient::class, ['demo']);
$sum = yield $client->handler('sum')->multi(1, 2, 3, 4, 5);
$this->outputJson($sum);
}
}
```
`$this->getObject(RpcClient::class, ['demo']);`注意第二個參數表示調用哪一個服務,和配置相對應。
## 并行調用服務
```php
<?php
/**
* RPC示例控制器
*
* @author camera360_server@camera360.com
* @copyright Chengdu pinguo Technology Co.,Ltd.
*/
namespace App\Controllers;
use PG\MSF\Controllers\Controller;
use PG\MSF\Client\RpcClient;
class RpcTest extends Controller
{
public function actionConcurrentSum()
{
$rpc[] = $this->getObject(RpcClient::class, ['demo'])->handler('sum')->func('multi', 1, 2, 3, 4, 5);
$rpc[] = $this->getObject(RpcClient::class, ['demo'])->handler('sum')->func('multi', 1, 2, 3, 4);
$rpc[] = $this->getObject(RpcClient::class, ['demo'])->handler('sum')->func('multi', 1, 2, 3);
$rpc[] = $this->getObject(RpcClient::class, ['demo'])->handler('sum')->func('multi', 1, 2);
$sum = yield RpcClient::goConcurrent($rpc);
$this->outputJson($sum);
}
}
```
`RpcClient::goConcurrent($rpc);`可以并行發送RPC請求,然后依次獲取結果。
- 0 文檔說明
- 1 為什么研發新框架
- 1.1 傳統php-fpm工作模式的問題
- 1.2 壓測數據對比
- 1.3 小結
- 2 微服務框架研發概覽
- 2.1 通信框架技術選型
- 2.2 swoole
- 2.3 協程原理
- 2.4 異步、并發
- 2.5 小結
- 3 框架運行環境
- 3.1 環境變量
- 3.2 運行代碼
- 3.3 docker
- 3.4 小結
- 4 框架結構
- 4.1 結構概述
- 4.2 控制器
- 4.3 模型
- 4.4 視圖
- 4.5 同步任務
- 4.6 配置
- 4.7 路由
- 4.8 小結
- 5 框架組件
- 5.1 協程
- 5.2 類的加載
- 5.3 異步Http Client
- 5.4 請求上下文
- 5.5 連接池
- 5.6 對象池
- 5.7 RPC
- 5.8 公共庫
- 5.9 RESTful
- 5.10 多語言
- 5.11 雜項
- 5.12 小結
- 6 常見問題
- 7 附錄