PHPackages                             gmono/amqp-rpc - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [API Development](/categories/api)
4. /
5. gmono/amqp-rpc

ActiveLibrary[API Development](/categories/api)

gmono/amqp-rpc
==============

a packages using amqplib to call remote services

00PHP

Since Feb 28Pushed 1y ago1 watchersCompare

[ Source](https://github.com/gmono/php-ampq-rpc2)[ Packagist](https://packagist.org/packages/gmono/amqp-rpc)[ RSS](/packages/gmono-amqp-rpc/feed)WikiDiscussions master Synced 1mo ago

READMEChangelogDependenciesVersions (2)Used By (0)

版本说明
====

[](#版本说明)

HTTP Return RPC通信版本
-------------------

[](#http-return-rpc通信版本)

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

### 中心路由API（system）

[](#中心路由apisystem)

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

### 程序管理器API（manager）

[](#程序管理器apimanager)

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
-----

[](#ports)

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

###  Health Score

14

—

LowBetter than 2% of packages

Maintenance34

Infrequent updates — may be unmaintained

Popularity0

Limited adoption so far

Community4

Small or concentrated contributor base

Maturity17

Early-stage or recently created project

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

### Community

Maintainers

![](https://www.gravatar.com/avatar/f588ab831a766180fcdad0732001dd8f54ee2cc140e14a83733c2c4021c14414?d=identicon)[gmono](/maintainers/gmono)

### Embed Badge

![Health badge](/badges/gmono-amqp-rpc/health.svg)

```
[![Health](https://phpackages.com/badges/gmono-amqp-rpc/health.svg)](https://phpackages.com/packages/gmono-amqp-rpc)
```

###  Alternatives

[stripe/stripe-php

Stripe PHP Library

4.0k143.3M480](/packages/stripe-stripe-php)[twilio/sdk

A PHP wrapper for Twilio's API

1.6k92.9M272](/packages/twilio-sdk)[knplabs/github-api

GitHub API v3 client

2.2k15.8M187](/packages/knplabs-github-api)[facebook/php-business-sdk

PHP SDK for Facebook Business

90121.9M34](/packages/facebook-php-business-sdk)[meilisearch/meilisearch-php

PHP wrapper for the Meilisearch API

73813.7M114](/packages/meilisearch-meilisearch-php)[google/gax

Google API Core for PHP

263103.1M454](/packages/google-gax)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)