PHPackages                             cheng\_util/mqserver - 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. cheng\_util/mqserver

ActiveLibrary

cheng\_util/mqserver
====================

v1.0.5(3y ago)13MITPHP

Since Dec 1Pushed 3y ago1 watchersCompare

[ Source](https://github.com/cc2415/mq_server)[ Packagist](https://packagist.org/packages/cheng_util/mqserver)[ RSS](/packages/cheng-util-mqserver/feed)WikiDiscussions main Synced 1mo ago

READMEChangelog (6)Dependencies (6)Versions (7)Used By (0)

mq服务
====

[](#mq服务)

**composer require cheng\_util/mqserver**

配置
--

[](#配置)

```
$config = [
        'main_ip' => '192.168.10.5',
        'rbmq' => [
            'host' => '192.168.10.5',
            'port' => 5672,
            'user' => 'guest',
            'pass' => 'guest',
            'vhost' => '/',
            'debug' => true,
        ],
        'coroutine' => true,    //使用swoole协程处理mq接收到的数据
        'swoole_udp' => [   //swoole upd的配置
            'port' => 9502,
            'host' => '127.0.0.1'
        ]
    ];
```

启动消费服务
------

[](#启动消费服务)

```
/**
 * 默认消费队列，纯rbmq处理
 */

require_once __DIR__.'/../../../vendor/autoload.php';
ConsumeServer::getInstance()->setConfig($config);
ConsumeServer::getInstance()->startDefaultConsume(function($message){   //使用闭包 config的coroutine必须为false
            $message->ack();
            var_dump(json_decode($message->body, true));
        });

/**
 * 延时队列，纯rbmq处理
 */

require_once __DIR__.'/../../../vendor/autoload.php';
ConsumeServer::getInstance()->setConfig($config);
        ConsumeServer::getInstance()->startDelayConsume(function($message){   //使用闭包 config的coroutine必须为false
            $message->ack();
            var_dump($message->body);
        });

```

发送mq消息
------

[](#发送mq消息)

```
require_once __DIR__.'/../../../vendor/autoload.php';
ProducerServer::getInstance()->setConfig($config);

$time = time();
//发送普通消息 第二个参数是延时，0则为普通数据
$res = ProducerServer::getInstance()->pushMessage([
    'type' => 'default_message',
    'msg' => '普通内容',
    'time_stamp' => $time,
    'time_date' => date('Y-m-d H:i:s', $time)
], 3, true);

var_dump($res);

//协程发消息
ProducerServer::getInstance()->pushMessageCoroutine([
                'type' => 'deafult_message',
                'msg' => '普通内容',
                'time_stamp' => $time,
                'time_date' => date('Y-m-d H:i:s', $time)
            ]);
```

单独发送udp消息，不经过mq
---------------

[](#单独发送udp消息不经过mq)

```
// 单独发udp消息
SwooleUdpClientService::getInstance()->setConfig($config);
$body = SwooleUdpClientService::getInstance()->buildBody('ccc', ['asdf' => date('Y-m-d H:i:s')]);
SwooleUdpClientService::getInstance()->CoroutineSend($body);
```

### demo说明：

[](#demo说明)

1、普通消费

```
DemoDefaultConsumeServer.php 启动普通消费队列

DemoDelayConsumeServer 启动延时队列

```

2、swoole的协程消费

```
先启动对应的mq服务，普通或者延时，然后启动DemoSwooleUdpServer.php 这个udp协程处理

```

###  Health Score

23

—

LowBetter than 27% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity5

Limited adoption so far

Community7

Small or concentrated contributor base

Maturity50

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 ~0 days

Total

6

Last Release

1257d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/68709dceb591959d43720cf7dec3c999de210aab53b455d01cb24cee4385268c?d=identicon)[cc2415](/maintainers/cc2415)

---

Top Contributors

[![cc2415](https://avatars.githubusercontent.com/u/23351624?v=4)](https://github.com/cc2415 "cc2415 (13 commits)")

### Embed Badge

![Health badge](/badges/cheng-util-mqserver/health.svg)

```
[![Health](https://phpackages.com/badges/cheng-util-mqserver/health.svg)](https://phpackages.com/packages/cheng-util-mqserver)
```

###  Alternatives

[brianium/paratest

Parallel testing for PHP

2.5k118.8M754](/packages/brianium-paratest)[magento/community-edition

Magento 2 (Open Source)

12.1k52.1k10](/packages/magento-community-edition)[wheelpros/fitment-platform-api

Magento 2 (Open Source)

12.1k1.2k](/packages/wheelpros-fitment-platform-api)[laravel/browser-kit-testing

Provides backwards compatibility for BrowserKit testing in the latest Laravel release.

5139.4M286](/packages/laravel-browser-kit-testing)[flow-php/flow

PHP ETL - Extract Transform Load - Data processing framework

81733.7k](/packages/flow-php-flow)[robiningelbrecht/phpunit-coverage-tools

PHPUnit coverage tools

1783.0k34](/packages/robiningelbrecht-phpunit-coverage-tools)

PHPackages © 2026

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