zircote / amqp
This library is a PHP implementation of the AMQP protocol.
Installs: 29 257
Dependents: 0
Suggesters: 3
Security: 0
Stars: 2
Watchers: 2
Forks: 4
Open Issues: 1
Requires
- php: >=5.3.0
This package is not auto-updated.
Last update: 2024-10-26 14:56:16 UTC
README
Setup
git
`git clone git://github.com/zircote/AMQP.git`
composer
{ "require": [ "zircote/amqp": "master-dev" ] }
composer install
Usage
host is defined by passing a URN string as first connection parameter:
`amqp://user:pass@hostname:port/vhost`
`amqps://user:pass@hostname:port/vhost`
connection options are passed as the second parameter of the connection:
<?php $amqp = 'amqp://user:pass@hostname:port/vhost'; // Options Options Array $options = array( 'insist' => false, 'login_method' => \AMQP\Connection::AMQP_AUTH_PLAIN, 'login_response' => null, 'locale' => 'en_US', 'connection_timeout' => 3, 'read_write_timeout' => 3, 'context' => null, 'ssl_options' => array() ); $connection = new \AMQP\Connection($amqp, $options);
With RabbitMQ running open two Terminals and on the first one execute the following commands to start the consumer:
$ cd php-amqplib/demo
$ php amqp_consumer.php
Then on the other Terminal do:
$ cd php-amqplib/demo
$ php amqp_publisher.php some text to publish
You should see the message arriving to the process on the other Terminal
Then to stop the consumer, send to it the quit
message:
$ php amqp_publisher.php quit
If you need to listen to the sockets used to connect to RabbitMQ then see the example in the non blocking consumer.
$ php amqp_consumer_non_blocking.php
More Examples
amqp_ha_consumer.php
: demoes the use of mirrored queuesamqp_consumer_exclusive.php
andamqp_publisher_exclusive.php
: demoes fanout exchanges using exclusive queues.amqp_consumer_fanout_{1,2}.php
andamqp_publisher_fanout.php
: demoes fanout exchanges with named queues.basic_get.php
: demoes obtaining messages from the queues by using the basic get AMQP call.
Loading Classes
$ ant setup
Place the following in your bootstrap once composer has been installed in the project:
<?php require_once(dirname(__DIR__) . '/vendor/autoload.php');
Debugging
If you want to know what's going on at a protocol level then add the following constant to your code:
<?php define('AMQP_DEBUG', true); ... more code ?>
Benchmarks
To run the publishing/consume benchmark type:
$ ant benchmark
Tests
Once your environment is set up you can run your tests like this:
$ ant build
History
This project is a work in progress and derived from work begun by php-amqplib. It attempts to achieve a cleaner, more friendly use-case by updating the API, documentation and php 5.3 compatibility. Because there was no desire to perform these changes in the related projects due to outdating books and publication, it was my deciscion to fork and begin this work.
For more information on its history please see this project.