RabbitMQ系列(6)-理解消息通信-持久化策略

重启RabbitMQ后,队列和交换器都会消失(随同里面的消息),原因在于每个队列和交换器的durable属性,该属性默认为false

欢迎访问本人博客:http://wangnan.tech

概述

重启RabbitMQ后,队列和交换器都会消失(随同里面的消息),原因在于每个队列和交换器的durable属性,该属性默认为false

durable属性,它决定了RabbitMQ是否需要在崩溃或者重启之后重新创建队列(或者交换器)
将他设置为true,这样就不需要在服务器断电后重新创建队列和交换器了

把这个属性设置为true不足以让消息幸免于重启,光这样还不够

如果想要从Rabbit崩溃中恢复,那么消息必须做到这三点:

  • 把它的投递模式选项设置为2(持久)
  • 发送到持久化的交换器
  • 到达持久化队列

RabbitMQ确保持久性消息能从服务器重启中恢复的方式是,将他们写入磁盘上的一个持久化日志文件。当发布一条持久化消息到持久交换器上时,Rabbit会在消息提交到日志文件后才发送响应

如果RabbitMQ重启,服务器会自动重建交换器和队列,重播持久性日志文件中的消息到合适的队列或者交换器上

你可以为所有消息都启动持久化,但是你也要为此付出代价:性能,写入磁盘要比写入内存慢了不止一点点,而且会极大的减少RabbitMQ服务器每秒可处理的消息总数,导致消息吞度量降低至少10倍的情况并不少见

持久化消息在RabbitMQ内建集群环境中工作的并不好,实际上集群上的队列均匀分布在各个节点上而且没有冗余,如果运行a队列的节点崩溃了,那么直到节点恢复前,这个队列就从整个集群消失了,而且这个节点上的所有队列不可用,而且持久化队列也无法重建

什么情况下应该使用持久化消息通信呢?
首先你需要分析性能需求,如果持久化通信可以满足性能需求,那么用这种机制是极佳的方式

AMQP事务(transaction)

发布操作不返回任何信息给生产者,那你怎么知道服务器是否已经持久化消息到硬盘?可能写入硬盘之前服务器就宕机了,消息丢失,你却不知道

所以你需要把这些行为包装在一个事务中

不要把AMQP事务与大多数数据库事务搞混了,在AMQP中,在把信道设置为事务模式后,你通过信道发送那些想要确认的消息,之后还有多个其他AMQP命令,这些命令时执行还是忽略,取决于第一条消息发送是否成功,一旦你发送完所有命令,就可以提交事务了

虽然事务是正式的AMQP 0-9-1规范的一部分,但是它也有致命弱点:几乎吸干了Rabbit的性能,使用事务不但会降低大约2-10倍的消息吞度量,而且会使生产者应用程序之间产生同步,而你使用消息通信就是想避免同步

发送方确认模式

RabbitMQ团队决定拿出更好的方案来保证消息投递:发送方确认模式

和事务相仿,你需要告诉Rabbit将信道设置成confirm模式

  • 一旦信道进入confirm模式,所有在信道上发布的消息都会被指派一个唯一的id号(从1开始)
  • 一旦消息被投递给所有匹配的队列后,信道会发送一个发送方确认模式给生产者应用程序(包含唯一的id),这使得生产者知晓消息已经安全到达目的队列了(如果消息和队列是可持久化的,那么确认消息只会在队列将消息写入磁盘后才会发生)
  • 发送方确认模式最大的好处是他们是异步
  • 如果Rabbit发生了内部错误从而导致了消息的丢失,Rabbit会发送一条nack消息,就像发送方确认消息那样,只不过这次说明的是消息已经丢失了
  • 由于没有消息回滚的概念,因此发送方确认模式更加轻量级,同时对Rabbit代理服务器的性能几乎没有影响

(注:内容整理自《RabbitMQ实战》)

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

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,494评论 18 139
  • 来源 RabbitMQ是用Erlang实现的一个高并发高可靠AMQP消息队列服务器。支持消息的持久化、事务、拥塞控...
    jiangmo阅读 10,335评论 2 34
  • 关于消息队列,从前年开始断断续续看了些资料,想写很久了,但一直没腾出空,近来分别碰到几个朋友聊这块的技术选型,是时...
    预流阅读 584,157评论 51 785
  • RabbitMQ采用Erlang编写,需安装语言库才能运行RabbitMQ代理服务器。AMQP:高级消息队列协议。...
    JAVA觅音阁阅读 3,546评论 0 7
  • RabbitMQ详解 本文地址:http://www.host900.com/index.php/articles...
    嘉加家佳七阅读 2,493评论 0 9