PHPackages                             meioa/php-mqlib - 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. [Queues & Workers](/categories/queues)
4. /
5. meioa/php-mqlib

ActiveLibrary[Queues & Workers](/categories/queues)

meioa/php-mqlib
===============

A simple library for MQ message listening and sending based on php-amqplib

v1.0.0(8mo ago)01MITPHP

Since Oct 14Pushed 8mo agoCompare

[ Source](https://github.com/cpptpp/php-mqlib)[ Packagist](https://packagist.org/packages/meioa/php-mqlib)[ RSS](/packages/meioa-php-mqlib/feed)WikiDiscussions main Synced today

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

PHP-MqLib
=========

[](#php-mqlib)

A simple library for MQ message listening and sending based on php-amqplib

Installation
------------

[](#installation)

```
composer require meioa/php-mqlib
```

Example
-------

[](#example)

```
    use PhpMqlib\Consumer;
    use PhpMqlib\Producer;
    //连接配置信息
    $config = [
        'host'      => '127.0.0.1',
        'port'      => 5672,
        'login'     => 'guest',
        'password'  => 'guest',
        'vhost'     => '/',
        ];
    //定义消息处理函数
    $callback = function ($msg){
        // 方法2: 使用 has 方法检查后获取
        if ($msg->has('content_type')) {
            echo "     Content-Type (checked): " . $msg->get('content_type') . "\n";
        }
        var_export($msg->getBody());
        echo PHP_EOL;
    };
    //监听 指定队列，处理消息
    (new Consumer($config))->run('q11',$callback);

    $data = ['a'=>123,'b'=>'vv'];
    //创建 指定交换机 的连接实例
    $producer = new Producer($config,'et5');
    //发送消息
    $producer->send($data,'route');
    //发送持久化消息 ,rabbitMq-server 重启后消息不丢失
    $producer->setDeliveryMode()->send($data,'route');
    //向指定 header 类型交换机 发送 带有headers 参数的 消息
    $producer->send($data,'',['h'=>2]);
```

###  Health Score

26

—

LowBetter than 41% of packages

Maintenance59

Moderate activity, may be stable

Popularity1

Limited adoption so far

Community6

Small or concentrated contributor base

Maturity35

Early-stage or recently created project

 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

Unknown

Total

1

Last Release

262d ago

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/65895729?v=4)[cpptpp](/maintainers/cpptpp)[@cpptpp](https://github.com/cpptpp)

---

Top Contributors

[![cpptpp](https://avatars.githubusercontent.com/u/65895729?v=4)](https://github.com/cpptpp "cpptpp (1 commits)")

### Embed Badge

![Health badge](/badges/meioa-php-mqlib/health.svg)

```
[![Health](https://phpackages.com/badges/meioa-php-mqlib/health.svg)](https://phpackages.com/packages/meioa-php-mqlib)
```

###  Alternatives

[vladimir-yuldashev/laravel-queue-rabbitmq

RabbitMQ driver for Laravel Queue. Supports Laravel Horizon.

2.1k10.5M33](/packages/vladimir-yuldashev-laravel-queue-rabbitmq)[bschmitt/laravel-amqp

AMQP wrapper for Laravel and Lumen to publish and consume messages

2822.5M7](/packages/bschmitt-laravel-amqp)[jwage/phpamqplib-messenger

Symfony messenger transport for the php-amqplib/php-amqplib library.

88227.2k1](/packages/jwage-phpamqplib-messenger)[hyperf/amqp

A amqplib for hyperf.

231.3M70](/packages/hyperf-amqp)[convenia/pigeon

3334.8k](/packages/convenia-pigeon)

PHPackages © 2026

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