冰河技术
导读
♻学习路线
  • 面试必问系列

    • 面试必问
  • 架构与模式

    • Java极简设计模式
    • 实战高并发设计模式
  • Java核心技术

    • Java8新特性
    • IOC核心技术
    • JVM调优技术
  • 容器化核心技术

    • Dockek核心技术
  • 分布式存储

    • Mycat核心技术
  • 数据库核心技术

    • MySQL基础篇
  • 服务器核心技术

    • Nginx核心技术
  • 渗透核心技术

    • 渗透实战技术
  • 底层技术
  • 源码分析
  • 基础案例
  • 实战案例
  • 面试
  • 系统架构
  • Spring6核心技术
  • 分布式事务

    • 分布式事务系列视频
  • SpringBoot
  • SpringCloudAlibaba
  • 🔥AI大模型项目

    • 一站式AI智能平台
    • AI智能客服系统
    • AI智能问答系统
    • 实战AI大模型
  • 中间件项目

    • 手写高性能Redis组件
    • 手写高性能脱敏组件
    • 手写线程池项目
    • 手写高性能SQL引擎
    • 手写高性能Polaris网关
    • 手写高性能RPC项目
  • 高并发项目

    • 分布式IM即时通讯系统(新)
    • 分布式Seckill秒杀系统
    • 实战高并发设计模式
  • 微服务项目

    • 简易电商脚手架项目
  • 手撕源码

    • 手撕Spring6源码
🌍知识星球
  • 总览

    • 《书籍汇总》
  • 出版图书

    • 《深入理解高并发编程:核心原理与案例实战》
    • 《深入理解高并发编程:JDK核心技术》
    • 《深入高平行開發:深度原理&專案實戰》
    • 《深入理解分布式事务:原理与实战》
    • 《MySQL技术大全:开发、优化与运维实战》
    • 《海量数据处理与大数据技术实战》
  • 电子书籍

    • 《实战高并发设计模式》
    • 《深入理解高并发编程(第2版)》
    • 《深入理解高并发编程(第1版)》
    • 《从零开始手写RPC框架(基础篇)》
    • 《SpringCloud Alibaba实战》
    • 《冰河的渗透实战笔记》
    • 《MySQL核心知识手册》
    • 《Spring IOC核心技术》
  • 关于自己
  • 关于学习
  • 关于职场
B站
Github
导读
♻学习路线
  • 面试必问系列

    • 面试必问
  • 架构与模式

    • Java极简设计模式
    • 实战高并发设计模式
  • Java核心技术

    • Java8新特性
    • IOC核心技术
    • JVM调优技术
  • 容器化核心技术

    • Dockek核心技术
  • 分布式存储

    • Mycat核心技术
  • 数据库核心技术

    • MySQL基础篇
  • 服务器核心技术

    • Nginx核心技术
  • 渗透核心技术

    • 渗透实战技术
  • 底层技术
  • 源码分析
  • 基础案例
  • 实战案例
  • 面试
  • 系统架构
  • Spring6核心技术
  • 分布式事务

    • 分布式事务系列视频
  • SpringBoot
  • SpringCloudAlibaba
  • 🔥AI大模型项目

    • 一站式AI智能平台
    • AI智能客服系统
    • AI智能问答系统
    • 实战AI大模型
  • 中间件项目

    • 手写高性能Redis组件
    • 手写高性能脱敏组件
    • 手写线程池项目
    • 手写高性能SQL引擎
    • 手写高性能Polaris网关
    • 手写高性能RPC项目
  • 高并发项目

    • 分布式IM即时通讯系统(新)
    • 分布式Seckill秒杀系统
    • 实战高并发设计模式
  • 微服务项目

    • 简易电商脚手架项目
  • 手撕源码

    • 手撕Spring6源码
🌍知识星球
  • 总览

    • 《书籍汇总》
  • 出版图书

    • 《深入理解高并发编程:核心原理与案例实战》
    • 《深入理解高并发编程:JDK核心技术》
    • 《深入高平行開發:深度原理&專案實戰》
    • 《深入理解分布式事务:原理与实战》
    • 《MySQL技术大全:开发、优化与运维实战》
    • 《海量数据处理与大数据技术实战》
  • 电子书籍

    • 《实战高并发设计模式》
    • 《深入理解高并发编程(第2版)》
    • 《深入理解高并发编程(第1版)》
    • 《从零开始手写RPC框架(基础篇)》
    • 《SpringCloud Alibaba实战》
    • 《冰河的渗透实战笔记》
    • 《MySQL核心知识手册》
    • 《Spring IOC核心技术》
  • 关于自己
  • 关于学习
  • 关于职场
B站
Github
  • 开篇:专栏介绍

    • 开篇:分布式IM即时通讯系统正式启动
    • 面试:可以写到简历上的分布式IM即时通讯系统
  • 第01部分:需求设计

    • 第01节:为何要学习分布式IM即时通讯系统
    • 第02节:分布式IM即时通讯系统的目标与挑战
    • 第03节:分布式IM即时通讯系统功能需求与流程梳理
    • 第04节:分布式IM即时通讯系统技术流程梳理
  • 第02部分:总体架构设计

    • 第01节:分布式IM即时通讯系统总体方案目标与架构设计
    • 第02节:分布式IM即时通讯系统数据模型设计
  • 第03部分:环境搭建

    • 第01节:分布式IM即时通讯系统研发环境搭建
    • 第02节:分布式IM即时通讯系统项目工程搭建
    • 第03节:分布式IM即时通讯系统Maven私服搭建
    • 第04节:搭建并优化多节点Minio分布式文件系统
  • 第04部分:通用模型设计

    • 第01节:分布式IM即时通讯系统通用模型设计
    • 第02节:分布式IM即时通讯系统通用缓存设计
    • 第03节:混合型缓存通用模型设计与实现
    • 第04节:分布式锁通用代码设计与实现
    • 第05节:MQ消息发送通用代码设计与实现
    • 第06节:多系统共用模型与工具推送到Maven私服
    • 第07节:分布式ID生成器的设计与实现
  • 第05部分:即时通讯后端服务

    • 第01节:通用代码设计与实现
    • 第02节:自定义编解码器的设计与实现
    • 第03节:通用ChannelHanler的设计与实现
    • 第04节:登录处理器的设计与实现
    • 第05节:心跳处理器的设计与实现
    • 第06节:单聊处理器的设计与实现
    • 第07节:群聊处理器的设计与实现
  • 第06部分:即时通讯SDK

    • 第01节:发送单聊消息的流程设计与实现
    • 第02节:发送群聊消息的流程设计与实现
    • 第03节:在线状态的统一设计与实现
    • 第04节:消息监听与广播机制的设计与实现
    • 第05节:接收消息发送结果的流程设计与实现
  • 第07部分:大后端平台-通用模型

    • 第01节:领域层对象模型的设计与实现
    • 第02节:用户Session与全局异常捕获机制
    • 第03节:缓存参数过滤器的设计与实现
    • 第04节:通用拦截器规则链的设计和实现
    • 第05节:XSS漏洞校验规则的设计和实现
    • 第06节:滑动窗口IP校验规则的设计和实现
    • 第07节:资源访问校验规则的设计和实现
    • 第08节:账号安全校验规则的设计和实现
  • 第08部分:大后端平台-用户微服务

    • 第01节:用户注册与登录授权的流程设计与实现
    • 第02节:JWT Token刷新机制的流程设计与实现
    • 第03节:用户微服务常规功能的设计与实现
    • 第04节:用户微服务整合即时通讯SDK
    • 第05节:领域事件的发送与接收设计和实现
    • 第06节:用户微服务整合Dubbo的流程设计与实现
  • 第09部分:大后端平台-好友微服务

    • 第01节:好友服务常规功能的设计和实现
    • 第02节:好友微服务整合Dubbo的流程设计与实现
    • 第03节:领域事件的发送与接收设计和实现
    • 第04节:异步更新好友微服务数据的设计和实现
  • 第10部分:大后端平台-群组微服务

    • 第01节:群组微服务常规功能的设计和实现
    • 第02节:群组微服务整合Dubbo的流程设计和实现
    • 第03节:业务事件的发送与接收设计和实现
    • 第04节:异步更新群组微服务数据的设计和实现
  • 第11部分:大后端平台-消息微服务

    • 第01节:单聊消息的发送流程设计和实现
    • 第02节:群聊消息的发送流程设计和实现
    • 第03节:单聊消息的拉取流程设计和实现
    • 第04节:群聊消息的拉取流程设计和实现
    • 第05节:单聊消息的已读流程设计和实现
    • 第06节:群聊消息的已读流程设计和实现
    • 第07节:单聊消息的撤回流程设计和实现
    • 第08节:群聊消息的撤回流程设计和实现
    • 第09节:图片、文件和语音消息的设计和实现
    • 第10节:消息监听回调流程的设计和实现
  • 第12部分:大后端平台-视频通话

    • 第01节:视频通话呼叫发起流程设计和实现
    • 第02节:视频通话呼叫取消流程设计和实现
    • 第03节:视频通话呼叫失败流程设计和实现
    • 第04节:视频通话呼叫接受流程设计和实现
    • 第05节:视频通话呼叫拒绝流程设计和实现
    • 第06节:视频通话呼叫挂断流程设计和实现
    • 第07节:视频通话同步会话状态流程设计和实现
  • 第13部分:大前端UI-基础架构

    • 第01节:Node.js基础环境搭建
    • 第02节:通用基础功能设计与研发
  • 第14部分:大前端UI-用户模块

    • 第01节:注册与登录流程的设计与实现
    • 第02节:页面主体框架设计与实现
  • 第15部分:大前端UI-好友模块

    • 第01节:好友主体页面的设计与实现
    • 第02节:好友关联单聊页面的设计与实现
  • 第16部分:大前端UI-群组模块

    • 第01节:群组主体页面的设计与实现
    • 第02节:创建群组流程的设计与实现
    • 第03节:修改群组流程的设计与实现
    • 第04节:邀请好友进群流程的设计与实现
    • 第05节:群主踢人出群流程的设计与实现
    • 第06节:成员退出群组流程的设计与实现
    • 第07节:群主解散群组流程的设计与实现
    • 第08节:发送群聊消息流程的设计与实现
  • 第17部分:大前端UI-消息模块

    • 第01节:发送文字消息流程的设计与实现
    • 第02节:发送表情消息流程的设计与实现
    • 第03节:发送图片消息流程的设计与实现
    • 第04节:发送文件消息流程的设计与实现
    • 第05节:发送语音消息流程的设计与实现
    • 第06节:双向视频通话流程的设计与实现
    • 第07节:查看历史消息流程的设计与实现
    • 第08节:消息已读未读流程的设计与实现
    • 第09节:实时消息删除流程的设计与实现
    • 第10节:实时消息撤回流程的设计与实现
    • 第11节:群聊@功能流程的设计与实现
  • 第18部分:OpenAI大模型接入服务

    • 第01节:OpenAI总体对接流程架构设计
    • 第02节:OpenAI接入服务总体框架设计
    • 第03节:OpenAI领域模型与核心接口设计
    • 第04节:OpenAI大模型对接设计和实现
    • 第05节:单聊消息对接OpenAI大模型
    • 第06节:群聊消息对接OpenAI大模型
    • 第07节:扩展实现对接多种OpenAI大模型
  • 第19部分:专栏总结

    • 总结:分布式IM即时通讯系统整体专栏总结

《分布式IM系统》需求设计-第04节:分布式IM即时通讯系统技术流程梳理

作者:冰河
星球:http://m6z.cn/6aeFbs
博客:https://binghe.site
文章汇总:https://binghe.site/md/all/all.html
源码获取地址:https://t.zsxq.com/0dhvFs5oR
课程视频:https://t.zsxq.com/144SWUMPi

沉淀,成长,突破,帮助他人,成就自我。

  • 本节难度:★★★☆☆
  • 本节重点:从技术角度梳理分布式IM即时通讯系统的流程,用户请求交互链路、发送消息交互链路、单聊交互链路和群聊交互链路,使研发人员能够从技术角度理解分布式IM即时通讯系统的整个技术流程与技术交互过程。
  • 课程视频:https://t.zsxq.com/144SWUMPi

大家好,我是冰河~~

在前面的文章中,我们对建设分布式IM即时通讯系统过程中要实现的目标与存在的挑战有了大致的了解。并且大致梳理了分布式IM即时通讯系统的功能需求和业务流程,心中大概明确了要开发哪些功能。除了这些,作为技术人员,我们还要从技术的角度梳理下分布式IM即时通讯系统的交互流程。

一、前言

运营或产品经理从实际场景和业务角度提出对应的业务需求后,作为研发人员,不仅需求理解场景和业务需求,还需要将这些场景和业务需求转化成技术实现方案。从技术的角度出发,来梳理需要实现的逻辑与交互流程,例如,用户请求交互链路、发送消息交互链路、单聊交互链路和群聊交互链路等,这样才能从整体链路上理解分布式IM即时通讯系统的实现。

二、本章诉求

在正式设计和编码实现分布式IM即时通讯系统之前,除了要理解业务需求和业务流程外,作为技术人员,还有一项非常重要的事情,那就是从技术角度好好梳理下分布式IM即时通讯系统的请求链路,交互逻辑和技术流程,以便更好的设计和研发分布式IM即时通讯系统。

本章,就从技术的角度出发,梳理下分布式IM即时通讯系统的用户请求交互链路、发送消息交互链路、单聊交互链路和群聊交互链路。

三、用户请求交互链路

从技术的角度来讲,用户通过客户端访问分布式IM即时通讯系统,一般都是通过域名来访问的,通过域名访问系统,就需要DNS服务器做域名解析,将域名解析成对应的IP地址来访问指定的服务器。进入服务器后,会通过Kong/OpenResty/Nginx进入系统的业务网关,再到我们部署的后端平台,IM即时通讯服务。由后端平台、IM即时通讯服务再到基础服务,由基础服务再到数据存储服务。向客户端返回数据时,再按照相反的顺序层层返回。整体链路如图4-1所示。


可以看到,当用户通过域名访问分布式IM即时通讯系统时,会经过如下的请求链路。

(1)用户通过PC/H5/小程序/APP访问分布式IM即时通讯系统时,请求可能会分为HTTP请求、TCP请求或者是WebSocket请求,不管是哪种请求,都会先经过DNS服务器对域名进行解析,解析出IP地址,通过IP地址定位到最终的服务器。

(2)请求进入服务器后,会先经过Kong/OpenResty/Nginx等流量网关或者负载均衡器,将请求发往业务网关。

(3)请求进入业务网关后,如果是HTTP请求,则业务网关会将请求路由到后端平台,如果后端平台此时的业务需要发送即时消息,则后端平台会通过集成的SDK向IM即时通讯服务发送即时消息。如果是TCP请求或者WebSocket请求,则业务网关会将请求路由到IM即时通讯服务,由IM即时通讯服务来处理即时消息。

(4)后端平台和IM即时通讯服务接收到请求后,进行对应的业务处理后,都会调用基础服务的接口来进一步处理业务。

(5)基础服务执行完业务逻辑,会将数据写入数据存储服务,比如Redis、MySQL、ES等数据存储服务中。

(6)后端平台会集成IM即时通讯SDK,并且会集成对接OpenAI大模型的SDK。

当分布式IM即时通讯系统处理完业务逻辑向客户端响应结果数据时,会经过如下的响应链路。

(1)如果客户端只是调用后端平台的接口,来执行后端平台的逻辑,例如搜索用户、查看好友列表、搜索群组、查看群列表等不涉及即时通讯的逻辑时,后端平台处理完业务逻辑并记录相关的数据后,就会按照与请求相反的链路响应数据。

(2)如果客户端调用后端平台的接口,通过后端平台的接口来发送即时消息时,后端平台处理完业务逻辑并记录相应的数据后,会通过集成的SDK服务向IM即时通讯服务发送即时消息,IM即时通讯服务接收到消息后,会通过客户端与IM即时通讯服务建立的长链接,向客户端发送即时消息。

(3)如果客户端是通过WebSocket或者TCP等协议向IM即时通讯服务发送消息,IM即时通讯服务处理完业务逻辑并记录数据后,会通过客户端与IM即时通讯服务建立的长链接,向客户端发送即时消息。

四、发送消息交互链路

查看完整文章

加入冰河技术知识星球,解锁完整技术文章与完整代码

在 GitHub 上编辑此页
上次更新: 2026/4/29 16:18
Contributors: binghe001
Prev
第03节:分布式IM即时通讯系统功能需求与流程梳理
阅读全文
×

扫码或搜索:冰河技术
发送:290992
即可立即永久解锁本站全部文章

星球会员
跳转链接