连击 天
fork: star:
1.mq要支持可伸缩,快速扩容。设计一个分布式的MQ,broker->topic->partition 每个partition放一个机器,存放一部分数据。如果资源不够,给topic增加partition,然后做数据迁移。 2.mq的消息要...
主要通过Rabbit的DLX特性来实现发送延迟队列。 等消息超时成为死信,转发到对应的队列上。 消息的超时时间就是延时队列的延时时间。 死信队列(DLX) Dead-Letter-Exchange 客户端->消息->交换...
Kafak是如何实现高可用: 1.zk部署2n+1个节点,形成zk集群,保证高可用。 2.Kafak Broker部署集群,每一个Kafak节点就是一个Broker。每个Topic的partition,基于副本机制,在broker集群中复制。...
消息是如何发送给MQ: 生产者(Producer)把消息发布到 Exchange 上,消息最终到达队列并被消费者接收,而 Binding 决定交换器的消息应该发送到那个队列 消息发布到交换器时,消息将拥有一个路...
没有更多内容
加载失败,请刷新页面
没有更多内容
文章删除后无法恢复,确定删除此文章吗?
动弹删除后,数据将无法恢复
评论删除后,数据将无法恢复