ihuangzhu/guzzle-jsonrpc

Guzzle 的 JSON-RPC 2.0 客户端

3.2.1 2016-02-16 15:18 UTC

README

Master branch build status Coverage Status Quality Score Published version PHP ~5.5 MIT Licensed

此库实现了 Guzzle HTTP 客户端的 JSON-RPC 2.0。我们尽量支持所有常用的 Guzzle 版本,包括

您可以选择任何方式安装,但我们推荐使用 Composer

{
    "require": {
        "graze/guzzle-jsonrpc": "~3.0"
    }
}

文档

<?php
use Graze\GuzzleHttp\JsonRpc\Client;

// Create the client
$client = Client::factory('https://:8000');

// Send a notification
$client->send($client->notification('method', ['key'=>'value']));

// Send a request that expects a response
$client->send($client->request(123, 'method', ['key'=>'value']));

// Send a batch of requests
$client->sendAll([
    $client->request(123, 'method', ['key'=>'value']),
    $client->request(456, 'method', ['key'=>'value']),
    $client->notification('method', ['key'=>'value'])
]);

异步请求

通过利用 Guzzle Promises 库,支持异步请求;这是 Promises/A+ 的一个实现。

<?php
use Graze\GuzzleHttp\JsonRpc\Client;

// Create the client
$client = Client::factory('https://:8000');

// Send an async notification
$promise = $client->sendAsync($client->notification('method', ['key'=>'value']));
$promise->then(function () {
    // Do something
});

// Send an async request that expects a response
$promise = $client->sendAsync($client->request(123, 'method', ['key'=>'value']));
$promise->then(function ($response) {
    // Do something with the response
});

// Send a batch of requests
$client->sendAllAsync([
    $client->request(123, 'method', ['key'=>'value']),
    $client->request(456, 'method', ['key'=>'value']),
    $client->notification('method', ['key'=>'value'])
])->then(function ($responses) {
    // Do something with the list of responses
});

在 RPC 错误时抛出异常

如果您收到 RPC 错误响应,可以通过在客户端构造函数中添加选项 [rpc_error => true] 来抛出异常。

<?php
use Graze\GuzzleHttp\JsonRpc\Client;
use Graze\GuzzleHttp\JsonRpc\Exception\RequestException;

// Create the client with the `rpc_error`
$client = Client::factory('https://:8000', ['rpc_error'=>true]);

// Create a request
$request = $client->request(123, 'method', ['key'=>'value']);

// Send the request
try {
    $client->send($request);
} catch (RequestException $e) {
    die($e->getResponse()->getRpcErrorMessage());
}

贡献

我们接受通过拉取请求(Pull Request)对源代码的贡献,但在合并之前必须包含单元测试。

~ $ make deps
~ $ make lint test

许可证

本库内容由 Nature Delivered Ltd 根据 MIT 许可证 发布。

您可以在 mit 或在 LICENSE 中找到此许可证的副本。