高并发情况下如何保证消息的顺序

  • Post author:
  • Post category:其他


在知乎上看到一位大牛总结了一些保证消息顺序的方案,在此记录下来学习一下。


在多队列消息处理的场景中,怎样保持多个消息之间的时间顺序,是一个很经典的问题。解决方法当然是有的。



为了讨论这个问题,让我们做一些简化问题的假设:




  1. 有若干个消息队列A、B、C……




2.有若干个线程在产生消息,并分别将消息加入这些队列






3.每个消息队列有一个对应的线程(WorkerA、Worker


B、Worker C……),从队列中读取和处理消息










另外,还有一个很重要的前提:要保持多个消息之间的时间顺序,首先它们要有一个全局的时间顺


序。因此,每个消息在被创建时,都将被赋予一个


全局唯一的、单调递增的、连续的


序列号(


SerialNumber,SN)

。可以通过一个全局计数器来实现这一点。通过比较两个消息的SN,确定其先后顺序。