gmono/amqp-rpc
Composer 安装命令:
composer require gmono/amqp-rpc
包简介
a packages using amqplib to call remote services
README 文档
README
HTTP Return RPC通信版本
- 提供一个putResult接口用于外部提交返回结果(可对接到同步http接口
- 提供一个中心的RPCClient类
- 提供数个包装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 自动装配:
- 注入RPCClient类型到服务容器中
- 注入IRPCClient单例到或factory服务容器中
手动指定port:
- 直接注入一个创建好的RPCClient对象到服务容器中
Ports
- LocalRPCPort 调试用port,本地异步调用
统计信息
- 总下载量: 0
- 月度下载量: 0
- 日度下载量: 0
- 收藏数: 0
- 点击次数: 0
- 依赖项目数: 0
- 推荐数: 0
其他信息
- 授权协议: Unknown
- 更新时间: 2025-02-18