RabbitMQ 初体验

keithxiaoy 发布于2019-07-01 10:16 / 1341人阅读

摘要：概述是一款消息队列中间件。他提供了几乎覆盖所有语言的与文档，简直强大的不的了。要详细的去了解学习，我建议还是看官方文档吧。对文章有什么问题或疑问，欢迎在评论区留言。

概述

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

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

异步处理

应用解耦

流量削峰

系统架构

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

生产者 创建RabbitMQ链接

$connection = new AMQPStreamConnection("localhost", 5672, "guest", "guest");
$channel    = $connection->channel ();

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

创建一个队列声明

$channel->queue_declare ("hello");

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

创建一条消息到队列

$message = new AMQPMessage("Hello World!");

发布消息到队列

$channel->basic_publish ($message, "", "hello");

hello 是上面创建的队列声明

关闭链接

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

释放资源

消费者 创建RabbitMQ链接

$connection = new AMQPStreamConnection("localhost", 5672, "guest", "guest");
$channel    = $connection->channel ();

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

创建一个队列声明

$channel->queue_declare ("hello");

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

消费

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

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

等待

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

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

关闭链接

$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, "
";
});
while (count ($channel->callbacks)) {
    $channel->wait ();
}
$channel->close ();
$connection->close ();

执行

php {生产者}.php
php {消费者}.php

其他

RabbitMQ支持多线程处理消息队列，所有你可以开启多个消费者去执行消息队列内的任务。你可以像我这样

如果你感觉RabbitMQ这玩意还需要安装啥的感觉特麻烦,那你可以看下我的Laravel队列如何简单的玩起来。
https://segmentfault.com/a/11...

致谢

感谢你看完我这篇文章，纯手记的一篇文章，官方文档对新手的理解造成很多的误解，所以整理此文档，尽量避免新手“进”坑吧。对文章有什么问题或疑问，欢迎在评论区留言。谢谢

云服务器 GPU云服务器初体验初长成小白初小白初入

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/28980.html

小程序云开发之初体验

摘要：小程序云开发之初体验前言选型的时候前后端都准备自己搞，然后选中方案，搭建的时候，发现官方文档没有了，后来问客服，客服说方案是存量用户使用的，相关文档已经下线说是现在主推云开发，然后带着疑问和懵逼脸转向了云开发最后发现云开发的我是幸福的小程序云开发之初体验前言：选型的时候前后端都准备自己搞，然后选中wafer方案，搭建的时候，发现官方文档没有了，后来问客服，客服说wafer方案是存量...

yanbingyun1990 2019-08-23 16:25 评论0 收藏0
小程序云开发之初体验

摘要：小程序云开发之初体验前言选型的时候前后端都准备自己搞，然后选中方案，搭建的时候，发现官方文档没有了，后来问客服，客服说方案是存量用户使用的，相关文档已经下线说是现在主推云开发，然后带着疑问和懵逼脸转向了云开发最后发现云开发的我是幸福的小程序云开发之初体验前言：选型的时候前后端都准备自己搞，然后选中wafer方案，搭建的时候，发现官方文档没有了，后来问客服，客服说wafer方案是存量...

Lionad-Morotar 2019-08-02 16:08 评论0 收藏0
小程序云开发之初体验

摘要：小程序云开发之初体验前言选型的时候前后端都准备自己搞，然后选中方案，搭建的时候，发现官方文档没有了，后来问客服，客服说方案是存量用户使用的，相关文档已经下线说是现在主推云开发，然后带着疑问和懵逼脸转向了云开发最后发现云开发的我是幸福的小程序云开发之初体验前言：选型的时候前后端都准备自己搞，然后选中wafer方案，搭建的时候，发现官方文档没有了，后来问客服，客服说wafer方案是存量...

Labradors 2019-08-30 15:56 评论0 收藏0