gmono/amqp-rpc

There is no license information available for the latest version (dev-master) of this package.

a packages using amqplib to call remote services

dev-master 2025-02-28 08:02 UTC

Requires

• php: >=7.2 <8.0
• athari/yalinqo: ^2.5
• bunny/bunny: @dev
• php-amqplib/php-amqplib: ^3.6
• ramsey/uuid: ^4.2
• react/event-loop: ^1.5
• react/promise: ^3.1
• reactivex/rxphp: ^2.0

Unknown License

README

HTTP Return RPC通信版本

1. 提供一个putResult接口用于外部提交返回结果（可对接到同步http接口
2. 提供一个中心的RPCClient类
3. 提供数个包装RPCClient 通过client进行api调用的类

中心路由API（system）

id为system用于调用节点适配器api，可以进行系统级设置如修改结果提交url等

程序管理器API（manager）

id为manager用于调用节点程序管理器api，支持获取节点程序列表，程序启停 状态监控等

样例说明

dev-http版本基本使用

use AmqpRPC\HTTP\HttpRPCClient;
use AmqpRPC\HTTP\SystemApi;

use AmqpRPC\HTTP;
use AmqpRPC\Lib\MQAddress;

$addr=new MQAddress();
$addr->host="159.75.243.179";
$addr->vhost="bthost";
$addr->username="test";
$addr->password="testtest";
$addr->port=5672;
$client=new HttpRPCClient($addr);

//tp5接口 post 文本body参数 直接传递到putResult
function postResult(string $jsontext){
    global $client;
    $client->putResult($jsontext);
}

//其他接口 调用api并设置返回后执行的操作
function otherPort(){
    global $client;
    $api=new SystemApi($client);
    $api->Hello(["1","2"])->then(function($res){
        echo $res;
    })->catch(function($err){
        echo $err;
    });
}

function init()
{
    global $client;
    $api=new SystemApi($client);
    $api->setReturnUrl("xxxxxx");
}

主版本说明

基于amqp 的RPC库

接口

create(address,port,vhost) 自动配置交换机（使用topic交换机 基于service自动路由 async call(serviceid,funcname,pars:[])->json result

基本使用

主要类:RPCClient 自动装配：

1. 注入RPCClient类型到服务容器中
2. 注入IRPCClient单例到或factory服务容器中

手动指定port:

1. 直接注入一个创建好的RPCClient对象到服务容器中

Ports

1. LocalRPCPort 调试用port，本地异步调用