一、RabbitMQ 入门秘籍,三分钟带你快速了解RabbitMQ

1、前言

刚开始接触RabbitMQ的时候,有些概念那理解起来简直是像风像雨又像雾,晦涩难懂。 这篇文章用尽量浅显的语言来解释RabbitMQ的入门知识。毕竟是入门课程,并无对不少概念进行深刻说明,若是你想更深刻的了解RabbitMQ,能够继续关注本头条号后续发布的文章或者本身从网上搜寻了资料,本身探索研究。html

2、RabbitMQ是什么

官方定义:RabbitMQ是一种消息中间件,用于处理来自客户端的异步消息。服务端将要发送的消息放入到队列池中。接收端能够根据RabbitMQ配置的转发机制接收服务端发来的消息。RabbitMQ依据指定的转发规则进行消息的转发、缓冲和持久化操做,主要用在多服务器间或单服务器的子系统间进行通讯,是分布式系统标准的配置。 趣味定义:兔子行动很是迅速并且繁殖起来也很是疯狂,用Rabbit来命名这个分布式软件,呼应了RabbitMQ的主要任务是处理海量的信息web

3、安装

一、安装erlang

下载地址:http://erlang.org/download/otp_win64_21.0.1.exeapache

二、安装rabbitmq

下载地址:https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.7/rabbitmq-server-3.7.7.exe 若是你要安装其它版本,注意版本对应:https://www.rabbitmq.com/which-erlang.html服务器

三、开启web访问

Windows下:打开CMD 进入rabbitmq的安装目录 执行rabbitmq-plugins enable rabbitmq_management命令 该命令,仅在首次运行RMQ时使用!!!目的就是加载Web插件!!! 异步

四、访问测试:http://localhost:15672/

默认用户名:guest 默认密码:guest 分布式

4、核心概念

https://content.pivotal.io/rabbitmq/understanding-when-to-use-rabbitmq-or-apache-kafka测试

  • RabbitMQ broker,原话是RabbitMQ isn’t a food truck, it’s a delivery service,其实说白了,就是一种传输服务。
  • Exchange: 接受生产者发送的消息,并根据Binding规则将消息路由给服务器中的队列。ExchangeType决定了Exchange路由消息的行为。在RabbitMQ中,ExchangeType经常使用的有direct、Fanout和Topic三种,在第三部分会详细介绍。
  • Message Queue: 消息队列。咱们发送给RabbitMQ的消息最后都会到达各类queue,而且存储在其中(若是路由找不到相应的queue则数据会丢失),等待消费者来取。
  • Binding Key:它表示的是Exchange与Message Queue是经过binding key进行联系的,这个关系是固定的,初始化的时候,咱们就会创建该队列。
  • Routing Key:生产者在将消息发送给Exchange的时候,通常会指定一个routing key,来指定这个消息的路由规则。这个routing key须要与Exchange Type及binding key联合使用才能生,咱们的生产者只须要经过指定routing key来决定消息流向哪里。
  • 个人注释:初始化的时候,exchange与各个队列的绑定关系是经过binding key进行绑定的;发送消息的时候,使用的routing key就是binding key的某一个(实质,二者是一个含义,角度不一样,名称含义不一样) 对于消费端来讲,只用知道MQ的virtual host 和queue的名称就能够了。而对于发送端,则须要知道exchange和routing key的名称,相对而言queue的名称就不那么重要了(不过也要依Exchange Type而定)。

如下是RabbitMQ最简单的流程图,相信看到这里的你,对MQ的运做流程应该会有个基本的了解了: 插件

5、三种ExchangeType

http://www.rabbitmq.com/tutorials/amqp-concepts.html 这里介绍三种最主要的类型的exchange:direct、fanout和topic。3d

一、direct交换器

Direct交换器很简单,若是是Direct类型,就会将消息中的RoutingKey与该Exchange关联的全部Binding中的BindingKey进行比较,若是相等,则发送到该Binding对应的Queue中。有一个须要注意的地方:若是找不到指定的exchange,就会报错。但routing key找不到的话,不会报错,这条消息会直接丢失,因此此处要当心日志

二、fanout交换器

Fanout 扇出,顾名思义,就是像风扇吹面粉同样,吹获得处都是。若是使用fanout类型的exchange,那么routing key就不重要了。由于凡是绑定到这个exchange的queue,都会受到消息。

三、topic交换器

  • direct是将消息放到exchange绑定的一个queue里(一对一);
  • fanout是将消息放到exchange绑定的全部queue里(一对全部) 那可不能够把消息放到exchange绑定的一部分queue里,或者多个routing key能够路由到一个queue里呢?
  • topic类型的exchange就能够实现(一对部分)。
  • topic应用场景:打印不一样级别的错误日志 例如,咱们的系统出错后会根据不一样的错误级别生成error_levelX.log日志,咱们在后台首先要把全部的error保存在一个总的queue(绑定了一个*.error的路由键)里,而后再按level分别存放在不一样的queue。

routing key绑定以下图

更多资料分享,问题咨询,能够入群讨论:375412858 请入群索要代码

相关文章
相关标签/搜索