markdunphy/ears

此包最新版本(0.1.0)没有可用的许可证信息。

使用php-amqplib的PHP RabbitMQ库

0.1.0 2014-07-23 03:37 UTC

This package is not auto-updated.

Last update: 2024-09-24 02:47:26 UTC


README

使用php-amqplib的PHP RabbitMQ库

##基本用法以下示例使用默认的localhost RabbitMQ服务器,该服务器在您安装时创建。对于生产使用(如果你这样做,那你真的很疯狂),你应该配置一个markdunphy\Ears\Connection对象,并将其作为第一个参数传递给markdunphy\Ears\Ears构造函数。

下面是一个简单的hello world演示。在一个终端标签中运行消费者代码,在另一个终端标签中运行发布者代码,以观察事情发生。

#####配置消费者

use \markdunphy\Ears\Ears;

$consumer = ( new Ears )->getConsumer();

$consumer->consumeBasic( 'hello', function( $message ) {
  echo $message->body . "\n";
} );

#####配置发布者

use \markdunphy\Ears\Ears;

$ears = new Ears( null, 'hello' );

$publisher = $ears->getPublisher();

$publisher->sendBasic( 'Hello world' );