rabbitMq实战指南笔记---第二章 理解消息通信

1.RabbitMq的消息是如何到达队列的?

   当你想要将消息投递到队列时,你通过把消息发送给交换器来完成。然后,根据确定的规则,RabbitMQ将会决定消息该投递到哪个队列。这些规则被称作路由键(routing key)。队列通过路由键绑定到指定交换器。当你把消息发送到代理服务器时,消息将拥有一个路由键---即便是空的---RabbitMQ也会将其和绑定使用的路由键进行匹配。如果相匹配的话,那么消息将会投递到该队列。如果路由的消息不匹配任何绑定模式的话,消息将进入“黑洞”。

2.协议中定义了几种不同类型的交换器?

  一共有四种类型:direct、fanout、topic和headers。每一种类型实现了不同的路由算法。

basic_publish($msg,' ' , 'queue-name'),第一个参数是你想要发送的消息内容;第二个参数指定交换器;第三个参数是路由键。

queue_bind(‘msg-inbox-errores’,‘log-exchange’,‘error.msg-inbox’)第一个参数队列名称;第二个参数交换器名称;第三个参数路由键。

direct交换器非常简单:如果路由键匹配的话,消息就被投递到对应的队列。

fanout:这种类型的交换器会将收到的消息广播到绑定的队列上。消息通信模式很简单:当你发送一条消息到fanout交换器时,它会把消息投递给所有附加在此交换器上的队列。

topic:这类交换器允许你实现有趣的消息通信场景,它使得来自不同源头的消息能够到达同一个队列。

3.vhost概念

  每一个RabbitMQ服务器都能创建虚拟消息服务器,称之为虚拟主机(vhost)。每一个vhost本质上是一个mini版的RabbitMQ服务器,拥有自己的队列、交换器和绑定,更重要的是,它拥有自己的权限机制。vhost之于Rabbit就像虚拟机之于物理服务器一样:它们通过在各个实例间提供逻辑上分离,允许你为不同应用程序安全保密地运行数据。在RabbitMQ的例子中,控制权限是以vhost为单位的。当你在RabbitMQ里创建一个用户时,用户通常会被指派给至少一个vhost,并且只能访问被指派vhost内的队列、交换器和绑定。vhost需要通过RabbitMQ的安装路径下./sbin/目录中的rabbitmqctl工具来创建。

4.当RabbitMQ崩溃或者重启时,如何确保关键消息不丢失?

  如果消息想要从Rabbit崩溃中恢复,那么消息必须:

    1.把它的投递模式选项设置为2(持久)

    2.发送到持久化的交换器

    3.到达持久化的队列

RabbitMQ确保持久性消息能从服务器重启中恢复的方式是,将它们写入磁盘上的一个持久化日志文件。

建议部分关键信息使用持久化,不要大量的使用持久化。持久化需要磁盘写入,会降低RabbitMQ的吞吐量。不重要的信息的可靠传输可以考虑做一种应答模式,即生产者发送消息,消费者在得到并消费消息后给予应答,生产者同时监听应答队列,如果在指定时间内没有收到指定信息的应答,则生产者重新发送信息。

5.由于发布操作不返回任何信息给生产者,那我们怎么知道服务器是否已经持久化了持久消息到硬盘呢?

两种方案:第一种AMQP事务,第二种发送方确认模式。

AMQP事务不但会降低大约2-10倍的消息吞吐量,而且会使生产者应用程序同步,而我们使用消息通信就是想要避免同步。因此不建议使用AMQP事务。

发送方确认模式:需要发送方将信道设置为confirm模式,一旦信道进入confirm模式,所有在信道上发布的消息都会被指派一个唯一的ID号。一旦消息被投递给所有匹配的队列后,信道会发送一个发送方确认模式给生产者应用程序。这使得生产者知晓消息已经安全到达目的队列了。如果消息是可持久化的,那么确认消息只会在队列将消息写入磁盘后才会发出。发送方模式的最大好处是它们是异步的。一旦发布了一条消息,生产者应用程序就可以在等待确认的同时继续发送下一条。当确认消息最终收到的时候,生产者应用的回调方法就会被触发来处理该确认信息。如果Rabbit发生了内部错误从而导致了消息的丢失,Rabbit会发送一条nack(not acknowledge,未确认)消息。就像发送方确认消息那样,只不过这次说明的是消息已经丢失了。

6.生产者和消费者生产消费消息流程

   发布者发布消息流程:

   1. 链接到RabbitMQ

    2.获取信道

    3.声明交换器

    4.创建消息

    5.发布消息

    6.关闭信道

    7.关闭连接

   消费者消费信息流程:

    1.连接到RabbitMQ

    2.获取信道

    3.声明交换器

    4.声明队列

    5.把队列和交换器绑定起来

    6.消费消息

    7.关闭信道

    8.关闭连接

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