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 条评论
登录 后参与评论

相关文章

来自专栏一枝花算不算浪漫

Dubbo的使用及原理浅析.

43113
来自专栏IT技术精选文摘

Presto内存调优及原理(基础篇)

Presto是一个开源的分布式SQL查询引擎,适用于交互式分析查询,数据量支持GB到PB字节。Presto支持在线数据查询,包括Hive, Cassandra,...

884
来自专栏开发与安全

大型网站架构演变过程、大并发服务器架构

大型网站架构演变过程: [Step1]web server与数据库分离 ? web动静资源分离 ? 静态请求:如html, js, css, img 动态请...

1866
来自专栏CSDN技术头条

Kafka Consumer 开发的一些关键点

Kafka的consumer是以pull的形式获取消息数据的。不同于队列和发布-订阅模式,kafka采用了consumer group的模式。通常的,一般采用一...

1779
来自专栏MongoDB中文社区

深入浅出MongoDB复制

笔者最近在生产环境中遇到许多复制相关问题,查阅网上资料发现官方文档虽然系统但是不够有深度,网上部分深度文章则直接以源码展示,不利于大家了解。所以本文则是结合前两...

943
来自专栏公有云大数据平台弹性MapReduce

Presto内存调优及原理(基础篇)

Presto是一个开源的分布式SQL查询引擎,适用于交互式分析查询,数据量支持GB到PB字节。

5106
来自专栏高性能服务器开发

windows完成端口(三)

系列目录 windows完成端口(一) windows完成端口(二) windows完成端口(三) windows完成端口(四) windows完成端口(五) ...

2604
来自专栏Java帮帮-微信公众号-技术文章全总结

Dubbo入门学习--Dubbo注册及监控中心(3)

Dubbo入门学习--Dubbo注册及监控中心 Dubbo提供广播、Zookeeper、Redis和Simple四种注册中心类型。 Multicast注册中心 ...

3143
来自专栏温安适的blog

保证MQ消息传递的一致性

4226
来自专栏chenssy

【死磕Netty】-----Netty的核心组件

原文出处http://cmsblogs.com/ 『chenssy』 转载请注明原创出处,谢谢! 在第一篇博客中(【死磕Netty】-----NIO基础详解),...

3885

扫描关注云+社区