<h2>概述</h2> <blockquote>RabbitMQ是一款消息队列中间件。他提供了几乎覆盖所有语言的SDK与文档，简直强大的不的了。要详细的去了解学习RabbitMQ，我建议还是看官方文档吧。<a href="http://www.rabbitmq.com/getstarted.html" rel="nofollow noreferrer">http://www.rabbitmq.com/getst...</a> </blockquote> <p>消息队列有以下几个基本用途</p> <ul> <li>异步处理</li> <li>应用解耦</li> <li>流量削峰</li> <li>系统架构</li> </ul> <blockquote>消息队列的这几个用途我会在后续的文章以真实案例去表述</blockquote> <h2>生产者</h2> <h3>创建RabbitMQ链接</h3>
1$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
2$channel = $connection->channel ();
<p>与链接一个数据库概念差不多</p> <h3>创建一个队列声明</h3>
$channel->queue_declare ('hello');
<p>创建多个队列与创建多个数据库一样,hello则是队列名</p> <h3>创建一条消息到队列</h3>
$message = new AMQPMessage('Hello World!');
<h3>发布消息到队列</h3>
$channel->basic_publish ($message, '', 'hello');
<p>hello 是上面创建的队列声明</p> <h3>关闭链接</h3>
1$channel->close ();
2$connection->close ();
<p>释放资源</p> <h2>消费者</h2> <h3>创建RabbitMQ链接</h3>
1$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
2$channel = $connection->channel ();
<p>与链接一个数据库概念差不多</p> <h3>创建一个队列声明</h3>
$channel->queue_declare ('hello');
<p>创建多个队列与创建多个数据库一样,hello则是队列名</p> <h3>消费</h3>
1$channel->basic_consume ('hello', '', false, true, false, false, function ($msg) {
2 echo ' [x] Received ', $msg->body, "\n";
3});
<p>通过回调函数处理消息队列</p> <h3>等待</h3>
1while (count ($channel->callbacks)) {
2 $channel->wait ();
3}
<p>无消息时，挂起保持等待状态</p> <h3>关闭链接</h3>
1$channel->close ();
2$connection->close ();
<p>释放资源</p> <h2>完整的案例</h2> <p>完整的按钮则是上面所有代码的整理</p> <h3>生产者</h3>
1$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
2$channel = $connection->channel ();
3$channel->queue_declare ('hello');
4
5$message = new AMQPMessage('Hello World!');
6$channel->basic_publish ($message, '', 'hello');
7
8$channel->close ();
9$connection->close ();
<h3>消费者</h3>
1$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
2$channel = $connection->channel ();
3$channel->queue_declare ('hello');
4// basic_consume 方法第7个方法可以直接传入函数
5$channel->basic_consume ('hello', '', false, true, false, false, function ($msg) {
6 echo ' [x] Received ', $msg->body, "\n";
7});
8while (count ($channel->callbacks)) {
9 $channel->wait ();
10}
11$channel->close ();
12$connection->close ();
<h3>执行</h3>
1php {生产者}.php
2php {消费者}.php
<h2>其他</h2> <p>RabbitMQ支持多线程处理消息队列，所有你可以开启多个消费者去执行消息队列内的任务。你可以像我这样</p>
<blockquote>如果你感觉RabbitMQ这玩意还需要安装啥的感觉特麻烦,那你可以看下我的Laravel队列如何简单的玩起来。<br><a href="http://www.jqhtml.com/19562.html">https://segmentfault.com/a/11...</a> </blockquote> <h2>致谢</h2> <p>感谢你看完我这篇文章，纯手记的一篇文章，官方文档对新手的理解造成很多的误解，所以整理此文档，尽量避免新手“进”坑吧。对文章有什么问题或疑问，欢迎在评论区留言。谢谢</p> 原文地址：https://segmentfault.com/a/1190000015482888