分层架构 IM 系统之多媒体功能设计与实现

现在 IM 系统已经不仅限于文本消息的通讯了,多媒体数据占据越来越多的比重,比如:文件传输、语音通话、视频通话等。

在前面的文章(《基于需求分析模型来结构化剖析 IM 系统》)中我们分析过,“多媒体消息” 属于扩展功能需求,“点对点私信消息” 属于基础功能需求,扩展功能以基础功能为基础,基础功能稳定实现后,开发扩展功能是非常简单和快速的事情。今天我们分析一下 IM 系统的文件传输和语音通话功能关键逻辑实现,内容不复杂。

在前面关于分层架构 IM 系统所有文章的描述中,客户端与服务端之间的通讯一直是基于一条 TCP 连接进行的,也就是单通道通讯。其实,在一个具备多种功能的 IM 产品中,前后端的通讯往往都是基于多通道的,也就是每个客户端与服务端之间会建立多条连接(可能是 TCP 协议、也肯能是 HTTP 协议,还可能是 WebSocket 协议),为什么要这样设计呢?

首先,每个通道传输自己专属的数据,避免通道之间相互影响,产生阻塞或延迟,尤其是文本消息数据,需要一个专属的通讯通道;我们知道多媒体数据往往会占用较大空间,如果通过文本消息通道传输多媒体数据的话,很容易影响文本消息的及时性和可靠性。

其次,每个通道传输自己专属的数据,这从底层逻辑上就解耦了逻辑关联,降低了整个系统实现的复杂性;我们在前面的文章(《架构师晋级:直播问答系统(解析)》)中,分析过直播问答系统如何通过多通道设计系统架构,降低复杂度。

下面,我们分别分析一下如何基于 IM 系统实现文件传输和语音通话。

一、文件传输

IM 系统的文件传输逻辑流程,见下图。

基于 IM 系统传输文件,我们需要扩展消息的类型;最常见的消息类型是文本消息,可以扩展出文件消息类型、表情消息类型、语音消息类型、视频消息类型等,只是在聊天窗口中需要以不同的方式进行展示。以客户端 uid=101 给客户端 uid=102 传输文件为例,文件传输的基本逻辑流程如下:

  1. 客户端 uid=101 访问 APPServer,获取访问令牌; APPServer 是需要搭建的内部服务,专门用来管理访问令牌;令牌是客户端用来访问文件服务器(这里以对象存储服务 OSS 为例)的凭证;APPServer 只给合法的客户端发放令牌,毕竟 OSS 是收费的,只能供自己的客户端产品使用。

  2. 客户端 uid=101 凭访问令牌,将文件上传到 OSS,并记录下文件的唯一标识,文件在 OSS 中的存储位置(桶和目录)。

  3. 客户端 uid=101 将文件在 OSS 中存储的相关信息(桶名称、存储目录、文件标识等)封装成 IM 消息,发送到 IM 服务端;这是 IM 消息发送的基本流程,在前面的文章(《分层架构 IM 系统之消息收发功能设计与实现》)中详细分析过。

  4. 若客户端 uid=102 处于在线状态,IM 服务端会将文件消息直接推送到客户端,这个过程通过 “三重保障” 实现消息的可靠性(《分层架构 IM 系统之消息收发功能设计与实现》);若客户端 uid=102 处于离线状态,待登录后,会拉取相关离线消息。

  5. 客户端 uid=102 通过解析,发现是文件消息类型后,请求 APPServer ,获取访问 OSS 的令牌。

  6. 客户端 uid=102 凭访问令牌,根据解析出的文件相关信息(桶名称、存储目录、文件标识等)访问 OSS,将客户端 uid=101上传的文件,下载到本地。

这就是基于 IM 系统进行文件传输的基本流程,第 3 和第 4 步,是消息收发的基本逻辑,以此为基础引入文件存储(OSS),集成和实现对文件存储的安全访问。

二、语音通话

IM 系统的语音通话逻辑流程,见下图。

基于 IM 系统进行语音通话逻辑流程实现,与文件传输类型,都是以 IM 系统传输消息为基础,集成语音通话服务(这里以 WChat 为例进行说明);客户端 uid=101 给客户端 uid=102 打语音电话,其基本的逻辑流程如下:

  1. 客户端 uid=101 访问 WChat,申请一个语音通话的房间,获取房间标识和访问令牌 voiceToken;房间是语音服务的一个逻辑概念,只有进入同一个房间的客户端才能建立语音连接实现语音通话;WChat 建立 “房间” 后,该 “房间” 具有一定的时效性(比如:30秒),若对方没有及时进入到 “房间”,“房间” 会失效;想一下,我们使用微信时通过语音呼叫对方的场景,很容易理解。

  2. 客户端 uid=101 将房间标识信息封装成 IM 消息,发送到 IM服务端;这是 IM 消息收发的基本逻辑。

  3. 若客户端 uid=102 在线,IM 服务端直接将语音消息推送到客户端;若客户端 uid=102 离线,IM 系统需要通过其他方式(手机push、微信消息、短信等)及时通知到用户。

  4. 客户端 uid=102 通过解析,发现是语音消息类型后,向 IM 服务端发出获取 voiceToken 的请求,IM 服务端会通过访问 WChat 获取语音会话令牌;为什么客户端 uid=102 不直接访问 WChat 获取 voiceToken 呢? 一是为了安全性,只有申请房间的客户端可以直接访问 WChat,而要加入房间的客户端,则需要访问 IM 服务端,IM 过滤掉了加入房间的非法用户;二是 WChat 中的房间具有时效性,要加入房间的客户端在访问 IM 时, IM 会对房间的时效性进行判断,IM 过滤掉了没有及时加入房间的用户。

  5. 客户端 uid=102 根据获取的 voiceToken 和房间标识,访问 WChat,加入房间,与客户端 uid=101 建立语音会话。

不管是文件传输,还是语音通话,都是以 IM 消息通道为基础,然后集成相关服务进行扩展。

最后,总结文中关键:

  1. “点对点私信” 是基础功能需求,“多媒体” 是扩展功能需求,基础功能稳定实现后,开发扩展功能是非常简单和快速的事情;

  2. 具备多种功能的 IM 产品中,前后端的通讯往往是基于多通道的,这样设计的原因一是为了避免通道之间的相互影响,导致数据阻塞和延迟,二是为了降低实现的复杂度;

  3. 基于 IM 的文件传输逻辑,以 IM 消息通道为基础,然后引入文件存储服务,实现对文件存储的安全访问;

  4. 基于 IM 的语言通话逻辑,以 IM 消息通道为基础,然后引入语音通话服务,实现对语音通话的安全访问。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/63692.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

0.gitlab ubuntu20.04 部署问题解决

安装依赖: ① sudo apt-get update 出现: 解决方式: 去 /etc/apt/sources.list.d 这个目录删除或注释对应的list文件 第三方软件的源一般都以list文件的方式放在 /etc/apt/sources.list.d 这个目录 重新运行sudo apt-get update 安装…

Next.js v15 - 服务器操作以及调用原理

约定 服务器操作是在服务器上执行的异步函数。它们可以在服务器组件和客户端组件中调用,用于处理 Next.js 应用程序中的表单提交和数据修改。 服务器操作可以通过 React 的 “use server” 指令定义。你可以将该指令放在 async 函数的顶部以将该函数标记为服务器操…

什么是3DEXPERIENCE SOLIDWORKS,它有哪些角色和功能?

将业界领先的 SOLIDWORKS 3D CAD 解决方案连接到基于单一云端产品开发环境 3DEXPERIENCE 平台。您的团队、数据和流程全部连接到一个平台进行高效的协作工作,从而能快速的做出更好的决策。 目 录: ★ 1 什么是3DEXPERIENCE SOLIDWORKS ★ 2 3DEXPERIE…

[Unity]【图形渲染】【游戏开发】Shader数学基础4-更多矢量运算

在计算机图形学和着色器编程中,矢量运算是核心的数学工具之一。矢量用于描述空间中的位置、方向、速度等各种物理量,并在图形变换、光照计算、纹理映射等方面起着至关重要的作用。本篇文章将详细讲解矢量和标量之间的乘法与除法、矢量的加法与减法、矢量的模与单位矢量、点积…

【漏洞复现】CVE-2023-37461 Arbitrary File Writing

漏洞信息 NVD - cve-2023-37461 Metersphere is an opensource testing framework. Files uploaded to Metersphere may define a belongType value with a relative path like ../../../../ which may cause metersphere to attempt to overwrite an existing file in the d…

Bcrypt在线密码加密生成器

具体前往:在线Bcrypt加密工具--使用bcrypt及生成salt的迭代次数强度参数计算生成哈希(摘要)

wxWidgets使用wxStyledTextCtrl(Scintilla编辑器)的正确姿势

开发CuteMySQL/CuteSqlite开源客户端的时候,需要使用Scintilla编辑器,来高亮显示SQL语句,作为C/C领域最成熟稳定又小巧的开源编辑器,Scintilla提供了强大的功能,wxWidgets对Scintilla进行包装后的是控件类:…

构建高性能异步任务引擎:FastAPI + Celery + Redis

在现代应用开发中,异步任务处理是一个常见的需求。无论是数据处理、图像生成,还是复杂的计算任务,异步执行都能显著提升系统的响应速度和吞吐量。今天,我们将通过一个实际项目,探索如何使用 FastAPI、Celery 和 Redis …

【win10+RAGFlow+Ollama】搭建本地大模型助手(教程+源码)

一、RAGFlow简介 RAGFlow是一个基于对文档深入理解的开源RAG(Retrieval-augmented Generation,检索增强生成)引擎。 主要作用: 让用户创建自有知识库,根据设定的参数对知识库中的文件进行切块处理,用户向大…

C/C++圣诞树

系列文章 序号直达链接1C/C爱心代码2C/C跳动的爱心3C/C李峋同款跳动的爱心代码4C/C满屏飘字表白代码5C/C大雪纷飞代码6C/C烟花代码7C/C黑客帝国同款字母雨8C/C樱花树代码9C/C奥特曼代码10C/C精美圣诞树11C/C俄罗斯方块12C/C贪吃蛇13C/C孤单又灿烂的神-鬼怪14C/C闪烁的爱心15C…

投标心态:如何在“标海战术”中保持清醒的头脑?

在竞争激烈的市场环境下,“标海战术”——即大规模参与投标——已经成为许多企业争取市场份额的重要策略。然而,盲目追求投标数量可能导致资源浪费、团队疲劳以及战略目标的模糊化。在这种高强度的竞争模式中,如何保持清醒的头脑,…

研发效能DevOps: Vite 使用 Element Plus

目录 一、实验 1.环境 2.初始化前端项目 3.安装 vue-route 4.安装 pinia 5.安装 axios 6.安装 Element Plus 7.gitee创建工程 8. 配置路由映射 9.Vite 使用 Element Plus 二、问题 1.README.md 文档推送到gitee未自动换行 2.访问login页面显示空白 3.表单输入账户…

NVIDIA DeepStream插件之Gst-nvtracker

NVIDIA DeepStream插件之Gst-nvtracker 1. 源由2. 基础知识3. Gst-nvtracker插件3.1 插件参数3.2 插件API接口 4. 分析问题5. 总结6. 参考资料 1. 源由 这篇的主要目的是稍微吐槽下NVIDIA的设计,当然其实他们做的还是不错的(从系统架构设计角度看&#…

进程内存转储工具|内存镜像提取-取证工具

1.内存转储,内存转储(Memory Dump)是将计算机的物理内存(RAM)内容复制到一个文件中的过程,这个文件通常被称为“内存转储文件”或“核心转储文件”(Core Dump),内存转储的主要目的是…

Lua语言入门 - Lua 面向对象

Lua 面向对象 面向对象编程(Object Oriented Programming,OOP)是一种非常流行的计算机编程架构,通过创建和操作对象来设计应用程序。 以下几种编程语言都支持面向对象编程: CJavaObjective-CSmalltalkC#Ruby Lua 是…

Pyqt6在lineEdit中输入文件名称并创建或删除JSON文件

1、创建JSON文件 代码 import osdef addModulekeyWordFile(self):if "" ! self.lineEdit_module.text():moduleFile self.lineEdit_module.text() .jsonelse:self.toolLogPrinting(请输入模块名称)returnfilePath modulekeyWordFileDir moduleFileif os.path.e…

数据结构--堆的向上调整和向下调整

文章目录 1.完全二叉树2.堆向上调整3.堆向下调整4.测试代码 1.完全二叉树 下面的这个就是对于我们的完全二叉树的这个逻辑结构和物理结构的说明: 逻辑结构就是我们自己认为的进行购想出来的; 但是这个物理结构却是我们的这个数据结构在内存里面的真是…

智能挂号系统设计典范:SSM 结合 Vue 在医院的应用实现

摘要 随着信息技术在管理上越来越深入而广泛的应用,管理信息系统的实施在技术上已逐步成熟。本文介绍了医院预约挂号系统的开发全过程。通过分析医院预约挂号系统管理的不足,创建了一个计算机管理医院预约挂号系统的方案。文章介绍了医院预约挂号系统的系…

Transform组件的用法

文章目录 1. 概念介绍2. 使用方法3. 示例代码我们在上一章回中介绍了Checkbox Widget相关的内容,本章回中将介绍Transform Widget.闲话休提,让我们一起Talk Flutter吧。 1. 概念介绍 我们在这里说的Transform是一种容器类widget,它和Container组件类似。它可以包含其它的组件…

go面试问题

1 Go的内存逃逸如何分析 go build -gcflags-m main_pointer.go 2 http状态码 300 请求的资源可包括多个位置,相应可返回一个资源特征与地址的列表用于用户终端(例如:浏览器)选择 301 永久移动。请求的资源已被永久的移动到新U…