突破Java面试(9)-如何保证消息队列的顺序性

简介: 如何保证消息的顺序性?

0 Github

1 面试题

如何保证消息的顺序性?

2 考点分析

MQ必问话题

  • 考察你是否了解顺序性
  • 考察你是否有办法保证消息的顺序性,因为这是生产系统中常见的一个问题.

3 详解

3.0 案例

一个MySQL binlog同步系统,日同步数据达到上亿.

  • 在MySQL里增删改一条数据
  • 即对应出增删改3条binlog
  • 接着这三条binlog发送到MQ里面
  • 消费出来依次执行

应该得保证消息按照顺序执行的吧!
不然本来是:增加->修改->删除
你楞是换了顺序给执行成:删除->修改->增加
全错!!!

该数据同步过来,最后本该被删除,结果你搞错顺序,最后它却被保留下来了,数据同步出错!

3.1 顺序错乱的场景

3.1.1 rabbitmq

一个queue,多个consumer,这不明显乱了

3.1.2 kafka

一个topic,一个partition,一个consumer,内部多线程,这也明显乱了

3.2 保证消息的顺序性

3.2.1 rabbitmq

拆分多个queue,每个queue一个consumer
就是多一些queue而已,确实麻烦点
或者就一个queue但是对应一个consumer,然后这个consumer内部用内存队列做排队,然后分发给底层不同的worker来处理

3.2.2 kafka

一个topic,一个partition,一个consumer,内部单线程消费,写N个内存queue,然后N个线程分别消费一个内存queue即可

参考

《Java工程师面试突击第1季-中华石杉老师》

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
4天前
|
SQL 存储 Java
致远互联java实习生面试
致远互联java实习生面试
20 0
|
4天前
|
Java C++
java面试基础 -- 深克隆 & 浅克隆
java面试基础 -- 深克隆 & 浅克隆
8 1
|
4天前
|
Java
java面试基础 -- 普通类 & 抽象类 & 接口
java面试基础 -- 普通类 & 抽象类 & 接口
9 0
|
4天前
|
存储 安全 Java
java面试基础 -- ArrayList 和 LinkedList有什么区别, ArrayList和Vector呢?
java面试基础 -- ArrayList 和 LinkedList有什么区别, ArrayList和Vector呢?
9 0
|
4天前
|
Java
java面试基础 -- 方法重载 & 方法重写
java面试基础 -- 方法重载 & 方法重写
6 0
|
6天前
|
消息中间件 存储 Java
Java分布式技术面试总结(全面,实时更新)
Java分布式技术面试总结(全面,实时更新)
|
6天前
|
监控 Java Nacos
Java微服务框架面试总结(全面,实时更新)
Java微服务框架面试总结(全面,实时更新)
|
13天前
|
消息中间件 存储 监控
RabbitMQ:分布式系统中的高效消息队列
RabbitMQ:分布式系统中的高效消息队列
|
13天前
|
消息中间件 分布式计算 监控
Python面试:消息队列(RabbitMQ、Kafka)基础知识与应用
【4月更文挑战第18天】本文探讨了Python面试中RabbitMQ与Kafka的常见问题和易错点,包括两者的基础概念、特性对比、Python客户端使用、消息队列应用场景及消息可靠性保证。重点讲解了消息丢失与重复的避免策略,并提供了实战代码示例,帮助读者提升在分布式系统中使用消息队列的能力。
46 2
|
13天前
|
消息中间件 Java
springboot整合消息队列——RabbitMQ
springboot整合消息队列——RabbitMQ
84 0

热门文章

最新文章