RabbitMQ入门-初识RabbitMQ

初识RabbitMQ

要说RabbitMQ，我们不得不先说下AMQP。AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。

那么RabbitMQ是什么？ RabbitMQ是一个开源的AMQP实现，开源项目地址在GitHub上，可以在GitHub上搜索rabbitmq-tutorials，服务器端用Erlang语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX，具有很好的跨平台特性。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。

RabbitMQ和Redis是目前对于高并发高性能网站应用的两大削峰利器。这两天在做一个功能的时候也正好用到，所以这一系列就来学习下RabbitMQ，看看它是如何施展拳脚，发挥自己的作用的。

基本概念

如果一上来就干巴巴的将一大推概念会让很多没有接触RabbitMQ的人头皮发麻，好的产品是因为好用，易懂，而不是一套又一套天花乱坠的概念。所以，我们先看下面一张图

结合这幅图，我们大概了解下RabbitMQ的工作流程以及是如何解决问题的。 请点击此处输入图片描述 最左边的橙色的长方块Publisher，其表示的生产者，在这里表示是消息的生产者，因为整个流程都是一个消息传递的过程

紧挨着的浅黄的圆形Exchange，其表示的是一个交换机，生产者发送的消息并不是直接送到最后的消费者手上，如果真是这样，那么RabbitMQ就没有存在的意义。正是由于有Exchange这样的一个中转站、缓冲，使得RabbitMQ成为异步处理的很好的手段，从而使削峰成为了可能。

下一个青涩的圆形Queue，其表示的是一个队列。Queue是用来存储消息的，RabbitMQ中的消息都只能存储在Queue中，生产者Publisher生产消息并最终投递到Queue中，消费者可以从Queue中获取消息并消费。

流程的最后一个浅黄色长方块Consumer，其表示的是消费者，消费者从Queue中取出消息，进行消费。注意：粗略来看，RabbitMQ就是一款目的明确，简单易用的产品。但是作为一款完备的产品，在很多细节的地方都有很好的处理手段，上图中每一条线，每一次流向都有很多的细节和设计技巧可以讲，但是作为入门篇，这里还是循序渐进从最基本的开始。

RabbitMQ的各种Exchange类型

上图展示的只是一个生产者发送消息到exchange，然后也只有一个消费者通过获取存储到Queue中的消息进行消费。但是在实际生产应用中，我们需要实现和应用的类型要更加复杂、多样。下面我们简单了解下RabbitMQ还支持了那些类型 Hello World类型

顾名思义，这是一种最基本的类型，这里只有一个生产这和一个消费者，还有一个消息队列Queue。这个好比送鲜奶的过程，送鲜奶的工作人员将鲜奶投递带鲜奶箱中，居民到点或者有空的时候到鲜奶箱里取出自己的鲜奶，这里的送鲜奶的工作人员就是生产者，居民就是消费者，存放鲜奶的鲜奶箱则是这里的队列Queue。 请点击此处输入图片描述

Work类型

该类型相较于Hello World类型来说，不同之处在于消费者不在只是一个人。对比Hello World类型，它有一个好处，就是不需要像Hello World中的消费者那样，必须等到把前一个消息消费完之后才能消费第二个。这种模式下当C1拿完队列中的一个消息后，C2完全可以同时拿走另外一个消息进行处理，这样的处理方式更加高效。

限于篇幅，这里就介绍这么多，RabbitMQ还有几种Exchange模型我们放在下篇讲，敬请关注^^ 如果您觉得阅读本文对您有帮助，请点一下“推荐”按钮，您的“推荐”将是我最大的写作动力！如果您想持续关注我的文章，请扫描二维码，关注JackieZheng的微信公众号，我会将我的文章推送给您，并和您一起分享我日常阅读过的优质文章。