即时通讯系统架构-机制

MySQL

Mobile

⑫消费

数据库

①登录授权

API接口服务

⑧消息推送

⑬存储

MQ

金企信系统架构图

Consumer

PC

⑤结构化数据操作

Mongodb

④非结构化数据操作

应用服务

运营支撑

业务系统

oAuth统一认证中心

消息队列服务

⑥接口数据返回

统一认证机制：①/⑦ oAuth作为统一认证中心，将所有系统服务保护起来，所有的请求必须先经过oAuth进行认证获取授权Token后才可调用；消息存储机制：⑩⑪⑫ 经Openfire中转的消息都会异步进入MQ消息队列中，然后由多线程可控数量的消费者搬运存储进Mongodb中；三方推送机制：⑦③⑧ 三方系统首先经过oAuth的统一认证，然后带着授权Token访问消息推送API接口，之后由API接口服务将信息推送给Openfire消息服务器；离线消息拉取机制：①③④⑥ 客户端登录oAuth统一认证中心后会调用离线消息获取接口，然后由API接口服务去查询Mongodb获取聊天记录返回给客户端；在线聊天机制：①②⑨⑩ 客户端成功通过oAuth的统一认证后会连接至Openfire消息服务器，此时用户处于在线状态，此状态下收发消息直接由Openfire提供服务；

③接口调用

⑩在线消息接收

②授权通过后连接Openfire

⑦登录授权

⑨在线消息发送

客户端

⑪异步消息存储

Openfire消息服务器