网易视频云消息队列设计中如何保证同一用户的消息按序处理

vcloud.163.com网易视频云：消息队列设计中如何保证同一用户的消息按序处理网易视频云是网易倾力打造的一款基于云计算的分布式多媒体处理集群和专业音视频技术，为客户提供稳定流畅、低时延、高并发的视频直播、录制、存储、转码及点播等音视频的PASS服务。在线教育、远程医疗、娱乐秀场、在线金融等各行业及企业用户只需经过简单的开发即可打造在线音视频平台。现在，网易视频云与大家分享消息队列设计中如何保证同一用户的消息按序处理。消息队列是应用开发的常用工具,也是系统解耦的必备利器。保证同一用户的消息按照顺序处理是应用的常见需求，譬如在微博应用中，发表微博、删除微博这两个操作必须按序处理，乱序势必造成业务逻辑错误。如何保证消息处理顺序？以下是常见的几种做法。设计一：单线程处理。虽然单线程处理非常简单好用，但是单线程限制了系统吞吐率。设计二：每个用户一个队列。看起来很美，实际上基本不可行。首先，每个消息队列基本都没啥消息，其次，不可能为每个用户安排一个线程。设计三：静态消息分发。系统设计分发线程和工作线程，每工作线程设置一个线程私有的消息队列，工作线程从私有消息队列取消息，执行业务逻辑。假定工作线程个数为N,分发线程从全局的消息队列取消息，推消息到第Hash(用户名）%N个线程私有队列。静态消息分发一般来说够用，但也存在一些弱点。首先存在伪冲突，隶属于同一个私有队列的消息按序处理，慢消息将阻塞私有队列中的后续消息，所以无法适用于实时性要求较高的应用。其次，全局阻塞问题。线程私有队列慢时，分发线程停顿，造成全局停顿，几乎无法接受。vcloud.163.com设计四：动态路由消息队列。设计一种新的消息队列，支持以下功能：（1）路由。工作线程取消息时，只能取出不在路由表中的消息，取出消息之后，登记到路由表。（2）ACK。工作线程处理完消息之后，调用ACK接口，消息队列删除消息，并清理路由表。从动态路由消息队列取消息，即不存在为冲突，也不存在全局阻塞，恰好能解决问题。