1. 背景信息

上篇提到了, IM协议层是主要解决会话和消息的同步, 在实现上, 以推模式为主, 拉模式为辅.
本文Agenda:

1. (How)如何同步
2. (How)如何设计同步位点
3. 如何设计 Gap过大(SyncGapOverflow) 机制
4. 如何设计Ack机制
5. 总结

提示: 本系列文章不会单纯的给出结论, 希望能够分享的是"如何分析, 如何得出的结论"的思路.

2. 同步协议如何设计

什么是同步协议

同步是通过将server的位置同步到client的位置, 最终实现了消息的同步.

大前提条件

1. 知道client 在哪里
2. 知道server 在哪里

小前提条件
3. client可以同步到server的位置
4. server在此流程中, 将消息内容带给端上

结论
实现消息内容的同步

示例

用户A发送了10,000条消息给B, 并且B仅有A一个会话. server的同步队列, 仅能记录单人的1000个同步事件, 在不同的场景下(场景为何如此划分, 请参考上篇文章)的处理.

scene: 首次登录

scene: 用户在线同步/短暂离线后再次在线同步

scene: 用户长期不在线再次在线后同步

示例场景总结

总共有四个步骤

1. client告诉server, client的同步位点
2. server计算client的同步位点与server的gap
3. server推送之间的gap与最新的同步点
4. 如果server推送之间的gap过大, server会告知client需要自己处理, client标记gap, 拉取最新的会话信息

此四个步骤便是同步协议的核心流程.
如果加上建联的过程. 便是完整的同步协议方案.

如何同步

完整的同步协议方案, 整体可以认为分为四个阶段.

1. 通讯层建连
2. 离线消息同步
3. 在线等待指令
4. 在线消息同步

而细化处理的逻辑如下

如图所示, 可以得出以下的结论

1. 通讯层建联后, 协议层的首个通讯是确定的, 是协议层建连同步.
2. 整个同步协议的核心要素有两个: 同步位点 以及 是否有gap.
3. Ack机制
4. 同步协议中的目的是同步位点同步, 以及消息同步. 那么消息同步是否一定要归属到同步协议中?

因而

• 同步位点以及 gap过大(SyncGapOverflow)的设计 ,成为了解决同步协议端到端方案的核心问题.
• Ack机制如何设计?
• 消息同步是否一定要归属到同步协议中, 是否可以拆出来?

如何设计同步位点

什么是同步位点

同步位点, 是server和client用于判定server的同步队列, 当前已经同步到的位置信息.以及用于server和client之间判断还有那些信息未同步的判断依据.

如何设计

版本号?

版本号的方式, client是OK的. 但是对于server而言, 如果server需要清空对应的队列时, 便需要记录已经清空的最新的版本号. 这样在新消息来临时, 才能比较准确的记录.

时间戳?

时间戳的方式, client是OK的. 如果是比较活跃的群聊, 单位时间内的消息暴涨, 采用毫秒的时间戳, 也是可能会有重复的记录. 建议采用纳秒.

其他方式?

如生成单独的uuid, 也是可以的. 不过对于server而言, 由于是字符串匹配, 检测client已经同步到的位置, 耗时会比较久.
因而采用纳秒级别的时间戳是一种比较好的解决方式.

结论

采取纳秒的方式作为同步位点, 另外, 为了做方便做后续的协议升级, 除了同步位点外, 还需要增加一个同步协议版本号的元素.

即同步协议版本号 + 纳秒的同步位点. 作为同步协议的同步位点解决方案

谁来持有同步位点?

client和server均需要持有同步位点.
server记录client的设备维度的同步位点 + 天然持有的同步队列的同步位点信息.
client记录当前设备上账号的同步位点信息.

如何设计 Gap过大(SyncGapOverflow) 机制

什么是Gap过大(SyncGapOverflow)

ps: 英文名字是我定义出来的.
英文名便比较好理解. Sync Gap Overflow. 同步gap时, 内容过多, server拒绝主动同步. 即告知client, 需要client主动拉取. 从推模式切成了拉模式.

如何做SyncGapOverflow

gap一般的处理, 也是一个端到端的问题.
出现SyncGapOverflow, 是client的同步位点, 已经不在同步队列中.
而不在同步队列中, client的位点太老可以导致, 也可能是server对同步队列做了定期清理机制导致.
因而一般的SyncGapOverflow的触发原因有两类

• client侧的设备首次登录或者超过了长期未登录
• server侧的清理机制导致

如何设计Ack机制

什么是ACK机制

ACK机制, 即ACK消息. “回复已经收到数据”. 而在同步协议的场景下, 是指 client 确认收到了sever的同步数据, 给到server的一个确认消息.
目的:
1. server确认同步消息消费了, 即保证消息的可靠性投递和消费
2. server根据此确认消息, 标记client的当前同步位点

如何设计Ack机制

以用户短暂离线再次在线为例.如图所示.

当用户离线后时, server记录的最新同步位点的index位于10,000, 而client的同步位点的index位于9,000.
用户再次登录时,

1. 通讯层建联
2. client将index为9,000的同步位点上传给到server.
3. server处理9,000的同步位点, 发现位于同步队列中, 并且未达到SyncGapOverflow的条件. 于是批次的下发同步的内容. 如. 50个sync消息作为一个业务包下发.
4. client在收到了9,001 ~ 9050的同步位点数据后, 进行处理
5. 对于处理的结果需要Ack server. 而Ack server有两种结果. SUC和FAIL.
6. 对于SUC的case. server更新client 同步位点到index为9,050.
7. 对于FAIL的case, server认为client处理失败. 进行重试机制的处理, 如 等 3s 在进行重试.
8. 如果重试的次数, 超过了三次. server告知client sync同步失败, client进行兜底的处理. 如端侧reset, 重新初始化.

Ack的逻辑, 可以直接参考TCP的Ack机制.

消息同步是否属于同步协议?

一般来讲, 消息同步是附属于同步协议的, 但是严格来讲, 同步协议与消息同步是可以做分割的
同步协议仅推送最新的同步位点信息,同步后, client 回复ack. 而client每次在收到同步位点信息时, 跟本地做比对, 然后主动拉取中间的消息内容,

即同步协议仅推送server最新的变更通知, client收到通知后, 回复ack. 主动拉取. 最大程度的使用拉模式. 依然以用户短暂离线再次在线为例.如图所示.

处理流程

而这种Ack机制, 也确实保证了是收到了消息通知, 但是没有保证client的消息数据正常处理了. 选择此种方案需要慎重.

3. 结论

本文通过同步协议的各个场景细化, 比较完整的介绍了同步协议的方案. 以及在设计同步协议中, 几个比较关键的元素的设计, 同步位点, Gap过大机制, 以及Ack机制.