Laravel YAR RPC Client

基于 Laravel 框架服务注册及门面的 YAR 客户端，提供优雅的 YAR RPC 服务调用。

功能特性

• 🚀 优雅的 RPC 调用方式，支持 Laravel Facade
• ⚡ 支持 HTTP Keep-Alive 持久连接
• 📝 自动生成类型提示完善的 Facade 类
• 🔧 灵活的全局配置和客户端级配置
• 🔄 支持多种序列化方式（PHP、JSON、MsgPack）
• ⏱️ 使用延迟加载（DeferrableProvider 接口）按需实例化提升性能

依赖要求

• PHP >= 7.3 || >= 8.0
• Laravel >= 5.8
• PHP YAR 扩展 (ext-yar)

安装

composer require huo-zi/laravel-yar-rpc-client

配置

1. 发布配置文件

php artisan vendor:publish --provider="Huozi\Yar\Rpc\Client\ServiceProvider"

2. 配置 RPC 服务端

编辑 config/yar_client.php 文件：

return [
    // Facade 类生成的命名空间
    'namespace' => 'App\\Rpc\\Clients\\',

    // 全局配置
    'options' => [
        // 调用超时时间（毫秒）
        \YAR_OPT_TIMEOUT => 5000,

        // 连接超时时间（毫秒）
        \YAR_OPT_CONNECT_TIMEOUT => 1000,

        // 序列化方式：php, json, msgpack
        \YAR_OPT_PACKAGER => 'php',

        // 是否启用 HTTP Keep-Alive
        \YAR_OPT_PERSISTENT => true,
    ],

    // RPC 客户端配置
    'clients' => [
        'user' => [
            'url' => 'http://api.example.com/user',
            // 客户端级配置（可选，会覆盖全局配置）
            'options' => [
                \YAR_OPT_TIMEOUT => 3000,
            ],
        ],
        'order' => [
            'url' => 'http://api.example.com/order',
        ],
    ],
];

使用

1. 生成 Facade

php artisan make:rpc_facade

此命令会自动：

• 爬取服务端的 API 方法列表
• 在 App/Rpc/Clients/ 目录生成对应的 Facade 类

2. 调用 RPC 方法

use App\Rpc\Clients\UserRpcClient;
use App\Rpc\Clients\OrderRpcClient;

// 调用远程方法
$user = UserRpcClient::getUser(1);
$users = UserRpcClient::listUsers(['page' => 1, 'limit' => 10]);

// 调用订单服务
$order = OrderRpcClient::getOrder(123);

3. 并发调用

支持并发调用多个 RPC 服务，提高请求效率：

3.1 魔术方法调用（推荐）

使用魔术方法调用：

use App\Rpc\Clients\ConcurrentRpcClient;

// 并发调用多个服务（魔术方法方式）
$result = ConcurrentRpcClient::user('getUser', [1])
    ->order('getOrder', [123])
    ->execute();

// 获取结果
$user = $result->get('user.getUser');
$order = $result->get('order.getOrder');

3.2 使用 call() 方法调用

使用 call() 方法调用：

use App\Rpc\Clients\ConcurrentRpcClient;

// 并发调用多个服务（call() 方法方式）
$result = ConcurrentRpcClient::call('user', 'getUser', [1])
    ->call('order', 'getOrder', [123])
    ->execute();

// 获取结果
$user = $result->get('user.getUser');
$order = $result->get('order.getOrder');

3.3 结果格式

// 成功示例
[
    'user.getUser' => [
        'code' => 0, // 0 表示成功
        'data' => $userData // 远程方法返回的数据
    ],
    'order.getOrder' => [
        'code' => 0,
        'data' => $orderData
    ]
]

// 失败示例（某个服务调用失败）
[
    'user.getUser' => [
        'code' => 0, // 成功
        'data' => $userData
    ],
    'order.getOrder' => [
        'code' => 1, // 失败，yar错误码
        'message' => 'Connect timeout' // 错误信息
    ]
]

并发调用特点：

• 所有请求同时发送，减少等待时间
• 自动处理错误，即使某个服务失败也不会影响其他服务
• 返回结果按 client.method 格式组织，方便获取
• 支持链式调用，代码更加简洁
• 支持两种调用方式：魔术方法和 call() 方法

配置选项说明

服务注册原理

服务提供者已实现 DeferrableProvider 接口，支持延迟加载：

// 服务容器键名格式
app('rpc.client.user');
app('rpc.client.order');

延迟加载机制：

• 服务提供者实现了 provides() 方法，返回服务标识列表
• 当首次调用某个 RPC Facade 时，Laravel 才会注册对应的服务提供者并实例化客户端

更新配置后的缓存清理

当你更新了 config/yar_client.php 中的客户端配置后，需要清理以下缓存文件：

php artisan clear-compiled

注意： 在生产环境中更新 RPC 配置后，务必执行缓存清理，否则新配置不会生效。

License

MIT License