当前位置: 首页 > article >正文

Rocket如何实现顺序消费

RocketMQ 支持两种消息模式

集群消费( Clustering )和广播消费( Broadcasting )。

集群消费:同一 Topic 下的一条消息只会被同一消费组中的一个消费者消费。也就是说,消息被负载均衡到了同一个消费组的多个消费者实例上。

广播消费:当使用广播消费模式时,每条消息推送给集群内所有的消费者,保证消息至少被每个消费者消费一次。

全局有序

在RocketMQ中,如果使消息全局有序,可以为Topic设置一个消息队列,使用一个生产者单线程发送数据,消费者端也使用单线程进行消费,从而保证消息的全局有序,但是这种方式效率低,一般不使用

局部有序

假设一个Topic分配了两个消息队列,生产者在发送消息的时候,可以对消息设置一个路由ID,比如想保证一个订单的相关消息有序,那么就使用订单ID当做路由ID,在发送消息的时候,通过订单ID对消息队列的个数取余,根据取余结果选择消息队列,这样同一个订单的数据就可以保证发送到一个消息队列中,消费者类实现MessageListenerOrderly接口监听处理有序消息,这就是RocketMQ的局部有序,保证消息在某个消息队列中有序。

// 消费者监听类
@Slf4j
@Component("orderConsumer")
public class OrderConsumer implements MessageListenerOrderly, InitializingBean {
     @Override
    public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext context) {
        return null;
    }

    
}

原文地址:https://blog.csdn.net/qq_36042938/article/details/134488740
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.kler.cn/a/133355.html

相关文章:

  • vscode 配置 lua
  • 【JVM】Java虚拟机
  • es的使用方法以及概念
  • levelDB之基础数据结构-Slice
  • 新材料工厂生产管理mes系统
  • Power BI Desktop数据可视化图表
  • portraiture2024ps磨皮插件参数设置教程
  • uniapp大概是怎么个开发法(前端)
  • idea中git 移除对某个文件的跟踪
  • 基于SSM的在线投稿系统设计与实现
  • 美国政府首席信息安全官详细介绍零信任战略竞赛
  • Apache Airflow (九) :Airflow Operators及案例之BashOperator及调度Shell命令及脚本
  • 【开源】基于Vue和SpringBoot的康复中心管理系统
  • 计数排序.
  • Nuxt3框架局部文件引用外部JS/CSS文件的相关配置方法
  • 融合语言模型中的拓扑上下文和逻辑规则实现知识图谱补全11.18
  • PCL内置点云类型
  • Vue中给对象添加新属性时,界面不刷新怎么办?
  • PS学习笔记——移动工具
  • 【LeetCode刷题日志】225.用队列实现栈