IM中群聊写扩散如何保证写用户timeline的顺序性?

Sudo · 2 年前

xdm, 写扩散用户的接收timeline是不是也只能单条消息顺序保存呢?

比如: 消息1和消息2同时需要写到用户A的timeline中,

如果是并发的写, 我消息1拿到一个seqNo=1, 消息2拿到一个seqNo=2, 就可能出现消息2写完消息都发给用户了, 消息1还没写完.. 这样前端拉取seqNo不连续的消息就会导致消息丢失

但顺序写timeline的话, 比如我用消息队列的单个partition有序的特点来实现有序性, 那这样在群聊场景, 群里N个人, 消息写到存储库后, 需要再写到群用户的timeline中, 这时候我不能批量写这些用户的timeline, 得发N条mq消息出去, 然后再顺序的单独为每个用户写timeline, 这样成本看起来非常高.

大家的方案是咋样的呢, 有什么最佳实践吗?

2022/7/6 update:

最终还是采用了先写msg表, 再按用户为key发到kafka的partition来顺序写入到用户的timeline里, partition针对key是有序的