2020年2月28日

摘要: 丢消息的情况有多种,可能是生产者丢了,可能是MQ丢了,可能是消费者丢了。 1、rabbitMQ 一般是用来承载核心业务的,数据是绝对不能丢的。解决方案的核心是接收消息方给发送消息方返回ack 一句话总结:生产者开启confirm模式 + MQ持久化消息 + 消费者关闭autoAck,手动提交 ack 阅读全文
posted @ 2020-02-28 17:07 黑子菜园 阅读(404) 评论(0) 推荐(0) 编辑
摘要: 消息重复消费,会造成数据混乱,特别是在涉及消费和财务系统里,此问题的解决显得尤为重要。 以kafka为例 关键字:消费端自动提交offset;写库或者redis时,先去查一下主键、key等是否存在 上图中,最顶上的a56爆大奖在线娱乐框丢失的文字:并通知kafka当前最大offset; 最右边的a56爆大奖在线娱乐框丢失的文字:数 阅读全文
posted @ 2020-02-28 15:54 黑子菜园 阅读(842) 评论(0) 推荐(0) 编辑

导航