在知乎上看到一位大牛总结了一些保证消息顺序的方案,在此记录下来学习一下。
在多队列消息处理的场景中,怎样保持多个消息之间的时间顺序,是一个很经典的问题。解决方法当然是有的。
为了讨论这个问题,让我们做一些简化问题的假设:
- 有若干个消息队列A、B、C……
2.有若干个线程在产生消息,并分别将消息加入这些队列
3.每个消息队列有一个对应的线程(WorkerA、Worker
B、Worker C……),从队列中读取和处理消息
另外,还有一个很重要的前提:要保持多个消息之间的时间顺序,首先它们要有一个全局的时间顺
序。因此,每个消息在被创建时,都将被赋予一个
全局唯一的、单调递增的、连续的
序列号(
SerialNumber,SN)
。可以通过一个全局计数器来实现这一点。通过比较两个消息的SN,确定其先后顺序。