php-amqp is a PHP Extension written in C to enable support for AMQP (Advanced Message Queuing Protocol) messaging directly from PHP. The extension is using the rabbitmq library (Version 1.6.0, AMQP Version 0.8) (http://hg.rabbitmq.com/rabbitmq-c).

Installation

• Download librabbitmq-c from from http://hg.rabbitmq.com/rabbitmq-c/ and extract its contents.
• Download librabbitmq-codegen from http://hg.rabbitmq.com/rabbitmq-codegen/ and extract its contents to a subdirectory in librabbitmq-c named "codegen" or if you have mercurial installed: hg clone http://hg.rabbitmq.com/rabbitmq-c cd rabbitmq-c hg clone http://hg.rabbitmq.com/rabbitmq-codegen codegen
• Compile and install librabbitmq using: autoreconf -i && ./configure && make && sudo make install
• Download and unpack the PHP extension, compile and install it using: phpize && ./configure --with-amqp && make && sudo make install
• Add the PHP Extension to your php.ini file: extension = amqp.so

Example

Check example.php in the source also ...

```

// create a connection ... $connection = amqp_connection_popen("localhost", 5672 );

$user = "guest"; $pass = "guest"; $vhost = "/";

// login $res = amqp_login($connection, $user, $pass, $vhost);

// open channel $channel_id = 1; $res = amqp_channel_open($connection, $channel_id);

$queue = 'MyQueue'; $exchange ="myexchange.direct"; $routing_key = "RoutingKey";

// optional: declare exchange, declare queue, bind queue $res = amqp_exchange_declare($connection, $channel_id, $exchange, "direct"); $res = amqp_queue_declare($connection, $channel_id, $queue, $passive = false, $durable = false, $exclusive = false, $auto_delete = true); $res = amqp_queue_bind($connection, $channel_id, $queue, $exchange, $routing_key);

// optinal, specify options for basic_publish() $options = array( "content_type" => "ContentType", "content_encoding" => "ContentEncoding", "delivery_mode" => 2, "priority" => 1, "correlation_id" => "correlation_id", "reply_to" => "reply_to", "expiration" => "tomorowww", "message_id" => "id of the message", "timestamp" => time(), "type" => "type of the message", "user_id" => "userId!", "app_id" => "ApplicationId", "cluster_id" => "ClusterId!" );

// send the message to rabbitmq $body = "Message Body"; $start = microtime(true); for ($i = 0; $i < 10; $i++) { $res = amqp_basic_publish($connection, $channel_id, $exchange, $routing_key, $body, false, false, $options); }

$end = microtime(true); echo "Total publish time: " . ($end - $start) ."\n";

```