RocketMQ消费模式是什么
RocketMQ提供了多种消费模式,可以根据业务需求选择合适的消费模式。以下是RocketMQ的消费模式介绍:
1. 集群模式:
集群模式是RocketMQ的默认消费模式,适用于同时消费同一个Topic的多个消费者实例。在集群模式下,同一个消费组的多个实例将平均地负载消费消息,每个实例消费的消息不会重复。当有新的消费者实例加入或退出时,各消费者实例会重新进行负载均衡。
2. 广播模式:
广播模式适用于需要所有消费者实例都能接收到同一消息的场景。在广播模式下,同一个消费组的每个实例都会消费消息。广播模式下不会进行负载均衡,每个实例都会独立消费消息,并且消息会被多个消费者实例重复消费。广播模式适用于需要全量消费消息的场景,如定时任务和运维报警。
3. 顺序消费模式:
顺序消费模式用于保证消息的消费顺序。在顺序消费模式下,消息的消费会按照消息的发送顺序来进行。RocketMQ提供两种顺序消费模式,分别是`严格顺序消费`和`局部顺序消费`。
3.1 严格顺序消费:在严格顺序消费模式下,同一个消费者实例只消费一个队列中的消息,保证了消息的消费顺序。但是,如果一个Topic有多个队列的时候,可能会导致消费速度慢。
3.2 局部顺序消费:在局部顺序消费模式下,多个消费者实例可以消费同一个队列中的消息。通过使用消息的`tags`属性将需要保证顺序的消息发送到同一个队列中,从而能够保证消息的局部顺序消费。
4. 流式处理模式:
流式处理模式适用于需要高吞吐量且有序消费的场景,在流式处理模式下,将消费者实例直接链接到生产者实例的Broker上,消费者通过Pull方式从Broker端主动拉取消息,消费和拉取消息并行处理。流式处理模式适用于对延迟和吞吐量有高要求的场景,如日志收集和流式计算。
猜您想看
-
如何理解ABAP的OPEN SQL和Hybris Commerce的Flexible Search
1. ABAP...
2023年07月20日 -
怎么利用elasticsearch结合mysql进行全文检索
一、Elast...
2023年07月23日 -
从iPhone删除应用程序的方法,保持您的设备干净整洁。
如何从iPho...
2023年04月15日 -
Steam游戏重新安装后进入账号需要重新购买怎么办?
Steam游戏...
2023年05月03日 -
如何理解django中板的继承及包含
Django板...
2023年05月26日 -
如何进行Jenkins自动化部署入门
一、什么是Je...
2023年05月26日