RocketMQ消费模式是什么
RocketMQ提供了多种消费模式,可以根据业务需求选择合适的消费模式。以下是RocketMQ的消费模式介绍:
1. 集群模式:
集群模式是RocketMQ的默认消费模式,适用于同时消费同一个Topic的多个消费者实例。在集群模式下,同一个消费组的多个实例将平均地负载消费消息,每个实例消费的消息不会重复。当有新的消费者实例加入或退出时,各消费者实例会重新进行负载均衡。
2. 广播模式:
广播模式适用于需要所有消费者实例都能接收到同一消息的场景。在广播模式下,同一个消费组的每个实例都会消费消息。广播模式下不会进行负载均衡,每个实例都会独立消费消息,并且消息会被多个消费者实例重复消费。广播模式适用于需要全量消费消息的场景,如定时任务和运维报警。
3. 顺序消费模式:
顺序消费模式用于保证消息的消费顺序。在顺序消费模式下,消息的消费会按照消息的发送顺序来进行。RocketMQ提供两种顺序消费模式,分别是`严格顺序消费`和`局部顺序消费`。
3.1 严格顺序消费:在严格顺序消费模式下,同一个消费者实例只消费一个队列中的消息,保证了消息的消费顺序。但是,如果一个Topic有多个队列的时候,可能会导致消费速度慢。
3.2 局部顺序消费:在局部顺序消费模式下,多个消费者实例可以消费同一个队列中的消息。通过使用消息的`tags`属性将需要保证顺序的消息发送到同一个队列中,从而能够保证消息的局部顺序消费。
4. 流式处理模式:
流式处理模式适用于需要高吞吐量且有序消费的场景,在流式处理模式下,将消费者实例直接链接到生产者实例的Broker上,消费者通过Pull方式从Broker端主动拉取消息,消费和拉取消息并行处理。流式处理模式适用于对延迟和吞吐量有高要求的场景,如日志收集和流式计算。
猜您想看
-
怎样理解gnomAD数据库
1、GnomA...
2023年05月26日 -
win7和win10哪个对硬件的要求比较高
Win7和Wi...
2023年07月23日 -
Docker怎么批量导入或删除镜像和容器脚本
批量导入镜像1...
2023年05月25日 -
如何使用Python CGIHTTPServer绕过注入时的CSRF Token防御
一、CSRF ...
2023年07月22日 -
Reactor模型与Proactor模型的区别是什么
1、React...
2023年05月25日 -
如何在PHP中使用单页应用框架
单页应用框架:...
2023年05月05日