- 基于 workerman 的多进程 RPC 框架
- 状态可维持,支持多次调用
- 首部固定 10 个字符长度用来保存整个数据包长度,位数不够左补 0
- 数据格式为 json 字符串
0000000068{"code":0,"message":"ok","data":["hello world, hello u!"]}
# 安装
composer require majorbio/rpc
# 发布配置文件
php artisan vendor:publish --provider="majorbio\rpc\Providers\RpcServiceProvider"
一、 配置 /config/rpc.php
<?php
return [
// 进程的名称
'name' => env('RPC_NAME', 'MajorbioRpc'),
// 监听端口
'port' => env('RPC_PORT', 39000),
// 启动进程数量
'count' => env('RPC_WORKER_COUNT', 4),
// RPC 服务文件命名空间
'rpcNameSpace' => '\\App\\Rpc\\',
// 指定 workerman 的 pid 文件
'pidFile' => storage_path() . '/workerman/rpc/workerman.pid',
// 指定 workerman 的 log 文件
'logFile' => storage_path() . '/workerman/rpc/workerman.log',
// 省略 -d 参数
'daemonize' => env('RPC_DAEMONIZE', false),
];
二、创建 RPC 服务 /app/Rpc/Calculator.php
<?php
namespace App\Rpc;
use majorbio\helper\RS;
class Calculator
{
public int $a = 1;
public int $b = 2;
/**
* 设置 a
*
* @param int $a
*
* @return void
*/
public function setA(int $a = 0)
{
$this->a = $a;
}
/**
* 设置 b
*
* @param int $a
*
* @return void
*/
public function setB(int $b = 0)
{
$this->b = $b;
}
/**
* 求和
*
* @return RS
*/
public function sum(): RS
{
return new RS(0, 'Calculator-sum', ($this->a + $this->b));
}
/**
* 相乘
*
* @return int
*/
public function multiply(): int
{
return $this->a * $this->b;
}
}
三、运行 RPC 服务
php artisan rpc start
<?php
use majorbio\rpc\Client as RpcClient;
// 创建 RpcClient
$rpcClient = new RpcClient('127.0.0.1', 30106);
// 调用 setA 方法(注意传参是个数组)
$rpcClient->invoke('Calculator', 'setA', [5]);
// 调用 setB 方法(注意传参是个数组)
$rpcClient->invoke('Calculator', 'setB', [3]);
// 调用 sum 方法
var_dump($rpcClient->invoke('Calculator', 'sum'));
// 调用 multiply 方法
var_dump($rpcClient->invoke('Calculator', 'multiply'));
$rpcClient->disconnect();