RocketMQ消费模式是什么
RocketMQ提供了多种消费模式,可以根据业务需求选择合适的消费模式。以下是RocketMQ的消费模式介绍:
1. 集群模式:
集群模式是RocketMQ的默认消费模式,适用于同时消费同一个Topic的多个消费者实例。在集群模式下,同一个消费组的多个实例将平均地负载消费消息,每个实例消费的消息不会重复。当有新的消费者实例加入或退出时,各消费者实例会重新进行负载均衡。
2. 广播模式:
广播模式适用于需要所有消费者实例都能接收到同一消息的场景。在广播模式下,同一个消费组的每个实例都会消费消息。广播模式下不会进行负载均衡,每个实例都会独立消费消息,并且消息会被多个消费者实例重复消费。广播模式适用于需要全量消费消息的场景,如定时任务和运维报警。
3. 顺序消费模式:
顺序消费模式用于保证消息的消费顺序。在顺序消费模式下,消息的消费会按照消息的发送顺序来进行。RocketMQ提供两种顺序消费模式,分别是`严格顺序消费`和`局部顺序消费`。
3.1 严格顺序消费:在严格顺序消费模式下,同一个消费者实例只消费一个队列中的消息,保证了消息的消费顺序。但是,如果一个Topic有多个队列的时候,可能会导致消费速度慢。
3.2 局部顺序消费:在局部顺序消费模式下,多个消费者实例可以消费同一个队列中的消息。通过使用消息的`tags`属性将需要保证顺序的消息发送到同一个队列中,从而能够保证消息的局部顺序消费。
4. 流式处理模式:
流式处理模式适用于需要高吞吐量且有序消费的场景,在流式处理模式下,将消费者实例直接链接到生产者实例的Broker上,消费者通过Pull方式从Broker端主动拉取消息,消费和拉取消息并行处理。流式处理模式适用于对延迟和吞吐量有高要求的场景,如日志收集和流式计算。
猜您想看
-
tomcat有哪些启动方式
1、命令行启动...
2023年05月25日 -
如何设置 OpenWrt 路由器为中继模式?
OpenWrt...
2023年04月17日 -
如何搭建一个区块链数字货币交易所系统
如何搭建一个区...
2023年07月23日 -
Ubuntu项目汇报常用的录屏、截图、Gif软件是什么
Ubuntu是...
2023年07月20日 -
Git 的 origin 和 upstream如何使用
origin ...
2023年07月21日 -
Popmetal ubuntu系统如何实现jpeg硬解
一、什么是JP...
2023年05月26日