三个部分
- 消息的生产者
- 消息的消费者
- 消息broker
生产者的能力
- 莫过去与broker建立通信,之后发送消息即可
- 发送消息的过程中是否需要考虑负载均衡的问题,如果broker是集群,如何选取目标
- 如果broker是集群,怎么获取broker的所有节点信息
broker的能力
- 存储消息,如何保证消息的可靠性。怎么去存储,设计什么数据结构去做索引,不可能没有索引,每次都去遍历吧
- 高可用,高可用的算法是什么,如果一个broker宕机了,会不会影响整个集群的工作
- broker自身怎么保证消息幂等。
消费者的能力
- 从broker拉取消息,同样需要考虑,怎么获取所有broker的信息
- 同一个消费组的消费者,只能有一个消费clustering的消息,这个是怎么维护的。用什么数据结构,高效吗
整体
- 网络通信的模型是什么,为什么要用这个模型
luckkann / rocketmq-source-doc Goto Github PK
View Code? Open in Web Editor NEWLicense: Apache License 2.0