IM

• 基于Vert.x开发的IM服务端
• 演示地址： http://www.justlive.vip

略 （简单修改了layim的ui）

• 基于Vert.x搭建项目
• 使用Event Bus Bridge将Event Bus扩展到客户端的JavaScript运行环境
• 短连接和长连接配合

• 请求报文 R
• 应答报文 A
• 通知报文 N

用户a向b发送“你好”

• 客户端a向服务器发送请求报文 msg:R
• 服务器收到后给客户端a发送应答报文 msg:A
• 服务器给客户端b发送通知报文 msg:N

可能出现的问题

• 服务器崩溃 N未发出
• 网络波动 N包被丢弃
• 客户端b崩溃 N未接收

增加确认报文

• 客户端b向服务器发送确认请求 ack:R
• 服务器向客户端b发送确认响应 ack:A
• 服务器向客户端a发送确认通知 ack:N

消息的超时与重传

• client-A发出了msg:R，收到了msg:A之后，在一个期待的时间内，如果没有收到ack:N，client-A会尝试将msg:R重发。
• 可能client-A同时发出了很多消息，故client-A需要在本地维护一个等待ack队列，并配合timer超时机制，来记录哪些消息没有收到ack:N，以定时重发

消息的去重

• 绑定msgid

相关

• 客户端重传，保证服务端无状态
• 离线消息需要伪造 ack:N
• 离线消息拉取也要ack，发送offline:R报文拉取消息，收到offline:A后，再发送offlineack:R删除离线消息

消息接收方不在线时的典型消息发送流程

• 客户端a发送消息到服务器 msg:R
• 服务器收到后给客户端a发送应答 msg:A
• 服务器发现客户端b不在线，持久化消息
• 服务器给客户端a发送确认通知 ack:N

离线消息存储主要字段

• 消息接收者
• 消息唯一id
• 发送时间
• 消息发送者
• 消息类型
• 消息体

拉取离线消息流程

• 客户端b拉取客户端a发送的消息请求
• 服务器获取离线消息
• 服务器删除消息
• 服务器返回客户端b消息

多用户拉取离线消息优化

• 先拉各个好友离线消息数量，真正去看消息再去单独拉取
• 一次性拉取所有离线消息，客户端去分组

原因

• 时钟不一致
• 多客户端（多发送方）
• 服务集群（多接收方）
• 网络传输与多线程

方法

• 以客户端或服务器的时序为准
• 服务端生成单调递增的id
• 大部分业务可以接受误差不大的趋势递增id
• 单点序列化

单对单聊天，怎么保证发送顺序与接收顺序一致

• 发送方增加序号seq
• 潜在显示突兀问题

群聊消息，怎么保证各接收方收到顺序一致

• 服务器单点序列化来做

用户a登录时获取全部好友的在线状态

• 服务器储存所有用户在线状态
• 用户状态变更需要修改服务器储存的在线状态
• 用户a登录时，先拉取所有用户列表再去获取在线状态

用户a的好友b状态改变时如何感知

• 方式1.轮询拉取用户b的状态
  • 获取不实时，有延迟
  • 会有大量无效轮询请求，占用服务器资源
• 方式2.用户b退出登录后，服务器修改b的状态，推送b的反向好友
  • 实时
  • 在线好友量很大的时候，会扩散成N个实时通知（消息风暴扩散系数）

保持群聊状态的一致性

• 一般采用拉取模式， 消息风暴扩散系数太高

离线消息表

• 群成员表
  • group_id
  • user_id
  • last_ack_msg_id
• 群消息表
  • group_id
  • send_id
  • msg_id
  • detail
  • time

短连接使用

• 前置http的sso单点接口
• 集群im的slb接口
• 小文件上传、下载接口

长连接使用

• 用户实时上下线通知
• 实时加好友加群
• 服务器发起的其他实时指令