Amqp协议和RabbitMq

在这篇文章中,我将讲述一下异步消息中的一些基本概念,在下篇文章中,你可以看到一些实现细节以及一些在springboot中使用rabbitMQ的代码块。

1.使用消息的目的

消息提供了一个让多个应用组件或软件甚至多个系统轻松整合的机制,它让系统之间的通信变得比较随意,异步。有很多协议都提供了这个特性,但是 AMQP协议确实最受欢迎并且健壮的。


2.AMQP

AMQP(Advanced Message Queuing Protocol) 就是一个RabbitMq用于实现消息的协议。虽然RabbitMQ也支持了许多其他协议,但是AMQP协议却是RabbitMq兼容性最强并且提供的特性最多的协议。


3.RabbitMQ

RabbitMQ是一个功能强大并且开源的消息代理器。它是世界上使用最广泛并且部署数量最多的消息代理器。这是它的官方网站:offical webSite

3.1 rabbitmq的安装

访问它的官方网站,你可以找到下载和安装连接,点击这个连接,你就可以进入下载和安装章节。你可以根据你使用的操作系统类型,来选择下载一个最合适的版本,然后进行安装。

注意一点,RabbitMQ需要Erlang环境才能运行,你可以为你所下载的RabbitMq去选择一个合适的Erlang版本。

3.2 RabbitMQ 的管理界面

     安装完成之后,你可以随时访问RabbitMQ的管理界面,在这个管理界面中,你可以看到一些关于exchange、queue、bindings 以及 messages 的一些细节。  (如果你没有在安装的时候,改变端口号的话)默认的访问url地址是:http://localhost:15672,默认    默认的用户名是:guest,密码是:guest。

我推荐你在这个界面上玩一下,比如 向队列中发送消息,从队列中取出消息等等,这样就能感受一下,它到底是如何工作的啦。如果你不懂这些关键术语的话,那么不要担心,在下一节中,我们将详细介绍这些关键术语。


3.3 RabbitMQ的架构设计

   Publisher -发布者

   Binding    -绑定

   Exchange  -交换机

   Subscriber  -订阅者


RabbitMQ架构图


3.4RabbitMQ的关键术语:

Exchange(交互机):取出一个消息并且把它路由给一个或多个队列。路由算法决定了从exchange的的什么地方发出这个消息,同时,路由算法也取决于exchange的类型和规则也就是所谓的:"bindings"。


交互机类型和路由规则

交互机类型:


    (1).  Direct    它的路由规则是: Direct会使用一个routing key来做路由,它会把消息路由给那些绑定到该exchange上并且routingkey相等的队列上。             目的:  这是默认的交互机类型 ,当一个消息需要发送给一个队列时,通常使用这种类型的交互机。

    (2).  Fanout    它的路由规则是: Fanout会把消息路由给所有绑定到该交互机上的队列。如果提供的有routing  key的话,routingkey也会被忽视。                  目的:  这非常适用于发布-订阅模式下广播特性。

    (3).  Topic      它的路由规则是: Topic会把消息路由给那些匹配routing key的队列。                                                           

                                  目的:  这比较适用于处理那些基于某些条件下广播给特定队列的场景

    (4).  Headers    它的路由规则是: Headers在路由消息时,是基于消息头来做出抉择的。                                                           

                                   目的:  这适用于那些点对点发送一些包含部分已知条件的消息。

下面用一张图来说明:

Topic :       Topics是消息的主题部分。这些对于消息交换机message exchage来说都是可选的参数。

Bindings:    "Bindings"就是把交换机exchange和队列queue粘合在一起的胶水,它都是一些路由算法的规则。

Queues :      Queue队列是消息的容器。 它只受主机内存和磁盘的限制,在消息被发送给订阅者之前,队列是消息的最终目的地。

队列的属性:


创建一个队列时需要指定那些属性

name              //队列名称

Durable            //是否持久化该队列到磁盘上

Exclusive          //如果不再使用就删除该队列

Auto-Delete        //如果没有消费者订阅的话,就删除。

生产者: 生产者就是发送消息给队列的程序。

消费者:  消费者就是从队列中接收消息的程序。


4.RabbitMQ配置

可以使用 rabbitmq.conf文件来对rabbitMQ进行配置,文件的默认的存储路径取决于操作系统,windows上的路径是:%APPDATA%\RabbitMQ\。


5.总结:

我希望这篇文章讲述了RabbitMQ中的一些基本概念。在我的下一篇文章中,我将讲述如何使用springboot集成RabbitMQ消息代理器来提供一个异步的消息功能。

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

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,633评论 18 139
  • http://liuxing.info/2017/06/30/Spring%20AMQP%E4%B8%AD%E6%...
    sherlock_6981阅读 15,892评论 2 11
  • 来源 RabbitMQ是用Erlang实现的一个高并发高可靠AMQP消息队列服务器。支持消息的持久化、事务、拥塞控...
    jiangmo阅读 10,351评论 2 34
  • 利用RabbitMQ集群横向扩展能力,均衡流量压力,让消息集群的秒级服务能力达到百万,Google曾做过此类实验;...
    有货技术阅读 3,458评论 0 1
  • 本文大纲 RabbitMQ 历史 RabbitMQ 应用场景 RabbitMQ 系统架构 RabbitMQ 基本概...
    Java_Explorer阅读 16,326评论 1 40