【消息队列】RabbitMQ简介

        【入门简介篇】

        一、 RabbitMQ特点

        开发语言:Erlang

        消息协议:AMQP

        缺点:多实例消费场景,无法保证消费有序性

        最初起源于金融系统,用于在分布式系统中存储转发消息,具体特点包括:

        1  可靠性保证:使用持久化、传输确认、发布确认等。

        2  具有灵活的路由功能:在消息进入队列之前,是通过Exchange(交换器)来路由消息的。

        3  支持消息集群:多台RabbitMQ服务器可以组成一个集群,形成一个逻辑Broker。

        4  具有高可用性:队列可以在集群中的机器上进行镜像,使得在部分节点出现问题的情况下队列仍然可用。

        5  支持多种协议:除了支持AMQP之外,还通过插件的方式支持其他消息队列的协议,比如STOMP、MQTT等。

        二、 基本概念

RabbitMQ整体架构图

        Publisher 生产者:一个向交换器发布消息的客户端应用程序,采用push模式。

        Exchange 交换器:用来接收生产者发送的消息,并将这些消息路由给服务器中的队列。

        Binding 绑定:用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则,所以可以将交换器理解为一个由绑定构成的路由表。

        Queue 消息队列:用来保存消息,直到发送给消费者。它是消息的容器,也是消息的终点。一条消息可被投入一个或多个队列中。消息一直在队列里面,等待消费者连接到这个队列将其取走。

        Message 消息:由消息头和消息体组成,消息头由一系列可选属性组成,这些属性包括routing-key(路由键)、priority(优先级)、delivery-mode(持久化模式)等。

        Connection 网络连接:比如一个TCP连接。

        Channel 信道:多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内的虚拟连接,AMQP命令都是通过信道发送出去,包括发消息、订阅队列、接收消息;这里的重点在于,复用了一个TCP连接,因为从操作系统层面来讲,建立和销毁TCP连接相对于信道的方式,开销非常大

        Consumer 消费者:表示一个从消息队列中取得消息的客户端应用程序,采用pull模式。

        Virtual Host 虚拟主机:默认的vhsot是“/”,本质上是一台缩小版的RabbitMQ服务器。

        Broker:代表消息服务器的实体。

        三、 AMQP中的消息路由

        AMQP中的消息路由过程:

        生产者发送消息到Exchange上,根据不同的Binding决定交换器上的消息应该被发送到哪个队列中,消息最终到达队列并被消费者接收,如图:

AMQP消息路由过程

        四、 Exchange类型

        交换器类型有四种:Header、Direct、Fanout和Topic,其中Header已被业界淘汰,所以在这里介绍其它三种交换器:

        1  Direct 交换器

Direct 交换器

        单播模式,只有消息的routing-key需要和Binding的routing-key完全一致,交换器就会将消息发送到对应的队列中;该模式的最大问题在于只能点对点

        2  Fanout 交换器

Fanout 交换器

        广播模式,该模式下交换器会忽略routing-key,直接将队列绑定到交换器,发送到交换器的消息会被转发到所有绑定的队列中;该模式的最大问题在于多实例下重复消费

        3  Topic 交换器

Topic 交换器

        主题模式,通过模式匹配来分配消息的路由键属性,routing-key可以通过模式进行匹配,其中routing-keyi可用多个单词+点"."分隔的方式进行定义,而且会识别“#”和“*”两个通配符,来进行单词匹配;最终效果相当于多个Direct交换器的灵活组合。


        参考文献

        倪炜 《分布式消息中间件实践》

        https://www.rabbitmq.com/documentation.html

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,033评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,725评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,473评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,846评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,848评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,691评论 1 282
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,053评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,700评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,856评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,676评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,787评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,430评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,034评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,990评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,218评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,174评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,526评论 2 343