Download the PHP package sergiuszm/php-amqplib without Composer

php-amqplib

This library is a pure PHP implementation of the AMQP protocol. It's been tested against RabbitMQ.

Requirements: PHP 5.3 due to the use of namespaces.

The library was used for the PHP examples of RabbitMQ in Action and the official RabbitMQ tutorials.

BC BREAKING CHANGES

Since version 2.0 this library uses AMQP 0.9.1 by default. You shouldn't need to change your code, but test before upgrading.

Supported RabbitMQ Extensions

Since the library uses AMQP 0.9.1 we added support for the following RabbitMQ extensions:

• Exchange to Exchange Bindings
• Basic Nack
• Publisher Confirms
• Consumer Cancel Notify

Extensions that modify existing methods like alternate exchanges are also supported.

Setup

Add a composer.json file to your project:

Then provided you have composer installed, you can run the following command:

That will fetch the library and its dependencies inside your vendor folder. Then you can add the following to your .php files in order to use the library

Then you need to use the relevant classes, for example:

Usage

With RabbitMQ running open two Terminals and on the first one execute the following commands to start the consumer:

Then on the other Terminal do:

You should see the message arriving to the process on the other Terminal

Then to stop the consumer, send to it the quit message:

If you need to listen to the sockets used to connect to RabbitMQ then see the example in the non blocking consumer.

Tutorials

To not repeat ourselves, if you want to learn more about this library, please refer to the official RabbitMQ tutorials.

More Examples

• amqp_ha_consumer.php: demos the use of mirrored queues
• amqp_consumer_exclusive.php and amqp_publisher_exclusive.php: demos fanout exchanges using exclusive queues.
• amqp_consumer_fanout_{1,2}.php and amqp_publisher_fanout.php: demos fanout exchanges with named queues.
• basic_get.php: demos obtaining messages from the queues by using the basic get AMQP call.

Batch Publishing

Let's say you have a process that generates a bunch of messages that are going to be published to the same exchange using the same routing_key and options like mandatory. Then you could make use of the batch_basic_publish library feature. You can batch messages like this:

and then send the batch like this:

When do we publish the message batch?

Let's say our program needs to read from a file and then publish one message per line. Depending on the message size, you will have to decide when it's better to send the batch. You could send it every 50 messages, or every hundred. That's up to you.

Optimized Message Publishing

Another way to speed up your message publishing is by reusing the AMQPMessage message instances. You can create your new message like this:

Now let's say that while you want to change the message body for future messages, you will keep the same properties, that is, your messages will still be text/plain and the delivery_mode will still be 2. If you create a new AMQPMessage instance for every published message, then those properties would have to be re-encoded in the AMQP binary format. You could avoid all that by just reusing the AMQPMessage and then resetting the message body like this:

Debugging

If you want to know what's going on at a protocol level then add the following constant to your code:

Benchmarks

To run the publishing/consume benchmark type:

Tests

To successfully run the tests you need to first setup the test user and test virtual host.

You can do that by running the following commands after starting RabbitMQ:

Once your environment is set up you can run your tests like this:

Using AMQP 0.8

If you still want to use the old version of the protocol then you can do it by settings the following constant in your configuration code:

The default value is '0.9.1'.

Providing your own autoloader

If for some reasone you don't want to use composer, then you need to have an autoloader in place fo the library classes. People have reported to use this autoloader with success.

Original README:

Below is the original README file content. Credits goes to the original authors.

PHP library implementing Advanced Message Queuing Protocol (AMQP).

The library is port of python code of py-amqplib http://barryp.org/software/py-amqplib/

It have been tested with RabbitMQ server.

Project home page: http://code.google.com/p/php-amqplib/

For discussion, please join the group:

http://groups.google.com/group/php-amqplib-devel

For bug reports, please use bug tracking system at the project page.

Patches are very welcome!

Author: Vadim Zaliva [email protected]