首页  

消息队列高可用、重复消费、消息丢失、顺序消息     所属分类 architecture 浏览量 1058
高可用 
RabbitMQ可以使用镜像模式搭建高可用集群,可以配置数据同步到所有节点还是指定数量的节点以满足实际需求。

kafka 副本机制 
replication-factor 3   (总共3分数据)

 kafka高可用机制简介  

RocketMQ 多master多slave异步复制模式、多master多slave同步双写模式多种集群部署模式

kafka  
Zookeeper 用于保存集群配置、选举Leader等
Producer使用push模式将消息发布到broker
Consumer使用pull模式从broker订阅并消费消息

重复消费
at least once  消息至少一次投递

kafka消息投递语义

保证消费端的幂等性
强校验   流水号 数据库唯一约束
弱校验   流水号 放到redis中

消息丢失
发送端丢数据   同步发送 确认和事务机制 
服务端   持久化  多副本 高可用 
消费端   自动确认消息模式,  推荐使用手动方式


顺序
分区  partition 同一个分区 可保证顺序

上一篇     下一篇
线程安全 与 原子性 可见性 有序性

offer拒信范例,牛逼的候选人,哈哈哈哈哈哈

新冠与流感病毒的区别

guava简介及使用

管理学定律

程序员的爱情