RocketMQ消费模式是什么
RocketMQ提供了多种消费模式,可以根据业务需求选择合适的消费模式。以下是RocketMQ的消费模式介绍:
1. 集群模式:
集群模式是RocketMQ的默认消费模式,适用于同时消费同一个Topic的多个消费者实例。在集群模式下,同一个消费组的多个实例将平均地负载消费消息,每个实例消费的消息不会重复。当有新的消费者实例加入或退出时,各消费者实例会重新进行负载均衡。
2. 广播模式:
广播模式适用于需要所有消费者实例都能接收到同一消息的场景。在广播模式下,同一个消费组的每个实例都会消费消息。广播模式下不会进行负载均衡,每个实例都会独立消费消息,并且消息会被多个消费者实例重复消费。广播模式适用于需要全量消费消息的场景,如定时任务和运维报警。
3. 顺序消费模式:
顺序消费模式用于保证消息的消费顺序。在顺序消费模式下,消息的消费会按照消息的发送顺序来进行。RocketMQ提供两种顺序消费模式,分别是`严格顺序消费`和`局部顺序消费`。
3.1 严格顺序消费:在严格顺序消费模式下,同一个消费者实例只消费一个队列中的消息,保证了消息的消费顺序。但是,如果一个Topic有多个队列的时候,可能会导致消费速度慢。
3.2 局部顺序消费:在局部顺序消费模式下,多个消费者实例可以消费同一个队列中的消息。通过使用消息的`tags`属性将需要保证顺序的消息发送到同一个队列中,从而能够保证消息的局部顺序消费。
4. 流式处理模式:
流式处理模式适用于需要高吞吐量且有序消费的场景,在流式处理模式下,将消费者实例直接链接到生产者实例的Broker上,消费者通过Pull方式从Broker端主动拉取消息,消费和拉取消息并行处理。流式处理模式适用于对延迟和吞吐量有高要求的场景,如日志收集和流式计算。
猜您想看
-
如何在Edge浏览器中设置书签栏的可见性
在Micros...
2023年05月13日 -
基于Gulp微信小程序开发工作流举例分析
Gulp是一个...
2023年07月20日 -
如何在QQ上创建审核群?
一、QQ审核群...
2023年05月15日 -
Python+appium框架原生代码实现App自动化测试的示例分析
示例代码的文件...
2023年07月21日 -
debug D命令如何查看指定地址的内容
1、什么是D命...
2023年05月26日 -
如何在Edge浏览器中搜索特定的内容
在Micros...
2023年05月13日