概述

RabbitMQ是一款消息队列中间件。他提供了几乎覆盖所有语言的SDK与文档，简直强大的不的了。要详细的去了解学习RabbitMQ，我建议还是看官方文档吧。http://www.rabbitmq.com/getstarted.html

消息队列有以下几个基本用途

异步处理
应用解耦
流量削峰
系统架构

消息队列的这几个用途我会在后续的文章以真实案例去表述

生产者

创建RabbitMQ链接

1 2	$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel ();

与链接一个数据库概念差不多

创建一个队列声明

1	$channel->queue_declare ('hello');

创建多个队列与创建多个数据库一样,hello则是队列名

创建一条消息到队列

1	$message = new AMQPMessage('Hello World!');

发布消息到队列

1	$channel->basic_publish ($message, '', 'hello');

hello 是上面创建的队列声明

关闭链接

1 2	$channel->close (); $connection->close ();

释放资源

消费者

创建RabbitMQ链接

1 2	$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel ();

与链接一个数据库概念差不多

创建一个队列声明

1	$channel->queue_declare ('hello');

创建多个队列与创建多个数据库一样,hello则是队列名

消费

1
2
3

$channel->basic_consume ('hello', '', false, true, false, false, function ($msg) {
	echo ' [x] Received ', $msg->body, "\n";
});

通过回调函数处理消息队列

等待

1
2
3

while (count ($channel->callbacks)) {
	$channel->wait ();
}

无消息时，挂起保持等待状态

关闭链接

1 2	$channel->close (); $connection->close ();

释放资源

完整的案例

完整的按钮则是上面所有代码的整理

生产者

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel    = $connection->channel ();
$channel->queue_declare ('hello');

$message = new AMQPMessage('Hello World!');
$channel->basic_publish ($message, '', 'hello');

$channel->close ();
$connection->close ();

消费者

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel    = $connection->channel ();
$channel->queue_declare ('hello');
// basic_consume 方法第7个方法可以直接传入函数
$channel->basic_consume ('hello', '', false, true, false, false, function ($msg) {
	echo ' [x] Received ', $msg->body, "\n";
});
while (count ($channel->callbacks)) {
	$channel->wait ();
}
$channel->close ();
$connection->close ();