RabbitMQ是一个开源的基于AMQP（Advanced Message Queuing Protocol）标准，并且可靠性高的企业级消息系统，目前很多网站在用，包括reddit,Poppen.de等。
1. Ubuntu下安装RabbitMQ
sudo apt-get install rabbitmq-server
sudo /etc/init.d/rabbitmq-server start
2. 安装librabbitmq
sudo apt-get install mercurial
hg clone http://hg.rabbitmq.com/rabbitmq-c
cd rabbitmq-c
hg clone http://hg.rabbitmq.com/rabbitmq-codegen codegen
autoreconf -i && ./configure && make && sudo make install
<?php
/** * producer demo * * @author wei * @version $Id$ **/ $params = array('host' =>'localhost', 'port' => 5672, 'login' => 'guest', 'password' => 'guest', 'vhost' => '/'); $cnn = new AMQPConnect($params); // declare Exchange $exchange = new AMQPExchange($cnn); $exchange->declare('ex1', 'topic', AMQP_DURABLE ); // declare Queue $queue = new AMQPQueue($cnn); $queue->declare('queue1', AMQP_DURABLE); // bind Queue $queue->bind('ex1','wei.#'); // publishing $msg = "msg"; for ($i=0; $i < 100; $i++) { $res = $exchange->publish($i . 'msg', 'wei.' . $i); if ($res) { echo $i . 'msg' . " Yes\n"; } else { echo $i . 'msg' . " No\n"; } } ?>
