RabbitMQ与AMQP协议详解

1. 消息队列的历史
了解一件事情的来龙去脉,将不会对它感到神秘。让我们来看看消息队列(Message Queue)这项技术的发展历史。

Message Queue的需求由来已久,80年代最早在金融交易中,高盛等公司采用Teknekron公司的产品,当时的Message queuing软件叫做:the information bus(TIB)。 TIB被电信和通讯公司采用,路透社收购了Teknekron公司。之后,IBM开发了MQSeries,微软开发了Microsoft Message Queue(MSMQ)。这些商业MQ供应商的问题是厂商锁定,价格高昂。2001年,Java Message queuing试图解决锁定和交互性的问题,但对应用来说反而更加麻烦了。

于是2004年,摩根大通和iMatrix开始着手Advanced Message Queuing Protocol (AMQP)开放标准的开发。2006年,AMQP规范发布。2007年,Rabbit技术公司基于AMQP标准开发的RabbitMQ 1.0 发布。

目前RabbitMQ的最新版本为3.5.7,基于AMQP 0-9-1。

RabbitMQ采用Erlang语言开发。Erlang语言由Ericson设计,专门为开发concurrent和distribution系统的一种语言,在电信领域使用广泛。OTP(Open Telecom Platform)作为Erlang语言的一部分,包含了很多基于Erlang开发的中间件/库/工具,如mnesia/SASL,极大方便了Erlang应用的开发。OTP就类似于Python语言中众多的module,用户借助这些module可以很方便的开发应用。

2. AMQP messaging 中的基本概念

  • Broker: 接收和分发消息的应用,RabbitMQ Server就是Message Broker。
  • Virtual host: 出于多租户和安全因素设计的,把AMQP的基本组件划分到一个虚拟的分组中,类似于网络中的namespace概念。当多个不同的用户使用同一个RabbitMQ server提供的服务时,可以划分出多个vhost,每个用户在自己的vhost创建exchange/queue等。
  • Connection: publisher/consumer和broker之间的TCP连接。断开连接的操作只会在client端进行,Broker不会断开连接,除非出现网络故障或broker服务出现问题。
  • Channel: 如果每一次访问RabbitMQ都建立一个Connection,在消息量大的时候建立TCP Connection的开销将是巨大的,效率也较低。Channel是在connection内部建立的逻辑连接,如果应用程序支持多线程,通常每个thread创建单独的channel进行通讯,AMQP method包含了channel id帮助客户端和message broker识别channel,所以channel之间是完全隔离的。Channel作为轻量级的Connection极大减少了操作系统建立TCP connection的开销。
  • Exchange: message到达broker的第一站,根据分发规则,匹配查询表中的routing key,分发消息到queue中去。常用的类型有:direct (point-to-point), topic (publish-subscribe) and fanout (multicast)。
  • Queue: 消息最终被送到这里等待consumer取走。一个message可以被同时拷贝到多个queue中。
  • Binding: exchange和queue之间的虚拟连接,binding中可以包含routing key。Binding信息被保存到exchange中的查询表中,用于message的分发依据。

3. 典型的“生产/消费”消息模型

生产者发送消息到broker server(RabbitMQ)。在Broker内部,用户创建Exchange/Queue,通过Binding规则将两者联系在一起。Exchange分发消息,根据类型/binding的不同分发策略有区别。消息最后来到Queue中,等待消费者取走。

4. Exchange类型
Exchange有多种类型,最常用的是Direct/Fanout/Topic三种类型。

Direct

Message中的“routing key”如果和Binding中的“binding key”一致, Direct exchange则将message发到对应的queue中。

Fanout

每个发到Fanout类型Exchange的message都会分到所有绑定的queue上去。

Topic

根据routing key,及通配规则,Topic exchange将分发到目标queue中。

Routing key中可以包含两种通配符,类似于正则表达式:

“#”通配任何零个或多个word“*”通配任何单个word

这里也推荐给想要了解RabbitMQ的同学一个网站,http://tryrabbitmq.com ,它提供在线RabbitMQ 模拟器,可以帮助理解Exchange/queue/binding概念。

至此,我们对于消息队列的发展,RabbitMQ的产生,以及AMQP协议中的重要概念做了一个完整的介绍。

(0)

相关推荐

  • SpringMVC和rabbitmq集成的使用案例

    SpringMVC和rabbitmq集成的使用案例

  • 还不知道异步队列?点进来看!

    你不知道的分布式异步队列 关于异步队列你解多少? 它被誉为大数据高并发的终极解决方案. 来先给你介绍几种: RabbitQM:是爱立信的产品,基于erlang语言(函数式编程大数据 scala语言) ...

  • 万字长文书写RabbitMQ最全见解!以后再也不用到处去搜索了呀!

    典型应用场景 1.跨系统的异步通信 人民银行二代支付系统,使用重量级消息队列 IBM MQ,异步,解耦,削峰都有体现. 2.应用内的同步变成异步 秒杀:自己发送给自己 3.基于Pub/Sub模型实现的 ...

  • Springboot 1.5.x 集成基于Centos7的RabbitMQ集群安装及配置

    RabbitMQ简介 RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件). RabbitMQ是一套开源(MPL)的消息队列服务软件,是由LShift提供的一 ...

  • 四种入门级消息中间件

    四种入门级消息中间件 ActiveMQ(性能一般) ActiveMQ是Apache出品,最流行的,能力强劲的开源消息总线,并且它一个完全支持JMS规范的消息中间件. 其丰富的API.多种集群构建模式使 ...

  • 三菱FX PLC编程口通讯协议详解

    因工程需要,需要了解三菱PLC编程口通讯协议,以为后续的上位机串口通讯打下相关基础-- 毕竟首次接触此类通讯,对其原理不甚了解,导致走了不少弯路,故记下之,以免忘记. 需要工具与资料: GXDevel ...

  • DNS协议详解及Linux下的配置

    DNS DNS产生的背景 在Internet网中连接着数量众多的主机,要让这些主机进行通信,更多情况下使用IP得知来标识计算机,主机在互联网上靠IP地址进行位置标识.但是这种纯数字的表示方式不便于人的 ...

  • 蓝牙4.0协议详解

    左手智慧 2018-07-31 14:52:59 8318 收藏 34分类专栏: 通讯 蓝牙 文章标签: 蓝牙4.0协议目录一.蓝牙4.0BLE介绍二.蓝牙4.0BLE协议与协议栈的关系三.如何使用蓝 ...

  • modbus通讯协议详解

    modbus通讯协议详解

  • HLS协议详解

    HTTP Live Streaming简称HLS是由Apple提出的基于HTTP的流媒体网络传输协议技术最早应用在iOS相关的设备上比如iPhoneiPadApple TVmacOS电脑等.很多web ...

  • UDP协议详解

    UDP协议详解

  • (9条消息) Modbus应用协议详解

    Modbus应用协议 缩略语 协议描述 服务器正常响应 服务器异常响应 三种PDU mb_req_pdu mb_rsp_pdu mb_excep_rsp_pdu 数据编码 Modbus数据模型 Mod ...

  • 无线充电原理与QI协议详解

    一 .无线充电基本原理 无线充电的基本原理就是我们平时常用的开关电源原理,区别在于没有磁介质耦合,那么我们需要利用磁共振的方式提高耦合效率,具体方法是在发送端和接收端线圈串并联电容,是发送线圈处理谐振 ...

  • 一万五千字详解HTTP协议

    本篇文章篇幅比较长,先来个思维导图预览一下. 一.概述 1.计算机网络体系结构分层 2.TCP/IP 通信传输流 利用 TCP/IP 协议族进行网络通信时,会通过分层顺序与对方进行通信.发送端从应用层 ...