RabbitMQ es un sistema gestor de colas de mensajes de código abierto que implementa el estándar AMQP (Advanced Message Queuing Protocol). Su principal característica es que soporta multitud de lenguajes de programación (Java, PHP, Python, Ruby, .NET, etc) lo que lo hace más versátil que por ejemplo los sistemas de colas que sólo implementan JMS. Es muy sencillo de utilizar y ofrece bastantes modelos de distribución de mensajes que cubren prácticamente todas las necesidades en este sentido.

Detrás de RabbitMQ está VMware, empresa que en 2010 compró este sistema a Rabbit Technologies Ltd. y que a día de hoy da soporte al producto y da garantías de continuidad a este buen middleware ofreciendo incluso soporte comercial.

Además el protocolo de mensajería AMQP que implementa está respaldado por grandes corporaciones internacionales, que velan por la evolución del estándar y aseguran que no caiga en el olvido.

La instalación del servidor RabbitMQ en Ubuntu 12.04 es sencilla, basta seguir las instrucciones que se dan en su página para añadir el repositorio e instalarlo vía apt-get.

Un poco más complicado es activar el soporte de AMQP en PHP. Ya que Ubuntu no lo ofrece en sus repositorios de forma oficial. Aquí os presento los pasos que he dado en una Ubuntu 12.04 de 64 bits para tener el soporte activado.

PASO 1. Descargar el código de la última librería C para rabbit

Usando Git, nos descargamos la última versión del código de la librería C, que podemos obtener de git://github.com/alanxz/rabbitmq-c.git. Por ejemplo en nuestro home de usuario ejecutamos lo siguiente:

git clone git://github.com/alanxz/rabbitmq-c.git
cd rabbitmq-c
git submodule init
git submodule update

Esto nos crea un directorio rabbitmq-c en el que está todo el código y ficheros necesarios para compilar la librería.

PASO 2: Compilar e instalar la última librería C para amqp.

cd rabbitmq-c
autoreconf –i
./configure --enable-64-bit
Make
make install

Esto compila las librerías para una máquina de 64 bits y las instala por defecto en /usr/local/lib. Ojo que para la instalación es necesario que seamos usuario root.

Paso 3: Compilar e instalar el módulo AMQP para PHP 5.3 (versión 1.0.3 estable)

Debemos descargar la última versión estable del módulo (a fecha de este artículo la 1.0.3) y compilarlo.

wget http://pecl.php.net/get/amqp-1.0.3.tgz
tar –zxvf amqp-1.0.3.tgz
cd amqp-1.0.3
phpize
./configure --with-amqp=/usr/local/lib/ CFLAGS="-m64"
make
make install

Como en el caso anterior hay que ser usuario root para la instalación.

PASO 4: Configurar php para activar el módulo

Creamos en /etc/php5/conf.d/ un fichero amqp.ini con el siguiente contenido

; configuration for php AMQP module
extension=amqp.so

PASO 5: Probar
Creamos un pequeño script en php para probar que tenemos el soporte activado correctamente:

function testConsumer($envelope, $queue) {
        echo "Message : " . $envelope->getBody() . "\n";
        return false;
}

// Create a connection
$cnn = new AMQPConnection();
$cnn->setHost('localhost');
$cnn->setPort(5672);
$cnn->setLogin('php-amqp-user');
$cnn->setPassword('devpassword');

$cnn->connect();

// Create a channel
$ch = new AMQPChannel($cnn);

if ($ch->isConnected()) {

        // Declare a new exchange
        $ex = new AMQPExchange($ch);
        $ex->setType(AMQP_EX_TYPE_FANOUT);
        $ex->setName('exchange1');
        $ex->declare();

        // Create a new queue
        $q = new AMQPQueue($ch);
        $q->setName('queue1');
        $q->declare();
        $q->bind('exchange1', 'routing.key');

        // Publish a message to the exchange with a routing key
        $ex->publish('message', 'routing.key');

        // Read from the queue
        $msg = $q->consume('testConsumer');
}

Al ejecutarlo en consola debemos obtener lo siguiente si todo va bien, o si algo falla se generará una excepción PHP que nos aclarará un poco por donde van los tiros.

jcaride@devdesktop:~$ php -f test.php
Message : message
jcaride@devdesktop:~$