RabbitMQ(一)简介

RabbitMQ(一)——简介

(原创内容,转载请注明来源,谢谢)

一、概述

RabbitMQ是一种消息的传输者(broker),除了消息持久化,不对消息内容本身做任何的处理。其类似于邮局,可以将邮件发送给他,也可以去邮局取邮件。RabbitMQ相似,用户可以将消息发到其中,也可以去取消息。

其和ActiveMQ、ZeroMQ、Kafka等功能相似。RabbitMQ具有高稳定性,支持数据持久化,及时运行rabbitmq的服务器宕机,重启后消息仍存在。且有ack回传机制,保证消息送达消费者后才会将消息从队列中清除。

二、关键词

rabbitmq中有一些关键词,如下:

1、生产者(producer)

生产者是消息的产生者,即发送内容供消费者使用。如用户登录点击发送短信确认,这个点击完发送之前的过程,就是生产者去实现。

2、消费者(consumer)

消费者即具体任务的处理者,例如上述具体去实现发送短信的过程,就是消费者实现的。消费者要去队列中取任务,并且执行任务。可以是死循环不断的运行,也可以是定时任务定期去消费。

生产者和消费者是用户根据实际业务场景去实现的,下面的内容则是rabbitmq通过用户不同的定义和声明内部实现的。

3、交换机(exchange)

接收生产者发送的信息,其作为第一步,并且将信息根据用户的配置,发送给队列。

4、队列(queue)

用于存储消息,供消费者来取,并且提供ack机制,消费者取完回馈ack后,会将消息从队列删除。

5、绑定(bind)

交换机和队列之间的一种机制,当有多个队列时,通过绑定,交换机会将信息传到具体的队列中。

6、路由键(routingkey)

除了绑定,队列还有一个具体的key,用于标识队列的身份,当有这个key时,输错则交换机不会将信息发送到队列。

7、vhost

类似于数据库的账号,一个rabbitmq可以由多个用户操作,不同的用户可以用不同的vhost和密码,用于区分不同用户的队列。

8、通道(channel)

通道是用户和rabbitmq交互的途径,生产者和交换机、消费者和队列,都是通过channel进行数据交互。

三、工作模式

rabbitmq有五种工作模式,分别是工作队列(workqueues)、发布订阅(publish/subscribe)、路由(routing)、主题(topic)、远程调用(rpc),每种模式都有不同的特性。如下图所示:

1、工作队列

2、发布订阅

3、路由

4、主题

5、远程

四、使用方式

1、安装

rabbitmq支持非常多种编程语言,这里用php来进行操作。php安装rabbit,建议采用composer的方式,即在项目创建一个composer.json文件,并写入:

{
    "require": {
        "php-amqplib/php-amqplib":">=2.6.1"
    }
}

在命令行中运行composer.pharinstall即可。如果已经有composer.json,则是在require里面添加这一行内容,然后运行updat命令即可。

2、文件引用

引入方式也很简单,如下:

require_once__DIR__ . '/vendor/autoload.php';
usePhpAmqpLib\Connection\AMQPStreamConnection;
usePhpAmqpLib\Message\AMQPMessage;

3、创建连接和channel

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

4、关闭连接

每次执行完后,生产者和消费者都需要关闭连接,如下:

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

5、生产者

假设文件名为producer.php

发送一段最基础的内容给消费者,比较简单,因为exchange可以采用默认的,因此甚至可以不用定义exchange,直接定义队列即可。

生产者较简单,定义队列、定义消息、发送消息即可。其中,AMQPMessage传入的内容即具体的业务逻辑,如果是数组或者对象还需要序列化后进行传输。

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

6、消费者

假设文件名为consumer.php

去队列中获取消息,并进行后续的处理工作。如果有开启ack机制,还需要在处理完任务后,给队列进行回馈。

消费者需要定义较多内容,包括定义队列、定义回调函数、定义消费方法、while循环中等待生产者发送消息并进行处理。

其中,回调函数即具体的业务逻辑。

$channel->queue_declare('hello',false, false, false, false);
$callback= function($msg) {
  echo " [x] Received ",$msg->body, "\n";
};
$channel->basic_consume('hello','', false, true, false, false, $callback);
while(count($channel->callbacks)){
    $channel->wait();
}

7、运行

打开两个控制台,一个运行phpproducer.php,一个运行consumer.php,则consumer.php会收到消息HelloWorld!。

consumer.php会在后台一直运行,每次生产者发送消息,消费者就会去执行。

因此,为了保证消费者一直在后台运行,通常要有一个守护进程监视消费者,当其挂掉,则需要重新唤醒。

——written by linhxx 2017.08.19

原文发布于微信公众号 - 决胜机器学习(phpthinker)

原文发表时间:2017-08-19

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Ryan Miao

redis学习之三配置文件redis.conf 的含义

摘自http://www.runoob.com/redis/redis-conf.html 安装redis之后的第一件事,我就开始配置密码,结果总是不生效,而我...

2675
来自专栏跟着阿笨一起玩NET

搭建windows server 2008 r2 FTP 后 开启防火墙无法访问的解决办法

转自http://kkworms.blog.51cto.com/540865/558477

1.2K1
来自专栏lulianqi

PipeHttp 测试工具使用

https://github.com/lulianqi/PipeHttp/ (工程地址)

2112
来自专栏赵俊的Java专栏

Hexo 扩展 --- 优雅的备份 Hexo 博客

4263
来自专栏信安之路

与http头安全相关的安全选项

由于HTTP是一个可扩展的协议,各浏览器厂商都率先推出了有效的头部,来阻止漏洞利用或提高利用漏洞的难度。了解它们是什么,掌握如何应用,可以提高系统的安全性。 下...

870
来自专栏hrscy

记录网站诞生过程-使用hexo+github pages

此博客记录了搭建网站的详细过程,以及建站过程中遇到的一些坑。博客介绍了安装homebrew,nodejs,hexo,域名注册,github设置,DNS解析等过程...

983
来自专栏大数据和云计算技术

MongoDB系列11:Munin监控MongoDB

Munin是一个网络资源监控工具,可以帮助分析资源趋势。默认提供了大量的分析图形。以下讲述如何设置MongoDB的Munin监控插件。

1353
来自专栏云计算教程系列

如何在Ubuntu 16.04上使用Concourse CI设置持续集成管道

Concourse CI是一个现代的,可扩展的集成系统,旨在通过可组合的声明性语法自动测试管道。

1422
来自专栏友弟技术工作室

linux日志系统

linux 软件 syslog syslog-ng(next generation) 日志系统:syslog 负责统一记录日志 syslog服务: syslog...

3697
来自专栏行者悟空

Nginx 启用upstream模块后,location块中的相关参数说明

652

扫码关注云+社区