PHPackages                             huaji-team/rabbitmq-client - 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. huaji-team/rabbitmq-client

ActiveLibrary

huaji-team/rabbitmq-client
==========================

v1.1(5y ago)040PHP

Since Jan 6Pushed 5y ago1 watchersCompare

[ Source](https://github.com/huaji-team/rabbitmq-client)[ Packagist](https://packagist.org/packages/huaji-team/rabbitmq-client)[ RSS](/packages/huaji-team-rabbitmq-client/feed)WikiDiscussions main Synced 1mo ago

READMEChangelogDependencies (1)Versions (4)Used By (0)

说明
==

[](#说明)

RabbitMQ 是一个很常用的消息中间件，但是官方提供客户端比较难用，好理解使用方便为目的，再次封装一下。

安装
==

[](#安装)

```
composer require huaji-team/rabbitmq-client
```

生产消息
====

[](#生产消息)

```
use PhpRabbitMQClient\Config;
use PhpRabbitMQClient\Client;
use PhpRabbitMQClient\Message\ProducerMessage;

$conf = new Config([
    'host' => '*****',
    'port' => 5672,
    'user' => 'admin',
    'password' => '123456',
    'vhost' => '/',
]);

$client = new Client($conf);

$msg = new ProducerMessage(
    [
        'a' => 1,
        'b' => 2
    ],
    'liu-exchange',
    'liu-routeking'
);

$client->produce($msg);
```

默认的交换机的是 主题型的可以通过

```
  $msg->getExchangeBuilder()
```

获取交换机类进行设置。

消费消息
====

[](#消费消息)

```
use PhpRabbitMQClient\Config;
use PhpRabbitMQClient\Client;
use PhpRabbitMQClient\Message\ConsumerMessage;
use PhpAmqpLib\Message\AMQPMessage;

$conf = new Config([
    'host' => '*****',
    'port' => 5672,
    'user' => 'admin',
    'password' => '123456',
    'vhost' => '/',
]);

$client = new Client($conf);

class Consumer extends ConsumerMessage
{
    public function __construct(string $exchange, $routingKey, string $queue)
    {
        parent::__construct($exchange, $routingKey, $queue);
    }

    public function consumeMessage($data, \PhpAmqpLib\Message\AMQPMessage $message): bool
    {
        print_r($data);

        return true;
    }
}

$consumer = new Consumer('liu-exchange', 'liu-routeking', 'liu-queue');
//$consumer->setNoACK(true);
//$consumer->isRequeue(false);

$client->consume($consumer);
```

首先要 创建一个 消费的类继承 ConsumerMessage类， consumeMessage方法就是写回调的逻辑。

默认 NoACK 是 false ，可以通过 $consumer->setNoACK(true); 设置不需要确认。

消息需要确认时候，回调里面 要return true 表示处理成功， retrun false 表示消费失败，会重新放到队列。 当抛出异常时候， 会根据是否方法队列就行判断，默认是放回队列，可以通过 $consumer->isRequeue(false) 就行设置，是放回队列还是丢弃。

###  Health Score

25

—

LowBetter than 37% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity8

Limited adoption so far

Community7

Small or concentrated contributor base

Maturity55

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

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.

###  Release Activity

Cadence

Every ~64 days

Total

2

Last Release

1887d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/6397eacfb2d02312520eeb74bcd3cc8f86aff55c2c053c562a3de0cced656b69?d=identicon)[liuzhang](/maintainers/liuzhang)

---

Top Contributors

[![liuzhang](https://avatars.githubusercontent.com/u/3394759?v=4)](https://github.com/liuzhang "liuzhang (2 commits)")

### Embed Badge

![Health badge](/badges/huaji-team-rabbitmq-client/health.svg)

```
[![Health](https://phpackages.com/badges/huaji-team-rabbitmq-client/health.svg)](https://phpackages.com/packages/huaji-team-rabbitmq-client)
```

###  Alternatives

[magento/community-edition

Magento 2 (Open Source)

12.1k52.1k10](/packages/magento-community-edition)[vladimir-yuldashev/laravel-queue-rabbitmq

RabbitMQ driver for Laravel Queue. Supports Laravel Horizon.

2.1k9.8M30](/packages/vladimir-yuldashev-laravel-queue-rabbitmq)[php-amqplib/rabbitmq-bundle

Integrates php-amqplib with Symfony & RabbitMq. Formerly emag-tech-labs/rabbitmq-bundle, oldsound/rabbitmq-bundle.

1.3k20.1M65](/packages/php-amqplib-rabbitmq-bundle)[bschmitt/laravel-amqp

AMQP wrapper for Laravel and Lumen to publish and consume messages

2752.3M7](/packages/bschmitt-laravel-amqp)[wheelpros/fitment-platform-api

Magento 2 (Open Source)

12.1k1.2k](/packages/wheelpros-fitment-platform-api)[enqueue/amqp-lib

Message Queue Amqp Transport

1078.5M61](/packages/enqueue-amqp-lib)

PHPackages © 2026

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