即时消息技术剖析与实战
袁武林
微博研发中心技术专家
24187 人已学习
新⼈⾸单¥59
登录后,你可以任选4讲全文学习
课程目录
已完结/共 25 讲
即时消息技术剖析与实战
15
15
1.0x
00:00/00:00
登录|注册

01 | 架构与特性:一个完整的IM系统是怎样的?

消息推送
Session维护
协议解析
连接保持
外部接口服务
存储服务
业务处理服务
接入服务
客户端
聊天会话
消息
联系人列表
账号关系
用户账号
安全性
一致性
可靠性
实时性
开发者眼中的聊天系统
使用者眼中的聊天系统
IM系统都有哪些特性?
从一个简单的聊天系统说起
架构与特性:一个完整的IM系统是怎样的?
IM系统架构与特性

该思维导图由 AI 生成,仅供参考

你好,我是袁武林。在接下来的一段时间里,我将和你一起探索 IM 的相关知识。今天是第一节课,我们就先从 IM 的相关概念开始着手。
说起 IM,我估计你会先愣一下,“IM 是 QQ 或者微信这样的即时聊天系统吗?它是不是很庞大,也很复杂?”
今天我们以一个简单的 App 聊天系统为例,来看下一个简单的聊天系统都有哪些构成要素,以此来了解一个完整的 IM 系统是什么样的。

从一个简单的聊天系统说起

我们可以从使用者和开发者两个角度来看一下。

1. 使用者眼中的聊天系统

如果我们站在一个使用者的角度从直观体验上来看,一个简单的聊天系统大概由以下元素组成:用户账号、账号关系、联系人列表、消息、聊天会话。我在这里画了一个简单的示意图:
这个应该不难理解,我来解释一下。
聊天的参与需要用户,所以需要有一个用户账号,用来给用户提供唯一标识,以及头像、昵称等可供设置的选项。
账号和账号之间通过某些方式(比如加好友、互粉等)构成账号间的关系链
你的好友列表或者聊天对象的列表,我们称为联系人的列表,其中你可以选择一个联系人进行聊天互动等操作。
在聊天互动这个环节产生了消息
同时你和对方之间的聊天消息记录就组成了一个聊天会话,在会话里能看到你们之间所有的互动消息。
确认放弃笔记?
放弃后所记笔记将不保留。
新功能上线,你的历史笔记已初始化为私密笔记,是否一键批量公开?
批量公开的笔记不会为你同步至部落
公开
同步至部落
取消
完成
0/2000
荧光笔
直线
曲线
笔记
复制
AI
  • 深入了解
  • 翻译
    • 英语
    • 中文简体
    • 中文繁体
    • 法语
    • 德语
    • 日语
    • 韩语
    • 俄语
    • 西班牙语
    • 阿拉伯语
  • 解释
  • 总结

即时消息(IM)系统是一种实时消息系统,包括用户账号、联系人列表、消息、聊天会话等构成要素。从开发者角度看,IM系统包括客户端、接入服务、业务处理服务、存储服务和外部接口服务。保持连接层的稳定性,提升用户体验。IM系统的特性包括实时性、可靠性、一致性和安全性。实时性要求消息实时触达,可靠性要求不丢消息和消息不重复,一致性要求多用户多终端的一致性体验,安全性要求数据传输安全、数据存储安全和消息内容安全。在后续课程中,将详细探讨如何实现这些要求。

仅可试看部分内容,如需阅读全部内容,请付费购买文章所属专栏
《即时消息技术剖析与实战》
新⼈⾸单¥59
立即购买
登录 后留言

全部留言(57)

  • 最新
  • 精选
  • 恰同学少年
    存储在服务端的作用: 1.会话一方用户不在线,上线时进行消息推送。 2.内容审查,监管,电子证据,法律要求。 3.数据分析,舆情分析。 暂时想到这些😊 是否要在服务端存储消息还是由业务与法律法规所决定的。

    作者回复: 👍

    2019-08-28
    44
  • newzai
    业务模块与接入模块的通信链路是如何设计的。接入模块收到一个消息后,通过什么方式,udp,or tcp等推送到业务模块?业务模块下发消息给用户时,怎么知道用户处于接入模块的那一个实例服务(接入模块肯定是有多个实例同时运行的)

    作者回复: 1. 接入层和业务层可以通过rpc或者mq来进行对接。 2. 推送时,可以在用户上线时维护一个全局的uid到接入网关的映射来做到定向推送,对于超大群或者直播互动场景可以不区分某一个用户落在哪个接入网关,而是让所有网关获取后来下推连到本机的用户。你想想这种方式的优势是什么呢?

    2019-08-29
    7
    13
  • summer
    问题1: 接入层要避免业务 如果用protobuf 怎么定义协议 避免各种业务变动影响就要把内容做抽象一些,就要用字符串 这样就失去protobuf 的效果了怎么办? 问题2 之前问过的 想知道具体一点。是要多端同步的。 收到消息就存入mysql吗?然后在从mysql取出发给用户吗?redis,pika hbase他们的角色是什么样的?

    作者回复: 问题1接入层避免业务也可以考虑使用统一协议的header,body部分直接透传二进制,或者把body的编码分委托给其他的编解码api。另外对于pb还不够紧凑的问题可以再gzip一下后再下推客户端。 问题2一般先落db,然后写离线buffer。db全量,buffer定长或者按时间过期。redis和pika一般比较适合做离线buffer,mysql和hbase一般由于消息的db存储。

    2019-08-29
    2
    11
  • 想比其他专供大厂面试的课程,这个实战的im是真的符合我的口味哈哈哈,买对课程了,im不仅仅是im,里面的技术可以营销平台,网关等出现

    作者回复: 感谢支持

    2019-11-22
    7
  • 蛮野
    存储在客户端,多终端登录时候如何同步(历史)消息的?

    作者回复: 是个好问题,如果消息只存储在客户端,实现多终端消息同步基本上就会非常困难。

    2019-08-28
    7
  • Curry
    我觉得即时消息可以放到MQ中,或者缓存中,使用数据抽取工具周期性的将数据提交服务器,进行持久化。服务器存储历史数据和近实时的数据。

    作者回复: 对,你说的这种方式其实是通过队列来异步化解耦消息存储逻辑。

    2019-08-28
    6
  • 接入服务层是不是就相当于网关层服务的?

    作者回复: 对,是指网关层服务。

    2019-08-28
    2
    6
  • 许童童
    思考题:我觉得是需要的,如果消息接受方不在线,消息总要有一个地方存储,不是存服务器就是存发送方,存发送方显然是不行的,因为那就相当于没有发送。所以最终还是要存到服务器的,但存储形式不限于存储服务,可以是去中心化的,或者是一种缓存机制只保存几天。

    作者回复: 是的,服务端可以只是维护一个用于暂存消息和信令的离线buffer,至于存多久和产品需求以及监管需求相关。

    2019-08-28
    5
  • 影随
    老师您好,我这边有个Netty做websocket服务器的问题,望您解惑,问题如下: 用Netty创建的websocket服务,此时有Netty服务器集群,机器A,B,C 假设客户端 m,n,x 分别这样(m-A,n-B,x-C)连上了服务器,产生一个channel 。 如果我要通过服务器,通过后台管理系统,向m,n,x客户端一次性推送一次相同的消息。 问题是,我需要先找到m,n,x所对应的通道机器,找到机器后再根据channel进行推送呢?还是? 业务逻辑找机器感觉有点奇怪,望老师指点迷津。

    作者回复: 如果m n x都需要接收同样的消息,可以让接入服务器通过消息队列来订阅业务层产生的所有消息就可以啦,就不需要业务层找机器了。

    2019-10-26
    3
    4
  • 东林路易斯
    存不存看需求吧。 1. 消息一定要经过服务端进行过滤验证的,用异步存储性能消耗也不大。 2. 只是存着拿来做什么,多端消息记录同步?历史记录搜索? 3. 多端同步会容易导致设备本地消息记录冲突混乱吧?历史记录搜索也不现实,数据量太大但使用率太低,有点浪费资源。 4. 就算存起来可能真的拿来自己玩,不可能对外提供服务的。例如不合法言论多重扫描鉴别,纠纷记录凭证,大数据进行关键词热点分析等等各种不可描述的商业操作。

    作者回复: 嗯,也要考虑监管方面的需求,多端同步方案合理的话不会导致冲突。

    2019-08-28
    2
    4
收起评论
显示
设置
留言
57
收藏
沉浸
阅读
分享
手机端
快捷键
回顶部