引言
客服答疑、私信、群聊、直播等全部或者部分场景往往公司必须的。
本文主要走查下IM即时通信的逻辑架构以及常用的消息处理策略。
本文主要内容有：
  • 逻辑架构分层
  • 通信基本场景
  • 消息处理策略
一、逻辑架构分层

1、逻辑架构图示

2、逻辑分层说明

  • 负载均衡：提供四层/七层负载均衡
  • 网关长连：提供长连接网关、该层也包含第三方厂商消息推送通道
  • 路由分发：根据分发到不同的业务场景中的转发服务，避免和长连接耦合
  • 业务逻辑：处理与即时通信相关的业务，单聊、群聊、打赏等
  • 内网网关：负责各个域特殊场景对接和交互

3、消息推送通道

  • 消息通过长连实现消息通信和推送
  • 长连接的心跳维护和保活
  • 当APP退出长连接关闭时可选择第三方辅助通道推送
  • 第三方厂商通道有：苹果手机APNs（Apple Push Notification service）服务、安卓手机GCM（Google Cloud Messaging）服务、厂商公共推送服务。

4、消息发送流程

  • userA发送一条消息到userB
  • userA发送一条消息
  • 消息通过IM系统存储
  • IM系统推送该消息到userB
二、通信基本场景
通信基本场景有：消息内容、消息索引、最近联系人、未读消息等。
未读还可以分为：会话未读以及总未读，需要各自单独维护。
另外架构也与场景关联，如果一个群聊允许5000人和一个只有3个人的群聊会有极大差异。

1、消息内容

  • 消息内容ID
  • 消息内容
  • 消息类型
  • 生产时间

2、消息索引

  • 用户ID
  • 关联用户ID
  • 收发消息类型
  • 消息内容ID

3、最近联系人

  • 用户ID
  • 关联用户ID
  • 消息内容ID
三、消息处理策略

1、发送重试策略

  • 发送消息需要收到IM端回执
  • 若未收到或超时需重试策略

2、幂等处理策略

  • 发送侧针对重试消息生成唯一的messageId
  • IM端根据messageId进行去重

3、消息推送确认

  • IM将消息推送给终端用户侧
  • 终端用户侧返回ack确认机制
  • 未收到消息IM端将重新推送
  • 终端用户侧会对消息幂等处理

4、消息的顺序性

  • IM服务端提供序号生成器
  • 保证群级别消息的顺序性
  • 序号生成器分布式高可用
  • 客户端对接收到的再整流

5、消息的安全性

  • 私有二进制协议代替Json等
  • 使用非对称加密传输协议
  • DNS被劫持和篡改等

6、处理的原子性

  • 使用分布式锁实现
  • 使用分布式事务实现
  • 原子操作的命令和脚本
继续阅读
阅读原文