RocketMQ-01
2019-07-28 本文已影响0人
Muscleape
发布-订阅模式
- 消息发送方=>发布者（Publisher）;
- 消息接收方=>订阅者（Subscriber）；
- 服务器端存放消息的容器=>主题（Topic）；
RocketMQ
- 发布订阅模式，其中也有队列（Queue）;
- 通过确认机制，提高可靠性；
- 每个主题中包括多个队列，通过多个队列实现多实例并行生产和消费；
- 只在队列上保证消息的有序性；
- 主题层面无法保证消息的有序性；
- 订阅者的概念是通过消费组（Customer Group）来体现；
- 每个消费组都消费主题中一份完成的消息；
- 组内消费者是竞争关系，每个只负责尊一部分消息；
- 在Topic消费过程中，消息可被不同组多次消费，所以，为每个消费组在各个队列上维护一个消费位置；
- consumer和queue不是强关联的，但是在任何时刻，某个queue在同一个consumer group中最多只能有一个consumer占用；
- producer和queue不需要关联，消息发送哪个queue都可以，Rocket MQ的默认策略是轮询选择每个queue;
