消息队列高可用、重复消费、消息丢失、顺序消息
所属分类 architecture
浏览量 1258
高可用
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简介及使用
管理学定律
程序员的爱情