RocketMQ

RocketMQ架构 RocketMQ消费模式广播形式(broadcast)一个topic名下的消息可以被多个消费者消费 集群模式允许N个queue被一个消费者消费 一个queue不允许被多个消费者消费, 不同模式下的offset维护的区别广播形式:消费者维护消费者消费的的offset 集群模式:由集群维护消费者消费的的offset,消费者平摊消息队列里的消息 RocketMQ VS Ka...

发布于 MQ

Kafka

kafka的优势 避免单点问题支持集群部署 高性能 按批发送消息,消费消息 Kafka的架构图 kafka的AKF划分y轴:基于业务划分的topic x轴:基于出主机的节点复制,鸡蛋不放在一个篮子里 x轴:解决y轴的某个topic消息量大的时候分之处理:partition 但是在x轴上,虽然可以使用读写分离的方案来提高读写性能,但是会有数据一致性的问题。对于Kafka而言,规定了读写只能...

发布于 MQ

MQ面试相关

MQ选型 中间件 过期特性 重试机制 死信队列 延迟队列 批量投递 RabbitMQ ✅ ✅重试计数机制 ✅ Kafka ✅ RocketMQ ✅重试队列 ✅ ✅ 过期特性:推送消息的时候携带过期时间,在队列中消息过期之后,会将过去消息放到死信队列,消费者将无法消费; 延迟消息:只有时间到了指定时间才能被消费者消费到,其实MQ做法就是在消息未到消费时间的...

发布于 MQ