PHPackages                             maweibinguo/easyrabbitmq - 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 &amp; Workers](/categories/queues)
4. /
5. maweibinguo/easyrabbitmq

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

maweibinguo/easyrabbitmq
========================

对php-amqplib/php-amqplib包的二次封装，为常见功能提供一套开箱即用的生产解决方案

V1.0(4y ago)22431MITPHP

Since Apr 12Pushed 4y ago1 watchersCompare

[ Source](https://github.com/maweibinguo/easyrabbitmq)[ Packagist](https://packagist.org/packages/maweibinguo/easyrabbitmq)[ RSS](/packages/maweibinguo-easyrabbitmq/feed)WikiDiscussions main Synced today

READMEChangelog (1)Dependencies (4)Versions (3)Used By (0)

[![Software License](https://camo.githubusercontent.com/d6bc2b26794002c24d023acaab01b6dbb953c57ab9cb80ba5b8aa2f2bd5de99a/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f4c6963656e73652d4d49542d626c7565)](LICENSE)[![Package Version](https://camo.githubusercontent.com/f15abedef83fb6c2f52e0ebcb91d1bf5cf4260de760a84d4372011210d7bf86c/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f76657273696f6e2d56312e302d677265656e)](VERSION)

在项目中rabbitmq得到了广泛的时候，这里对rabbitmq的常规功能做了一个简单的总结，并封装成了composer包，[composer包地址](https://packagist.org/packages/maweibinguo/easyrabbitmq)、[github地址](https://github.com/maweibinguo/easyrabbitmq)，欢迎fork，由于水平有限，难免存在bug，欢迎提出宝贵意见

easy-rabbitmq 包简介
-----------------

[](#easy-rabbitmq-包简介)

对php-amqplib/php-amqplib包的二次封装，为常见功能提供一套开箱即用的生产解决方案 。目前支持的功能列表如下：

- 推送消息到直连交换机(含延迟消息)
- 推送消息到扇形交换机(含延迟消息)
- 推送消息到主题交换机(含延迟消息)
- 订阅模式下的可靠消费, 消费者消费失败后将会尝试继续消费，最多尝试5次。
- 拉取模式下的可靠消费, 消费者消费失败后将会尝试继续消费，最多尝试5次。

如果还有其它场景，欢迎继续补充，随后进行迭代！！

要求
--

[](#要求)

- 安装包对PHP版本对要求主要取决于php-amqplib/php-amqplib包本身对要求,这里为了兼顾php5.0的使用者,我们使用了php-amqplib/php-amqplib包V2.9.0的版本。 具体的要求参照[这里](https://packagist.org/packages/php-amqplib/php-amqplib#v2.9.0)。 不过笔者推荐使用php7.0及其以上版本, 这个开发包也是在7.0这个版本上面开发完成的！

安装
--

[](#安装)

```
	composer require maweibinguo/easyrabbitmq
```

使用
--

[](#使用)

在这里我们推荐php脚本+supervisor结合使用，用以保证消费进程的可靠性、增强worker的消费能力！ 如果你还没有听说过supervisor，可以[点击这里](http://www.supervisord.org/introduction.html)了解.

### 1、推送消息

[](#1推送消息)

#### 1-1、推送消息到直连交换机

[](#1-1推送消息到直连交换机)

```
	$config = [
	    "host" => "127.0.0.1",
            "port" => "5672",
            "user" => "guest",
            "password" => "guest",
            "vhost" => "/",
            "channel_max_num" => 10,
	];
	$instance = RabbitMq::getInstance($config);

	//延迟消息,30 秒中后才会到达指定的交换机
	$instance->pushToDirect(
				$msg = time(), //消息体内容
				$exchange = "easy_direct_exchange", //交换机名称
				$routingKey = "direct_test_queue", //消息的routingKey，consume(get) 方法到bingdingKey 要和routingKey保持一致
				$delaySec = 30 //延迟秒数
	);

	//无延迟，推入到指定到直链交换机
	$instance->pushToDirect(
				$msg = time(), //消息体内容
				$exchange = "easy_direct_exchange", //交换机名称
				$routingKey = "direct_test_queue", //消息的routingKey，consume(get) 方法到bingdingKey 要和routingKey保持一致
	);
```

#### 1-2、推送消息到扇形交换机

[](#1-2推送消息到扇形交换机)

```
	$config = [
	    "host" => "127.0.0.1",
            "port" => "5672",
            "user" => "guest",
            "password" => "guest",
            "vhost" => "/",
            "channel_max_num" => 10,
	];
	$instance = RabbitMq::getInstance($config);

	//延迟消息,30 秒中后才会到达指定的交换机
	$instance->pushToFanout(
				$msg = time(), //消息体内容
				$exchange = "easy_fanout_exchange", //交换机名称
				$delaySec = 30 //延迟秒数
	);

	//无延迟，推入到指定到直链交换机
	$instance->pushToFanout(
				$msg = time(), //消息体内容
				$exchange = "easy_fanout_exchange" //交换机名称
	);
```

#### 1-3、推送消息到主题交换机

[](#1-3推送消息到主题交换机)

```
	$config = [
	    "host" => "127.0.0.1",
            "port" => "5672",
            "user" => "guest",
            "password" => "guest",
            "vhost" => "/",
            "channel_max_num" => 10,
	];
	$instance = RabbitMq::getInstance($config);

	//延迟消息,30 秒中后才会到达指定的交换机
	$instance->pushToTopic(
				$msg = time(), //消息体内容
				$exchange = "easy_topic_exchange", //交换机名称
				/**
				 * routingKey 要同consum(get)方法的bindingKey相匹配
				 * bindingKey支持两种特殊的字符"*"、“#”，用作模糊匹配, 其中"*"用于匹配一个单词、“#”用于匹配多个单词(也可以是0个)
				 * 无论是bindingKey还是routingKey, 被"."分隔开的每一段独立的字符串就是一个单词, easy.topic.queue, 包含三个单词easy、topic、queue
				 */
				$routingKey = "easy.topic.queue",
				$delaySec = 30 //延迟秒数
	);

	//无延迟，推入到指定到直链交换机
	$instance->pushToTopic(
				$msg = time(), //消息体内容
				$exchange = "easy_topic_exchange", //交换机名称
				$routingKey = "easy.topic.queue"
	);
```

### 2、消费消息

[](#2消费消息)

消费支持自动重试，最多尝试重试5次，每次消费失败后该消息将会被重新投入到消费队列中。重新的时间将会随着失败的次数增多逐渐推移,本客户端支持的推移策略如下： 失败1次（1秒钟后会再被投递）, 失败2次（2秒钟后会再被投递）, 失败3次（4秒钟后会再被投递）, 失败4次（8秒钟后会再被投递）, 失败5次（16秒钟后会再被投递）

#### 2-1、订阅模式

[](#2-1订阅模式)

##### 订阅模式下的可靠消费

[](#订阅模式下的可靠消费)

```
	$config = [
	    "host" => "127.0.0.1",
            "port" => "5672",
            "user" => "guest",
            "password" => "guest",
            "vhost" => "/",
            "channel_max_num" => 10,
	];
	$instance = RabbitMq::getInstance($config);
	$instance->consume(
		$queueName = "direct_test_queue",//订阅的队列名称
		$consumerTag = "c1",//消费标记
		$exchange = "easy_direct_exchange",//交换机名称
		$bindingKey = "direct_test_queue",//bindingkey，如果是直链交换机需要同routingKey保持一致
		$callback = function($msg){
		    $body = $msg->body;
		    file_put_contents("./test.log", "time => " . time() . "\t" . " body => " . $body . PHP_EOL , FILE_APPEND);
		    //如果返回结果不绝对等于(===)true,那么将触发消息重试机制
		    return false;
		},
		//5次消费消费失败后，失败消息将会投递到的队列名称
		$failedQueue = "easymq@failed"
	);
```

#### 2-2、拉取模式

[](#2-2拉取模式)

##### 拉取模式下的可靠消费

[](#拉取模式下的可靠消费)

```
	$config = [
	    "host" => "127.0.0.1",
            "port" => "5672",
            "user" => "guest",
            "password" => "guest",
            "vhost" => "/",
            "channel_max_num" => 10,
	];
	$instance = RabbitMq::getInstance($config);
	$instance->get(
		$queue = "get_queue",
		$exchange = "easy_fanout_exchange",
		$bindingKey = "",
		$callback = function($msg){
		    $body = $msg->body;
		    file_put_contents("./test.log", "time => " . time() . "\t" . " body => " . $body . PHP_EOL , FILE_APPEND);
		    //如果返回结果不绝对等于(===)true,那么将触发消息重试机制
		    return false;
		},
		//5次消费消费失败后，失败消息将会投递到的队列名称
		$failedQueue = 'easymq@failed'
    	);
```

#### 3、意见反馈

[](#3意见反馈)

如果你对这个组件有什么建议或者想法，欢迎到[https://segmentfault.com/a/1190000039806384，提交评论进行反馈](https://segmentfault.com/a/1190000039806384%EF%BC%8C%E6%8F%90%E4%BA%A4%E8%AF%84%E8%AE%BA%E8%BF%9B%E8%A1%8C%E5%8F%8D%E9%A6%88)

###  Health Score

27

—

LowBetter than 52% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity15

Limited adoption so far

Community10

Small or concentrated contributor base

Maturity53

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 63.2% 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

1805d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/262939401f088206b93dd5638cbd81ec86303e5637d93a4d07eec7f20105cef4?d=identicon)[maweibinguo](/maintainers/maweibinguo)

---

Top Contributors

[![SurprisePhp](https://avatars.githubusercontent.com/u/59953612?v=4)](https://github.com/SurprisePhp "SurprisePhp (12 commits)")[![maweibinguo](https://avatars.githubusercontent.com/u/6221360?v=4)](https://github.com/maweibinguo "maweibinguo (7 commits)")

---

Tags

messagequeuerabbitmq

###  Code Quality

TestsPHPUnit

Code StylePHP\_CodeSniffer

### Embed Badge

![Health badge](/badges/maweibinguo-easyrabbitmq/health.svg)

```
[![Health](https://phpackages.com/badges/maweibinguo-easyrabbitmq/health.svg)](https://phpackages.com/packages/maweibinguo-easyrabbitmq)
```

###  Alternatives

[php-amqplib/php-amqplib

Formerly videlalvaro/php-amqplib. This library is a pure PHP implementation of the AMQP protocol. It's been tested against RabbitMQ.

4.6k123.1M803](/packages/php-amqplib-php-amqplib)[php-amqplib/rabbitmq-bundle

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

1.2k19.9M59](/packages/php-amqplib-rabbitmq-bundle)[kdyby/rabbitmq

Integrates php-amqplib with RabbitMq and Nette Framework

30685.2k4](/packages/kdyby-rabbitmq)[convenia/pigeon

3232.4k](/packages/convenia-pigeon)

PHPackages © 2026

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