加载中
如何设计消息中间件架构

1.mq要支持可伸缩,快速扩容。设计一个分布式的MQ,broker->topic->partition 每个partition放一个机器,存放一部分数据。如果资源不够,给topic增加partition,然后做数据迁移。 2.mq的消息要...

2020/12/16 15:52
30
RabbitMQ实现延迟队列

主要通过Rabbit的DLX特性来实现发送延迟队列。 等消息超时成为死信,转发到对应的队列上。 消息的超时时间就是延时队列的延时时间。 死信队列(DLX) Dead-Letter-Exchange 客户端->消息->交换...

2019/07/31 18:54
124
Kafak的高可用、消息可靠性以及消息顺序消费

Kafak是如何实现高可用: 1.zk部署2n+1个节点,形成zk集群,保证高可用。 2.Kafak Broker部署集群,每一个Kafak节点就是一个Broker。每个Topic的partition,基于副本机制,在broker集群中复制。...

2019/06/18 20:17
1.7K
Apache Kafak概念

Kafak是基于发布订阅的消息系统。是一个分布式,可分区,冗余备份的持久化的消息系统。主要用户处理活跃的流式数据。 几个重要基本的概念: 1.Topic :主题,特指Kafak处理的消息源的不同分类...

2019/06/18 19:08
250
Rabbit的高可用模式和消息的可靠性

消息是如何发送给MQ: 生产者(Producer)把消息发布到 Exchange 上,消息最终到达队列并被消费者接收,而 Binding 决定交换器的消息应该发送到那个队列 消息发布到交换器时,消息将拥有一个路...

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部