Jack Jiang

我的最新工程MobileIMSDK:http://git.oschina.net/jackjiang/MobileIMSDK
posts - 539, comments - 13, trackbacks - 0, articles - 1

2026年4月20日

本文由云音乐技术团队燕十三分享,有修订和改动。

1、引言

本文分享的是网易云音乐技术团队基于实时消息总线技术,解决了直播活动系统的模块灵活组合、消息治理与异步履约等问题,希望能给你带来启发。

cover-opti

2、系列文章

本文是系列文章中的第 10 篇:

  1. 直播系统聊天技术(一):百万在线的美拍直播弹幕系统的实时推送技术实践之路
  2. 直播系统聊天技术(二):阿里电商IM消息平台,在群聊、直播场景下的技术实践
  3. 直播系统聊天技术(三):微信直播聊天室单房间1500万在线的消息架构演进之路
  4. 直播系统聊天技术(四):百度直播的海量用户实时消息系统架构演进实践
  5. 直播系统聊天技术(五):微信小游戏直播在Android端的跨进程渲染推流实践
  6. 直播系统聊天技术(六):百万人在线的直播间实时聊天消息分发技术实践
  7. 直播系统聊天技术(七):直播间海量聊天消息的架构设计难点实践
  8. 直播系统聊天技术(八):vivo直播系统中IM消息模块的架构实践
  9. 直播系统聊天技术(九):千万级实时直播弹幕的技术实践
  10. 直播系统聊天技术(十):基于实时消息总线的活动系统架构设计》(* 本文

3、技术背景

所谓组装,就离不开老生常谈的复用,我们可以对大部分认为比较共性的场景做好系统级别的封装,封装成一个个复用度较高的服务,然后通过接口和扩展点的方式进行一部分的能力开放,但是有一种场景是解决不了的,就是当一个功能级别的代码执行结束后,希望触发到另外一个功能,同时希望这个功能是可以通过配置去解决的,并且不需要通过开发的手段去解决这类问题。

例如,用户送了一个礼物给一个主播,直播间的贡献榜上对该用户做了积分 +1,这是一个很典型的「履约」类场景,与我们在直播间内下单购买,履约给仓储系统道理是一样的,但是这都建立在这个流程模式是固化的。

而活动往往不是这样的,活动相比这些固化的流程是更为灵活的。

笔者的团队曾经开发过这样一个场景:

用户通过送礼,去帮助主播完成一个直播间虚拟能量条的冲击,而每充满这个能量条都希望做一件事情,这个事情就彰显出业务侧的脑洞大开,第一次的活动是希望给某个榜单加上分数,第二次的活动希望是给主播掉落一个虚拟的宝箱,第三次的活动是给用户发送一些抽奖券,依次类推,只要是做过的功能,他都希望这个事情可以去用,时间久了,就会面临频繁去修改这个模块的代码,当它「结束」后,if 条件式的去触发各个代码,或者策略模式的去魔改代码,对于长期建设来看这种方式并不友好,就我看来这只是这个模块结束后要做这么多事情,那么下一个模块如果从这么多事情挑两件岂不是还要再写一堆代码?

因此我们想到了一个相对比较原始的解决方案:总线式服务。

4、信鸽服务的组合能力

与其说组合,更倾向于用「履约」这个词形容会比较恰当一点,因为对于活动来说,信鸽只做「履约」这一侧的功能比较重要,他要解决的是异步场景的分发类问题,而不是对一些系统做一些 adapter 组合集成的能力。

这里以一个活动场景来做示例:

1

音乐人活动的一个简单的页面主要包含了几个模块功能:

  • 1)用户通过送礼、观看等行为完成相关任务;
  • 2)为喜爱的音乐人加进度条积分;
  • 3)当进度条积分完成某个档位后,触发宝箱的掉落、飘屏送礼等。每个档位的类型是不同的;
  • 4)幸运锦鲤的模块。

对于这样一个活动,从开发的角度来看,其实它是由几个模块进行组装的,除了 4 是需要独立开发的,1、2、3 都可以通过现有的系统进行组装,这里 1 抽象为任务系统,2 抽象为进度条系统,3 也可以抽象为宝箱系统、送礼系统等。

下图是对场景抽象化模块的概念:

2

那么难点来了,通过什么手段可以来将这些模块进行组装呢?

通过图中可以看到,当一个模块完成了他的生命周期,可以发送一份数据,路由系统收到了这个数据之后,会帮我们做一层路由的转发,决定数据会路由到下一个系统上去。下一个系统可能是「奖励系统」也可以是「进度条系统」。

同时可以对这个行为进一步细化的抽象,我们希望这个路由系统充当一个「总线」的角色,「信件」代表了每一个系统希望收到的数据,同时对每一个系统都抽象化成一个目的地,如果我们配置了一份路由关系(抽象为信鸽配置),那么这只「信鸽」可以作为将数据信件为我们带到我们想去的任何目的地,那么对于系统的好处是,系统只需要提供自己接入这个路由系统的能力即可,下一次随便是什么活动,可以直接做一些组合关系。

有了信鸽路由这种思路,针对音乐人活动这种场景,我们可以将一个流程的完整链路梳理出来:

3

图中可以看到,我们对任务、进度条等基础模块,做了一些扩展点(EXT-POINT)来满足业务流程的编排,这在中台里是比较常规的解决问题的手段之一,而在系统模块组组合的场景中,多了一层信鸽服务的概念,在【2】、【3】、【4】的处理流程中,都可以由信鸽来决定数据流向哪个系统,事实证明这个方案是可行也并且有效的。

5、整体架构设计

那么如何设计这样一个组合能力的架构呢?

研发的重心可以分为四个层面:

  • 1)履约能力:当代码结束后做到末端的触发。
  • 2)SDK 接入能力:Interface 级别的包装,天然的 Autoconfigure 能力。
  • 3)全局的标识字典:一份数据如何让所有接入的系统都可以达成共识。
  • 4)系统的自动注册能力:接入 SDK 后,自动上报到信鸽服务的统一管理,自动激活,不需要人工的介入开启。

基于这四个层面,架构设计如下图:

4

从图中可以看到:左侧虚线框代表了一个系统的触发,右边虚线框代表了最终另外一个系统的触达。信鸽系统充当了代理的服务,触发的系统只需要接入信鸽 SDK,当执行完自己的职责之后,对数据做一层组装发送给信鸽系统,信鸽系统会根据发送的信鸽 id,寻找到信鸽的相关配置,信鸽 id 决定了数据会流转到那个接入的子系统上,这个流转可以是同步的也可以是异步的(当然大部分都是异步场景),异步主要依赖「RocketMQ」的投递能力,当转发失败后,会对投递的数据结果集进行备份存储,用于定时步长的重试操作。在以往的实践过程中,大部分场景都是异步的链路,不需要获得下一个子系统提供的返回的结果集,并且「RocketMQ」本身投递消息的出错率也是小概率事件(毕竟4台 broker,出错3台的可能性是极低的),相比 RPC 这类通信级别的接口有绝对的优势。

6、提供的SDK能力

6.1 路由触发

在上图中,我们可以看到对于子系统分成了大概 2 类场景,一种是活动业务域,另外一种是非活动业务域,这本身与业务的场景有关,我们希望所有的子系统都可以按照标准去接入 SDK,但是并不能保证每个子系统提供能力都依靠 SDK,对于一些非活动业务域使用了定制化开发的模式来进行桥接工作,这种桥接工作更像是传统的 adapter 和 ESB 总线思路。

而活动业务域的子系统都可以采取接入 SDK 的模式,这里主要会介绍一下异步的设计思路,当一个子系统接入 SDK 后,会在 Spring 容器创建 bean 的时候,默认创建一个 PushConsumer 的 bean ,添加监听信鸽 「fly」 的 「Listener」 ,这样能做到自动消费到路由的消息,对消息进行解析,假设这个系统可以承担的模块能力分别是 S1 / S2 ..., SN 等功能,那么整体实现图如下图所示。

5

6.2 自动注册

每一个 Provider 的 Server 都是一个独立的应用服务集群,对于每一个 Provider 来说他提供的能力并不是单一的,正如上文所说,一个领域服务(活动 TOY 服务:主要提供各类积木式玩法领域),他能够提供的模块是非常多样的,诸如宝箱、进度条、留言板等等,「act-toy」 服务他具备了许多功能,当 「act-toy」 服务接入 SDK 后,就需要把自己子域需要发布成 Provider 的功能注册到信鸽上,注册的方案如下图。

当一个 Server 拉取 SDK 的启动后,会定时的拉取定义好的 Interface ,对实现的 Class ,获取自定义注解的 Type 类型,通过顺序消息的方式注册到信鸽服务上,采用了启动 + 定时推送的方式,信鸽服务收到相关的注册信息可以后会将其存储。

6

7、与ESB消息总线方案的比较

从整个组合的能力上看,整体的设计思路是符合总线式服务,而总线式服务业内比较经典的,就是 ESB 总线。

ESB 总线这个技术用今天互联网的角度来看是比较过时的,因为他本身更适应用于大型 IT 企业内部的一些跨语言类服务架构方案,而他本身承接了系统和系统之间的桥接能力。但是信鸽本身的设计不同于 ESB 总线,他更注重的特点是「哑管道」的概念,忽略集成的适配转换,也不适合做中心化同步的集成。

那么具体的比较如下:

7

那么可以从2个 ESB 场景来介绍信鸽的优势所在,笔者理解的 ESB 总线技术大致分两类:

1)开源的 ESB 解决方案:这类是提供开源的一种框架技术,部署在同一个 Tomcat 容器中,开发若干个 Bundle 可以运行在容器中,并且能做到热替换的作用,但是每个 bundle 需要通信的模式需要定制私有协议。由于这类开源框架较早,提供的通信协议大部分是 WebService 类的,因此在开发过程中,开发的成本会非常高,例如 Apache 早期开源的 ServiceMix 。关于协议,需要写大量的 「wsdl」 做通信,大多数也是依赖 WebService 发布的接口。

2)自研的 ESB 集成能力:笔者曾经参加过一个企业级的项目,大致是 ESB 的总线集成了各路系统,包括了 Rest 协议接口、C++ 服务发布的 WebService 协议、海外第三方公司发布的 WebService 协议,为了打通公司内部 C++ 服务、Java Web 服务与海外第三方系统,采用的就是做一个集成的总线,这里需要太多的协议转换,包括如何解析 「wsdl」 文件读取节点数据,转换成 Json 等等,这类场景在企业级服务是常见的事情,本身不适用互联网场景,侧重点更偏向于同步接口协议的转换,同时还不知道编排的能力,大部分依靠硬编码来解决。

无论 1 还是 2 与我们信鸽设计思路都是不同的,信鸽本质上强调的是异步去做末端的事件,选用轻量的协议结构,在技术上属于同语言系,因此关于字典的定义也是标准化的,也就是说,userId、anchorId 分别代表了用户id和主播id,并不需要任何一方突发奇想定义 uid、aid 这类的字样,由信鸽来定义统一化的字典,同时编排统一收拢到信鸽服务来确定,是可视化的,不需要编写复杂的 XML 节点文件。

8、与Pipeline流水线方案的比较

从总线这个概念来看,或多或少同「管道」是类似的,Pipeline 的思想被广泛应用在诸多技术领域中。

比如:

  • 1)CI/CD 持续集成的场景;
  • 2)开源框架中的流水线设计模式,例如 Netty框架中的网络字节流处理等;
  • 3)业务自定义的一些工作流流转技术。

第一种场景:更倾向于 DevOps 的解决方案,从持续集成,持续交付,持续部署,为了快速、自动化、可重复的方式的去处理工程,与我们今天要解决的上层业务编排场景是完全不同的两个领域。

第二种场景:本质上是一种代码实现的设计模式,像 Netty 中,采用的是「责任链」的设计模式去实现,网络字节流经过「工厂流水线」后,进行包装,最后得到一个成品,与我们今天要解决的业务同样不是一个领域。

第三种场景:是业务开发过程中经常遇到的问题,尤其是有复杂流程的场景中,这里包含了对流程的编排、服务的编排,每个代码块和服务都可能作为一种处理的「节点」,在整个流水线中进行串排完成业务的实现。与我们的信鸽有什么不同呢?

8

在我看来,两种技术方案是可以同时存在的,我们对已经稳定的领域场景,做一些灵活自定义的一些流程编排,这些流程可以作为「流水线」的思路去实现,在「流水线」末尾的一个流程节点上可以定位为「信鸽」的节点,这个节点可以再继续自由组合定制化的活动场景。

9、信鸽服务的消息转发能力

9.1 面临的问题

直播的活动与营销活动的不同,大部分触发的场景偏向于平台的下游,因此需要监听许多 topic,去实现自己的业务编码,而活动在非成熟的形式背景下,必然要面临大量的短期代码,短期代码的生命周期往往只局限于活动周期内,这类代码代表了探索,代表了拓荒。直播活动在领域建模上是具备双面性的,一方面要在历史的经验去做经验复制和沉淀,另一方面要具备快速展开短期代码的能力。而随着服务数量的增多,就面临着许多服务要监听 topic,而这些 topic 对于 A 服务可能是监听过的,对于 B 服务可能也是监听过的,面临着这类问题,我们需要把 topic 接入的代码做一次代码的 Copy 或者做一些包来解决,但是这并不是一个友好的解决方案。同时,这也面临着另外一个问题,另外一个问题就是当一个代码块完成他的使命后,再也没有开启的那天,他接入的 topic 会一直进行空转的消费,我们不可能经常的对 「Nydus」(云音乐版 RocketMQ )管控平台去做一些消费下线,时间久了,消息治理就变得比较棘手起来,就如同我们去分层解决服务循环依赖,没成想有一天异步链路中也出现了一团乱麻。下面这个图代表了 「dev」 过程中遇到的问题:

9

9.2 解决思路

我们希望信鸽可以继续发挥他的优势,它不仅仅是一个只做业务末端履约的一个总线服务,他更应该帮助我们活动域内的服务做好消息治理这方面的工作,首先需要有一个研发思路的转变,就是开发同学需要为自己 「dev」 的模块去提供他的 topic,这个 topic 与自己 「dev」 的模块是一个技术闭环的,如果每一个 「dev」 的模块都具备这样的能力,信鸽只需要发挥他的优势,对本来需要监听的 topic 变成由信鸽转发给模块的 topic。

10

按照这个解决思路的前提下,我们希望信鸽需要具备的就是消息转发的能力,而这个转发的场景可以抽象为三种。

具体是:

1)业务自定义的分发场景:这个场景是一定要做一些特定业务处理的,通过原始消息,做一些业务清洗工作,再去转发到一些业务场景中,属于定制化的场景。

2)注册上报自动分发的场景:这个场景只要保证信鸽服务的 receiver 监听的 topic 足够,那么信鸽就可以自动分发到各个业务模块的 topic 上,其中分发的消息结构是具备异样的,可以通过 tag 的不同让 consumer 自住选择性拉取,根据 tag 的区分,同时也能解决某类 topic 消息过多,导致饿死的场景,犹如上图提到的一样。

3)消息存储的场景:并不是所有的消息都需要存储,在活动中我们认为较为重要的消息是需要做备份,方便后期去做回放,例如礼物消息,是任何场景使用率较高的,为了提升写入的能力,可以采用批量消费的消费方式,做batch的写入,在写入这里初步选型是用TiDB,TiDB相对DDB(网易分布式数据库)比较适合去存这类消息,同时,这类消息大部分时候是不需要做读操作。

按照提到的三个场景,整体的架构如下:

11

我们的 receiver 可以根据配置过的 topic 动态的在 spring 容器里创建 consumer 的 bean,兼容了新接入 topic,需要修改信鸽服务代码的问题,同时在收到了 topic 消息的那一刻,消息转发如图中所描述一样,分成了三条路。

这三条路代表了:自动转发、自定义转发、消息存储,这里选用三个不同的 consumer,保证消费线程池的足够宽,和转发 topic 队列足够可消费,自动转发收到消息后会根据源 topic 的类型再一次做 Tag 区分的转发到配置的 topic 关系上,同时这个转发关系是可以让研发自助管理的,也可以配置他的存活周期,非常适用于活动短期场景,在活动结束后,减少了服务的空转消费的情况。当然毕竟也要考虑到另外一个问题,多了一跳的操作会导致到转发的失败,对于这种场景,我们会对失败的消息做 exception 的存储,进行重试处理。

同时:我们对信鸽的转发能力做了压力测试,队列的长度设置的足够宽,不考虑写表链路的场景下,单纯的转发能力,消耗 io 的点主要还是集中在 broker 通信的场景上,如果考虑消息都采用异步落盘的情况下,系统的吞吐量会更优,选用了 「8U16G」 的服务器配置,在 32 台 docker 云容器的支撑下,receiver 是可以承担到 300w/min 的消息量,并且 cpu 还能保持到 45% 左右。

虽然信鸽的转发能力解决了我们的问题,但并不代表这是个最优解,我希望的最优解是可以让信鸽搭载 FaaS 平台,毕竟 FaaS 可以提供很多关于消息清洗的场景,而且 FaaS 在机器资源调度上会有更好表现。FaaS + BaaS 这样的组合,是未来系统技术转型的趋势。

10、本文小结

花费时间做一个系统到底带来什么样的好处,又遇到什么难点呢?

10.1 开发维护性

这里用一个 case 来描述研发在使用信鸽服务做业务开发后会带来怎样的好处,大勇作为一名业务研发同学,今天他需要开发一个活动,活动涉及到榜单晋级、直播间杀怪、直播间飘屏、主播任务。

这个活动的流程思路是:

  • 1)主播完成了 「xx」 任务后在直播间掉落一个「怪物」,并发送飘屏通知。
  • 2)主播完成了 「xx」 任务后给榜单加上一些分数。
  • 3)榜单跨日晋级 topN,topN 发送飘屏通知。

很幸运的是、以上涉及到的功能,以前都开发过了,这一次只需要完成组合,很不幸的是,大勇需要开发这类组合能力。直到他遇到了信鸽,一切迎刃而解了,每个功能都接入了信鸽,那么大勇只需要通过信鸽后台,配置好任务完成要飞向「杀怪」、「飘屏」等等信鸽,对于大勇可能只需要很短的时间提测了,发布流程也减少了,一次性的胶水组装代码也不需要,毕竟完成任务掉落怪物,这个逻辑写在任务系统好像也不是很合适。

10.2 遇到的困难

在做消息管理这类问题处理的时候,实现业务覆盖的时候遇到了很多难点。

我们要对现有系统已经接入的 topic 做一些改造,在新业务场景中是屡试不爽的,但是在旧系统中(例如任务系统),新提供了一个任务的 topic,收发路由的旧消息,虽然我们也按照 SDK 的方式做了根据 tag(源 topic)做一些不同 service 的区分,但是这里依然避免不了关于数据清洗和数据结构的协议转换问题,这类问题可能与任务系统本身的清洗思路是有问题的,而这类问题最佳的解决方案一般可以选用脚本语言去做消息清洗会更加灵活一点。

同时在做容量评估的时候,初期的压测并不是很顺利,由于写表链路与信鸽服务存在一个服务中进行压测,如果对某些消息进行数据写入 TiDB 的话,即便是批量消费写入整体服务的吞吐量也是难以压上去的,因此对写TiDB链路的服务单独进行独立,单独进行这方面的压测,信鸽原始服务只做转发,而写存储这一块可以单独去做写能力的评估。

去掉了写 TiDB 链路的场景,单独对服务的进行吞吐量压测,起初选用的 「4U8G」 的服务器资源,由于整体的转发性能较为吃 cpu ,当提升了规格之后,整体的吞吐量有了很明显翻倍,而介于线上消息量的评估,100w/min 的消息可能是我们现有业务的极限状况,我们分别按照不同消息量做了压测,最后输出了一个压测结果集,会根据不同的消息量区间做适当的扩容和缩减。

10.3 未来展望

本文就云音乐大直播活动中台技术团队在日常研发过程中遇到关于业务场景组合、消息管理这类问题,提供了一种系统设计的思路,希望可以帮助读者在日常开发提供一些参考的意见。

目前主要还是围绕着解决现有技术侧问题所展开的,后期会考虑对消息回放这一块作为修复数据的一个重要手段和解决方案,站在异常处理的视角上,如何帮助研发同学快速修复线上问题。

同时,面对未来国际化的场景下,对于消息用户地区机房不够敏感的场景下,希望可以通过一些手段来帮助业务侧消息转发到相关机房,协助 「Nydus」国际化后,解决业务侧路由的不清晰之处,而在未来的国际化路由机房的基础上,如果做到模块之间消息可以准确的路由到用户所在机房也是我们需要更加深入思考的问题。

我们希望信鸽可以作为直播相关产品在活动业务域的重要解决手段之一,帮助更多相关同学解决「复用」、「组合」的烦恼,同时希望它可以国际化,适应更多的产品场景之中。

11、参考资料

[0] 移动端实时音视频直播技术详解(一):开篇

[1] 海量实时消息的视频直播系统架构演进之路(视频+PPT)

[2] 百万在线的美拍直播弹幕系统的实时推送技术实践之路

[3] 阿里电商IM消息平台,在群聊、直播场景下的技术实践

[4] 微信直播聊天室单房间1500万在线的消息架构演进之路

[5] 百度直播的海量用户实时消息系统架构演进实践

[6] 百万人在线的直播间实时聊天消息分发技术实践

[7] 直播间海量聊天消息的架构设计难点实践

[8] vivo直播系统中IM消息模块的架构实践

[9] 万人群聊消息投递方案的思考和实践

[10] 海量实时消息的视频直播系统架构演进之路(视频+PPT)[附件下载]

[11] 社交场景下的统一即时通讯im消息流交互层模块化技术实践

[12] 阿里IM技术分享(八):深度解密钉钉即时消息服务DTIM的技术设计

[13] B站IM消息系统的新架构升级实践

[14] 视频直播技术干货(九):千万级直播系统后端架构设计的方方面面

[15] 视频直播技术干货(十):一文读懂主流视频直播系统的推拉流架构、传输协议等

[16] 视频直播技术干货(十三):B站实时视频直播技术实践和音视频知识入门

即时通讯技术学习:

- 移动端IM开发入门文章:《新手入门一篇就够:从零开发移动端IM

- 开源IM框架源码:https://github.com/JackJiang2011/MobileIMSDK备用地址点此

(本文同步发布于:http://www.52im.net/thread-4914-1-1.html

posted @ 2026-06-08 11:52 Jack Jiang 阅读(30) | 评论 (0)编辑 收藏

一、基本介绍

1

MobileIMSDK-Web是一套纯JS编写的Web端IM即时通讯框架(含服务端):

  • 1)超轻量级、极少依赖;
  • 2)纯JS编写、高度提炼,简单易用;
  • 3)基于著名的socket.io网络库实现,浏览器兼容性好、服务端并发性能好;
  • 4)支持运行于iOS、Android等移动端浏览器和各种PC端浏览器;
  • 5)能与MobileIMSDK的APP版(原生移动端代码编写)完美互通;
  • 6)可应用于手机端/PC端的网页聊天应用、企业OA、Web端消息推送等场景。

☞ 补充说明:MobileIMSDK-Web是 MobileIMSDK 的姊妹工程,MobileIMSDK-Web专注于Web端网页聊天(或推送),而MobileIMSDK用于原生代码编写的移动端IM(或推送)应用,但二者可完美互通——从而实现原生代码编写的移动端与基于html的网页聊天完美互通。

☞ 关于为何使用的是Socket.io而不是Netty作为MobileIMSDK-Web的网络层,详见:MobileIMSDK-Web的网络层框架为何使用的是Socket.io而不是Netty?》。

二、与MobileIMSDK的区别

2

☞ 关于MobileIMSDK

MobileIMSDK主要使用原生代码编写,应用于非Web网页方式的移动端即时通讯场景下(当然最新的MobileIMSDK框架也支持基于HTML5的WebSocket客户端)。

⭐️ 同步开源地址:

☞ 关于MobileIMSDK-Web:
MobileIMSDK-Web完全使用JavaScript编写,主要应用于不支持HTML5的需要兼容旧式浏览器的Web网页方式的即时通讯场景下(包括但不限于手机端、PC端的网页聊天(或消息推送)等)。

☞ MobileIMSDK与MobileIMSDK-Web的互通:

基于MobileIMSDK-Web开发的开发的网页聊天等和基于MobileIMSDK开发的移动端IM等可以无缝地进行消息互通,两个框架之间的通信协议完全兼容,从而实现您的网页聊天(或推送)与手机端原生代码开发的IM(或推送)进行完美协作,实现多端通信。

☞ 我该如何选择?

选择一:如果您的应用是用原生代码编写,如移动端是原生代码编写或者不需要兼容旧式浏览器,那么您可以将 MobileIMSDK 引入到您的项目中从而实现IM(或推送)应用;

选择二:如果您的应用是基于Web网页且需要兼容旧式浏览器,那么您的最佳选择就是使用MobileIMSDK-Web来开发您的网页端聊天(或消息推送)。

三、设计目标 

原生的WebSocket代码或者原始的socket.io代码,使得网络通信代码与大量前端UI界面代码混在一起,使得UI界面的重构、维护、改版都非常困难。而MobileIMSDK-Web工程将让开发者专注于UI应用层的开发,网络通信层专业的代码交由SDK开发人员,从而解偶Web端IM的UI前端和通信层的耦合性,同时大大降低复杂性。

总结一下,MobileIMSDK-Web的设计目标是为您的Web端IM带来以下便利:

  • 1)前端UI代码与网络通信代码解耦:UI界面的重构、维护、改版都非常容易和优雅;
  • 2)服务端网络通信代码与业务代码解耦:使得服务端的业务逻辑实现起来清晰简单;
  • 3)浏览器端的高兼容性:受益于socket.io框架,MobileIMSDK-Web在不支持WebSocket的旧式浏览器上仍可很好地工作;
  • 4)服务端的高并发、高性能:得益于Nodejs的异步编程模型和高并发特性,基于MobileIMSDK-Web编写的IM服务端拥有极高的并发处理性能。

四、框架组成 

整套MobileIMSDK-Web框架由以下2部分组成:

  • 1)浏览器端SDK:用于开发浏览器端页面,纯JS编写,极少依赖,方便对接基于原生JS、Angular、EmberJS、VUE等各种前端框架;
  • 2)服务器端SDK:用于开发Web端IM的服务端,支持高性能和高并发。

目录+精编源码

五、技术亮点

  • ✅️ 轻量易使用:超轻量级——纯JS编写且极少依赖,高度提炼——简单易用;
  • ✅️ 兼容性好:基于socket.io网络框架,浏览器兼容性好,在不支持WebSocket的旧式浏览器上仍可很好地工作;
  • ✅️ QoS机制:完善的消息送达保证机制(真正ACK应答机制),确保不漏过每一条消息;
  • ✅️ 断网恢复能力:拥有网络状况自动检测、断网自动治愈的能力;
  • ✅️ 支持多种设备:支持运行于iOS、Android等移动端浏览器和各种PC端浏览器;
  • ✅️ 封装的通信协议:实现了一个对上层透明的即时通讯通信协议模型;
  • ✅️ 身份认证机制:实现了简单合理的身份认证机制(socket.io官方并未实现之,资料也几乎没有);
  • ✅️ 全消息路径:实现了client to server、server to client、client to client 共3种消息路径(socket.io官方只演示了广播消息,一对一发送无资料);
  • ✅️ 服务端慢io解偶:开发者可通过使用MQ进行DB等慢io的读、写解偶,保证IM实时消息高吞吐和性能;
  • ✅️ 服务端代码解偶:实现了上层应用代码与sdk核心代码的解偶,上线、下线、c2s消息、c2c消息、身份认证等的回调通知;
  • ✅️ 实现了在线列表:服务端实现了一个高性能的在线用户列表机制;
  • ✅️ 完善的log记录:服务端接入了log4js日志框架,确保MobileIMSDK-Web中的每一个关键步骤都有日志输出,让您的运行调试更为便利;
  • ✅️ 浏览器端代码解耦:实现了UI前端代码与sdk网络通信代码解偶,防止前端代码跟IM核心代码混在一起,不利于持续升级、重用和维护;
  • ✅️ 轻松开启数据加密:一个参数即可开启SSL/TLS通信加密;
  • ✅️ 聊天协议兼容:实现了与MobileIMSDK 完全兼容的协议模型。

MobileIMSDK-Web的浏览器兼容性:

x1

MobileIMSDK-Web的兼容性由socket.io网络框架决定:点此查看兼容性说明

六、性能负载

得益于socket.io网络框架的高性能和Nodejs的异步编程模型,MobileIMSDK-Web可支持单机数万甚至上十万并发连接。当然,每种应用场景都有各自的特点和差异,请视具体场景具体评估之,性能数据仅供参考。(关于为何使用的是Socket.io而不是Netty作为MobileIMSDK-Web的网络层,详见《MobileIMSDK-Web的网络层框架为何使用的是Socket.io而不是Netty?》)

☞ socket.io性能测试讨论:socket.io 高并发实战socket.io保持6万+连接测试?如何实现单服务器300万个长连接的?

七、开发者手册

缩略清单-无阴影

八、Demo运行截图

运行效果all_in_one拼合图-opti

九、产品案例

以下为基于MobileIMSDK-Web的Web端IM产品案例 RainbowChat-Web 的产品情况。

rbpw_tb_main1

下图为RainbowChat-Web的主界面更多截图更多演示视频):

main1

下图为RainbowChat-Web的主界面[聊天窗全屏时]更多截图更多演示视频):

main2

本文内容引用自:http://www.52im.net/thread-959-1-1.html

posted @ 2026-06-01 10:51 Jack Jiang 阅读(28) | 评论 (0)编辑 收藏

本文由ArchSynapse AI分享,有修订和重新排版。

1、引言

在为大型语言模型(LLM)应用构建实时前后端通信系统时,选择正确的底层技术至关重要。

本章节将深入剖析三种主流技术的核心原理:

  • 1)Server-Sent Events (SSE):它作为服务器主导的单向数据流的黄金标准;
  • 2)WebSocket:作为通用的全双工通信解决方案;
  • 3)WebRTC:专注于媒体流和点对点数据交换。

理解它们的技术设计哲学和技术细节,是做出明智技术选型的关键基础。

本文将为读者剖析 SSE、WebSocket、WebRTC 的技术原理,并对比三者在性能、安全与架构方面的优劣势,详解了AI大模型(LLM)在实时通信协议方面的综合技术考量以及最终选择。

cover-opti2

2、AI大模型实时通信技术专题

技术专题系列文章目录如下,本文是第 5 篇:

3、SSE是什么?

Server-Sent Events (SSE) 是一种基于标准 HTTP 协议的技术,专为服务器向客户端推送单向事件流而设计。

1

其工作流程始于客户端创建一个 EventSource 对象,该对象会自动发起一个持久的 HTTP GET 请求。服务器接收到请求后,不立即关闭连接,而是保持响应打开,并以特定格式发送数据。

这个格式要求服务器设置 Content-Type 头部为 text/event-stream

每个事件由一系列字段组成,包括:

  • 1)必需的 data: 字段用于承载消息内容;
  • 2)可选的 event: 字段用于定义事件类型;
  • 3)id: 字段用于标识事件以便在连接中断后恢复;
  • 4)以及 retry: 字段用于指定重新连接前的等待时间。

消息之间必须以两个换行符 \n\n 分隔。

这种机制使得服务器能够在一个长连接上持续不断地推送增量数据,非常适合 LLM 流式传输等场景。SSE 的一大优势在于其天然地融入了现有的 HTTP 生态,能够无缝通过反向代理、负载均衡器和防火墙,无需特殊配置。

☞ 进一步学习:

4、WebSocket是什么?

WebSocket 则提供了一种更为强大和灵活的全双工通信协议。它通过一次性的 HTTP 握手来“升级”一个标准的 TCP 连接。

2

握手过程涉及客户端发送一个包含 Upgrade: websocket 和 Connection: Upgrade 等特定头部的 HTTP 请求。如果服务器支持 WebSocket,它会返回一个状态码为 101 (Switching Protocols) 的响应,从而完成协议切换。

一旦连接建立,客户端和服务器就可以随时独立地向对方发送消息,而无需像 HTTP 那样每次都发起新的请求。

WebSocket 消息被封装在轻量级的帧中进行传输,支持文本和二进制数据,极大地降低了网络开销。

这种持久且双向的特性使其成为聊天应用、在线游戏和实时协作工具的理想选择。然而,其复杂性也远超 SSE,因为它是一个独立的协议栈,需要专门的服务器库和客户端处理逻辑。

☞ 进一步学习:

5、WebRTC是什么?

WebRTC (Web Real-Time Communication) 是一个更为复杂的生态系统,旨在实现浏览器间的直接音视频通话和任意数据交换。

3

它的核心思想是尽可能地建立点对点(Peer-to-Peer, P2P)连接,从而绕过中间服务器传输大量媒体数据,以达到最低的延迟。

WebRTC 的整个通信过程分为三个阶段:

  • 1)首先是通过信令服务器交换初始信息;
  • 2)其次是通过 ICE (Interactive Connectivity Establishment) 框架进行 NAT 和防火墙穿越;
  • 3)最后才是建立 P2P 数据通道。

ICE 框架依赖于 STUN (Session Traversal Utilities for NAT) 服务器来帮助设备发现自己的公网 IP 地址,如果直接连接失败,则会降级到 TURN (Traversal Using Relays around NAT) 服务器进行中继。

TURN 服务器虽然能保证连接成功,但会消耗大量带宽,因为所有流量都需要经过它转发。

WebRTC 的另一个关键组件是 RTCDataChannel API,它允许在两个浏览器之间建立一个类似 WebSocket 的 P2P 数据通道,用于传输非媒体数据。

由于其架构的复杂性,WebRTC 通常需要一个额外的信令层(常由 WebSocket 或 SSE 实现)来协调连接的建立。

4

 

☞ 进一步学习:

  1. 访谈WebRTC标准之父:WebRTC的过去、现在和未来
  2. WebRTC实时音视频技术的整体架构介绍
  3. 新手入门:到底什么是WebRTC服务器,以及它是如何联接通话的?
  4. WebRTC实时音视频技术基础:基本架构和协议栈
  5. 实时音视频入门学习:开源工程WebRTC的技术原理和使用浅析
  6. 零基础快速入门WebRTC:基本概念、关键技术、与WebSocket的区别等

6、兼容性、性能与开发复杂度对比

在为 LLM 应用选择实时通信技术时,必须在兼容性、性能和开发复杂度这三个关键维度上进行权衡。本章节将对 Server-Sent Events (SSE)、WebSocket 和 WebRTC 进行全面的横向对比,以揭示它们在不同方面的优劣,从而为技术选型提供数据驱动的依据。

6.1 兼容性与平台支持

首先,在兼容性与平台支持方面,SSE 和 WebSocket 拥有非常广泛的浏览器支持,几乎覆盖了所有现代浏览器,包括 Chrome、Firefox、Safari 和 Edge。Opera Mini 是少数不支持 WebSocket 和 SSE 的例外。IE 浏览器则完全不支持这两种技术。

相比之下,WebRTC 的支持范围稍窄一些,IE 不支持,旧版的 Edge 也不支持,但同样广泛应用于其他现代浏览器及其移动端版本。

对于 LLM 应用而言,这意味着 SSE 和 WebSocket 能够触及更广泛的用户群体。然而,值得注意的是,随着 HTTPS 成为网页标配,HTTP/2 得到了普及,这彻底解决了过去 SSE 在 HTTP/1.1 下因浏览器并发连接数限制(通常是6个)而导致的性能瓶颈,使得 SSE 在现代 Web 架构中表现得更加稳健和高效。

6.2 延迟性能

其次,延迟性能是衡量实时通信技术优劣的核心指标。

理论上,WebSocket 具有最低的延迟,因为它在握手完成后就建立了一个纯粹的、无头开销的数据通道。WebRTC 在 P2P 模式下可以实现极低的延迟,因为它避免了服务器中转。

然而,WebRTC 的延迟受到 NAT/防火墙穿越过程的影响,可能需要 fallback 到较慢的 TURN 中继服务器。

SSE 的延迟取决于底层的 HTTP 版本。在 HTTP/1.1 下,由于队头阻塞(Head-of-Line Blocking),多个 SSE 连接可能会相互阻塞。但在 HTTP/2 下,得益于其强大的多路复用能力,SSE 的性能得到了极大提升,可以与常规 HTTP 请求并行,延迟接近 WebSocket。

一项针对真实世界数据流的测试表明,SSE 和 WebSocket 在 EPS(每秒事件数)方面表现出相当的性能,WebSocket 在高并发下略占优势,但差异在实践中往往可以忽略不计。

因此,对于大多数 LLM 文本流式传输场景,SSE 在 HTTP/2 下已经提供了足够低的延迟。

6.3 开发复杂度

最后,开发复杂度是决定项目成本和上线速度的关键因素。

在这三者中,SSE 的开发复杂度最低。它基于标准的 HTTP,开发者可以利用现有的 Web 服务器和工具链,客户端代码也极为简洁,只需几行 JavaScript 即可启动 EventSource 并监听事件。

WebSocket 的复杂度显著更高。除了协议本身,开发者还需要处理连接管理、状态同步、手动实现心跳包和自动重连逻辑、应对粘性会话(Sticky Sessions)带来的负载均衡挑战,以及在分布式系统中使用 Redis Pub/Sub 等消息队列来广播消息。

WebRTC 的开发复杂度最高,它不仅包含了上述 WebSocket 的所有挑战,还引入了信令、ICE 候选者收集、STUN/TURN 服务器的配置和维护等一系列全新的难题。此外,WebRTC 的安全模型也更为复杂,需要同时保护信令通道和媒体通道。

5

综上所述:SSE 在兼容性、性能和开发复杂度之间取得了最佳平衡,尤其是在 HTTP/2 得到普及的今天。WebSocket 提供了更高的灵活性和更低的理论延迟,但代价是巨大的开发和运维复杂性。WebRTC 则因其固有的复杂性,仅适用于特定的 P2P 和媒体流场景。

7、安全性考量与风险缓解策略

在 LLM 应用中采用实时通信技术时,安全性是不可忽视的核心要素。本章节将深入探讨 Server-Sent Events (SSE)、WebSocket 和 WebRTC 在安全性方面的关键考量、潜在风险及相应的缓解策略。

7.1 Server-Sent Events

对于 Server-Sent Events (SSE),其安全性很大程度上继承自标准的 HTTP 安全模型。

首要的安全措施是强制使用 HTTPS,因为 SSE 的长期连接窗口使其更容易受到中间人攻击(Man-in-the-Middle),窃听或篡改流中的数据。

身份验证是另一个关键环节。由于 EventSource API 不支持自定义 HTTP 头部,传统的 JWT 令牌传递变得困难。常见的解决方案是通过 URL 查询参数传递短时效的访问令牌,但这存在安全隐患,因为令牌可能被记录在服务器日志或浏览器历史中。

另一种更安全的方式是利用带有 SameSite=Strict 属性的 Cookie 来进行认证,这种方式能自动随请求发送,但需要注意 CSRF(跨站请求伪造)攻击的风险,可以通过检查 Origin 头部来缓解。

此外,SSE 端点容易受到 DoS(拒绝服务)攻击,攻击者可以通过建立大量连接耗尽服务器资源。对此,应实施严格的速率限制,限制来自同一 IP 或用户的并发连接数。

7.2 WebSocket

WebSocket 的安全性挑战更为复杂。

虽然 WSS (WebSocket Secure) 使用 TLS 加密来保护数据传输,但其状态化的性质带来了新的攻击面。

首先,WebSocket 缺乏标准化的身份验证机制,开发者必须自行实现,例如在握手阶段通过 Cookie 或查询参数传递凭证。如果未正确验证 Origin 头部,应用将面临 Cross-Site WebSocket Hijacking (CSWSH) 攻击,恶意网站可以在未经授权的情况下建立 WebSocket 连接并访问敏感数据。

其次,WebSocket 容易受到 DoS 攻击,特别是通过 Flood 攻击(发送大量小消息或建立海量连接)来耗尽服务器 CPU 或内存。有效的防御措施包括要求连接前进行认证、限制消息大小和频率、以及实施精细的速率控制 [89]。输入数据也可能导致注入攻击,如 SQL 注入或 XSS,因此所有传入的消息都必须经过严格的验证和清理。

最后,由于 WebSocket 连接是持久的,如果令牌在连接期间过期,可能会导致会话劫持,因此需要实现 token 刷新机制。

7.3 WebRTC

WebRTC 的安全性设计更为严格,其核心理念是端到端加密。

所有媒体流都默认使用 SRTP (Secure Real-time Transport Protocol) 加密,而数据通道则使用 DTLS (Datagram Transport Layer Security) 加密,确保只有通信双方可以解密数据。

然而,WebRTC 的安全性并非万无一失,其脆弱性主要集中在基础设施层面。最著名的安全问题是 IP 地址泄露。由于 ICE 协商需要交换候选者的 IP 地址,即使用户使用了 VPN,其真实的本地和公网 IP 仍可能暴露给通信的另一方,这严重损害了隐私。

缓解此问题的方法是在网络拓扑中强制使用 TURN 服务器中继,从而隐藏客户端的真实 IP。信令通道的安全性至关重要,如果信令服务器未使用 WSS (WebSocket Secure) 或 HTTPS,攻击者可以拦截信令消息,从而发起会话劫持或拒绝服务攻击。

此外,TURN 服务器若配置不当,可能被滥用进行 DDoS 攻击或数据窃取。

最后,尽管 WebRTC 协议本身很安全,但其浏览器实现可能存在漏洞,需要及时更新浏览器以修补已知的安全问题。

6

 

8、架构设计与可扩展性挑战

为 LLM 应用选择实时通信技术不仅关乎功能实现,更深刻地影响着系统的整体架构设计和未来的可扩展性。本章节将深入探讨使用 Server-Sent Events (SSE)、WebSocket 和 WebRTC 时面临的架构挑战,特别是在大规模生产环境下的可扩展性问题。

8.1 Server-Sent Events

使用 Server-Sent Events (SSE) 的架构相对简单且更具弹性。

由于 SSE 基于标准的 HTTP,它可以轻松地与现有的无状态微服务架构集成。服务器可以水平扩展,因为每个 SSE 连接都是独立的,负载均衡器可以将新连接分发到任何可用的服务器实例。

然而,当需要向所有订阅用户广播消息时,简单的无状态架构会遇到挑战。解决这个问题的常见模式是引入一个中央消息代理,如 Redis Pub/Sub 或 Kafka。所有服务器实例都订阅同一个 Redis 频道,当有新消息需要广播时,只需将消息发布到该频道,Redis 会将其高效地分发给所有相关的 SSE 客户端。这种发布/订阅(Pub/Sub)模式极大地简化了广播逻辑,并提高了系统的可扩展性。

此外,SSE 的 stateless nature 使其非常适合在云原生环境中运行,例如 Kubernetes 或 serverless 平台,因为它不需要在节点间共享会话状态。

8.2 WebSocket

相比之下,WebSocket 的架构设计则充满了挑战,其根本原因在于连接的有状态性。

每个 WebSocket 连接都会占用服务器的一个文件描述符,并持续消耗内存和 CPU 资源。当用户数量从数百增加到数万甚至数百万时,这种状态化特性会迅速成为瓶颈。

传统的负载均衡策略(如轮询或最少连接)无法有效分配 WebSocket 连接,因为客户端断线重连后很可能需要回到最初的服务器实例以保持会话状态。

为了解决这个问题,通常需要采用“粘性会话”(Sticky Sessions)或“会话亲缘性”(Session Affinity)的负载均衡策略,但这会导致负载分布不均,并形成单点故障。

更高级的解决方案是构建一个全局状态管理系统,例如将所有连接状态存储在 Redis 等外部数据库中。当服务器 A 接收到需要路由到服务器 B 上某个用户的 WebSocket 消息时,它可以从 Redis 获取目标用户的连接信息并进行转发。这种方法虽然可行,但极大地增加了系统的复杂性和延迟。因此,许多团队最终会选择使用专门的实时通信平台(如 Ably 或 Pusher)来托管这部分基础设施,从而将焦点重新放回业务逻辑上。

8.3 WebRTC

WebRTC 的可扩展性问题则源于其点对点(P2P)的本质。

纯 P2P 架构在小规模群组(例如,最多 4-5 人)内工作良好,因为每个参与者只需要与其他成员建立连接即可。然而,当参与者数量增加时,连接数量会呈二次方增长(N² problem),导致每个客户端的带宽和 CPU 负载急剧上升,很快就会超出个人设备的处理能力。

为了实现 WebRTC 的规模化,必须引入中心化的媒体服务器。

目前主要有两种架构:

  • 1)MCU(Multipoint Control Unit,多点控制单元);
  • 2)SFU(Selective Forwarding Unit,选择性转发单元)。

MCU 会接收所有参与者的媒体流,进行解码、混音/拼接,然后重新编码成一个新的流再分发给所有人,这样客户端只需接收一个流,但 MCU 承担了巨大的计算压力。

SFU 则是一种更高效的架构,它只负责将每个参与者发送的媒体流转发给其他所有人,而不进行任何处理,从而将计算负担分散到各个客户端。SFU 是现代大规模 WebRTC 应用(如 Zoom、Google Meet)的首选架构。

然而,无论是 MCUs 还是 SFUs,都需要大量的服务器资源和复杂的网络基础设施来支持,这对于许多团队来说是一笔巨大的投资。

7

总而言之:

  • 1)SSE 在可扩展性方面提供了最大的灵活性和成本效益;
  • 2)WebSocket 的扩展性挑战巨大,通常需要借助第三方服务或投入大量内部工程资源;
  • 3)WebRTC 的扩展性则最为昂贵和复杂,是专门为媒体流设计的,不适合用于普通的文本数据通信。

9、最终决策与综合建议

在对 Server-Sent Events (SSE)、WebSocket 和 WebRTC 进行了全面的原理、性能、安全性和可扩展性分析之后,本章节将整合所有信息,为 LLM 应用的前后端实时通信提供一个清晰的决策框架,并给出具体的选型建议。

选择何种技术,最终取决于您的 LLM 应用的具体需求、团队的技术栈和预算。我们可以将 LLM 应用的实时通信场景划分为几个典型的层级,每个层级对应不同的技术最优解。

9.1 第一层级:流式文本展示

这是最常见的 LLM 应用场景,用户输入一个问题,然后看到答案逐字或逐词地动态呈现出来。这种模式的核心特征是服务器主导的单向数据流。

在这个场景下,Server-Sent Events (SSE) 是无可争议的最佳选择。

其理由非常充分:

1)首先,SSE 的设计初衷就是为此类单向推送而优化的,它比 WebSocket 更加轻量和简单。

2)其次,得益于现代浏览器对 EventSource API 的原生支持,客户端实现极其简单,且内置了可靠的自动重连机制,极大地提升了用户体验和应用的健壮性。

3)再者,SSE 基于标准 HTTP,在部署和运维上非常友好,可以无缝融入现有的 web 服务生态,无需为实时通信单独搭建一套复杂的基础设施。

Shopify 在其 2022 年黑色星期五活动中的 BFCM Live Map 成功案例,就是一个有力的证明,他们通过 SSE 将毫秒级的数据更新推送给数十万用户,展现了其在生产环境下的强大能力和可扩展性。

9.2 第二层级:双向实时互动

当应用的需求超越了单向展示,进入真正的“对话”或“协作”阶段时,就需要选择能够支持客户端和服务器双向通信的技术。在这种情况下,WebSocket 是唯一的选择。

典型的用例包括:

  • 1)语音 I/O:OpenAI 的 Realtime API 就是一个绝佳的例子,它利用 WebSocket 实现了低延迟的语音对话,允许用户在 AI 说话时打断,并即时获得反馈。这种场景需要双向的音频流和命令流,是 WebSocket 的典型应用。
  • 2)多智能体系统:当多个 AI Agent 需要在后台协同工作,并需要向前端实时同步各自的思考过程、工具调用结果或状态变化时,WebSocket 提供了必要的双向通道。
  • 3)实时协作编辑:当 LLM 作为协作者与用户共同编写代码、文档或进行头脑风暴时,WebSocket 可以确保用户的每一次修改都能被实时同步给 LLM,反之亦然。

选择 WebSocket 的代价是显著增加的开发和运维复杂度。您需要投入资源来构建和维护一个能够处理成千上万个并发长连接的系统,并解决由此带来的一系列可扩展性问题。

9.3 第三层级:点对点媒体流与数据交换

这是 WebRTC 的专属领域。虽然 WebRTC 也能传输数据,但它的核心价值在于绕过服务器直接传输高质量的音视频流。

在 LLM 应用中,WebRTC 的应用场景非常具体且有限:

  • 1)高级语音交互:当需要处理原始的、高保真的音频流,而不是经过编码的文本或语音片段时,WebRTC 可能是必要的底层传输协议。
  • 2)P2P 文件共享:如果 LLM 应用涉及到用户之间直接通过浏览器共享由 LLM 生成的大文件,WebRTC 的 DataChannel 可以提供一条绕过服务器的高速通道。

除非您的应用明确属于上述范畴,否则不应轻易选择 WebRTC。它的高昂复杂性和成本使其成为一个非常规的选择。

9.4 综合决策框架

8

 

9.5 最终结论与建议

对于绝大多数 LLM 应用的前后端通信需求,我们强烈建议从 Server-Sent Events (SSE) 开始。

它足够强大,足以满足当前主流的流式文本展示需求,同时又足够简单,能让团队快速迭代产品。不要为了所谓的“先进性”或过度设计而一开始就选择更复杂的 WebSocket。只有当业务发展到确实需要双向、低延迟的实时互动时,才应该评估并投入资源迁移到 WebSocket。

记住,没有一种技术是完美的,最好的技术是那个能够以最低的成本和复杂度解决你当前问题的技术。

10、参考资料

[0] EventSource API Docs
[1] Web端即时通讯技术盘点:短轮询、Comet、Websocket、SSE
[2] SSE技术详解:一种全新的HTML5服务器推送事件技术
[3] 使用WebSocket和SSE技术实现Web端消息推送
[4] 详解Web端通信方式的演进:从Ajax、JSONP 到 SSE、Websocket
[5] 使用WebSocket和SSE技术实现Web端消息推送
[6] 一文读懂前端技术演进:盘点Web前端20年的技术变迁史
[7] WebSocket从入门到精通,半小时就够!
[8] 网页端IM通信技术快速入门:短轮询、长轮询、SSE、WebSocket
[9] 搞懂现代Web端即时通讯技术一文就够:WebSocket、socket.io、SSE
[10] WebRTC实时音视频技术基础:基本架构和协议栈
[11] 零基础入门:基于开源WebRTC,从0到1实现实时音视频聊天功能
[12] 实时音视频入门学习:开源工程WebRTC的技术原理和使用浅析
[13] 零基础快速入门WebRTC:基本概念、关键技术、与WebSocket的区别等
[14] 大模型时代多模型AI网关的架构设计与实现
[15] 全民AI时代,大模型客户端和服务端的实时通信到底用什么协议?
[16] 通俗易懂:AI大模型基于SSE的实时流式响应技术原理和实践示例
[17] Web端实时通信技术SSE在携程机票业务中的实践应用
[18] ChatGPT如何实现聊天一样的实时交互?快速读懂SSE实时“推”技术

即时通讯技术学习:

- 移动端IM开发入门文章:《新手入门一篇就够:从零开发移动端IM

- 开源IM框架源码:https://github.com/JackJiang2011/MobileIMSDK备用地址点此

(本文同步发布于:http://www.52im.net/thread-4909-1-1.html

posted @ 2026-05-28 11:57 Jack Jiang 阅读(31) | 评论 (0)编辑 收藏

1、写在前面

对于IM系统来说,如何做到IM聊天消息离线差异拉取(差异拉取是为了节省流量)、消息多端同步、消息顺序保证等,是典型的IM技术难点。总结下来其实就是要解决好一个问题:即如何保证聊天消息的唯一性判定和顺序判定。

很多读者在讨论这个问题的时候,普遍考虑的是使用整型自增序列号作为消息ID(即MsgId):这样确实能保证消息的唯一性又方便保证顺序性,但问题是在分布式情况下是很难保证消息id的唯一性且顺序递增的,维护id生成的一致性难度太大了(网络延迟、调试出错等等都可能导致不同的机器取到的消息id存在碰撞的可能)。

1

微信消息序列号实际上是解决消息的唯一性、顺序性问题,可以将一个技术点分解成两个:即将原先每条消息一个自增且唯一的消息ID分拆成两个关键属性——消息ID(msgId)和消息序列号(seqId)。消息ID只要保证唯一性而不需要兼顾顺序性(比如直接用UUID)、消息序列号只要保证顺序性而不需要兼顾唯一性,这样的技术分解就能很好的解决原本一个消息ID既要保证唯一性又要保证顺序性的难题。

那么,如何优雅地解决“消息序列号只要保证顺序性而不需要兼顾唯一性”的问题呢?这就是本文所要分享的内容,强烈建议深入理解和阅读。

2、本文分篇

本文是“IM消息ID技术专题”系列文章的第1篇,总目录如下:

  1. IM消息ID技术专题(一):微信的海量IM聊天消息序列号生成实践(算法原理篇)》(☜  本文)
  2. IM消息ID技术专题(二):微信的海量IM聊天消息序列号生成实践(容灾方案篇)
  3. IM消息ID技术专题(三):解密融云IM产品的聊天消息ID生成策略
  4. IM消息ID技术专题(四):深度解密美团的分布式ID生成算法
  5. IM消息ID技术专题(五):开源分布式ID生成器UidGenerator的技术实现
  6. IM消息ID技术专题(六):深度解密滴滴的高性能ID生成器(Tinyid)
  7. IM消息ID技术专题(七):深度解密vivo的自研分布式ID服务(鲁班)

3、技术背景

微信在立项之初,就已确立了利用数据版本号(注:具体的实现也就是本文要分享的消息序列号)实现终端与后台的数据增量同步机制,确保发消息时消息可靠送达对方手机,避免了大量潜在的家庭纠纷。时至今日,这套同步机制仍然在消息收发、朋友圈通知、好友数据更新等需要数据同步的地方发挥着核心的作用。

而在这同步机制的背后,需要一个高可用、高可靠的消息序列号生成器来产生同步数据用的版本号(注:因为序列号天生的递增特性,完全可以当版本号来使用,但又不仅限于版本号的用途)。这个消息序列号生成器我们微信内部称之为 seqsvr ,目前已经发展为一个每天万亿级调用的重量级系统,其中每次申请序列号平时调用耗时1ms,99.9%的调用耗时小于3ms,服务部署于数百台4核 CPU 服务器上。

本篇将重点介绍微信的消息序列号生成器 seqsvr 的算法原理、架构核心思想,以及 seqsvr 随着业务量快速上涨所做的架构演变(下篇《微信技术分享:微信的海量IM聊天消息序列号生成实践(容灾方案篇)》会着重讨论分布式容灾方案)。

2

4、关于作者

曾钦松:微信高级工程师,负责过微信基础架构、微信翻译引擎、微信围棋PhoenixGo,致力于高可用高性能后台系统的设计与研发。2011年毕业于西安电子科技大学,早先曾在腾讯搜搜从事检索架构、分布式数据库方面的工作。

5、技术思路

微信服务器端为每一份需要与客户端同步的数据(例如聊天消息)都会赋予一个唯一的、递增的序列号(后文称为 sequence ),作为这份数据的版本号(这是利用了序列号递增的特性)。在客户端与服务器端同步的时候,客户端会带上已经同步下去数据的最大版本号,后台会根据客户端最大版本号与服务器端的最大版本号,计算出需要同步的增量数据,返回给客户端。这样不仅保证了客户端与服务器端的数据同步的可靠性,同时也大幅减少了同步时的冗余数据(就像这篇文章中讨论的一样:《如何保证IM实时消息的“时序性”与“一致性”?》)。

这里不用乐观锁机制来生成版本号,而是使用了一个独立的 seqsvr 来处理序列号操作:

  • 1)一方面因为业务有大量的 sequence 查询需求——查询已经分配出去的最后一个 sequence ,而基于 seqsvr 的查询操作可以做到非常轻量级,避免对存储层的大量 IO 查询操作;
  • 2)另一方面微信用户的不同种类的数据存在不同的 Key-Value 系统中,使用统一的序列号有助于避免重复开发,同时业务逻辑可以很方便地判断一个用户的各类数据是否有更新。

从 seqsvr 申请的、用作数据版本号的 sequence ,具有两种基本的性质:

  • 1)递增的64位整型变量;
  • 2)每个用户都有自己独立的64位 sequence 空间。

举个例子,小明当前申请的 sequence 为100,那么他下一次申请的 sequence ,可能为101,也可能是110,总之一定大于之前申请的100。而小红呢,她的 sequence 与小明的 sequence 是独立开的,假如她当前申请到的 sequence 为50,然后期间不管小明申请多少次 sequence 怎么折腾,都不会影响到她下一次申请到的值(很可能是51)。

这里用了每个用户独立的64位 sequence 的体系,而不是用一个全局的64位(或更高位) sequence ,很大原因是全局唯一的 sequence 会有非常严重的申请互斥问题,不容易去实现一个高性能高可靠的架构。对微信业务来说,每个用户独立的64位 sequence 空间已经满足业务要求。

目前 sequence 用在终端与后台的数据同步外,同时也广泛用于微信后台逻辑层的基础数据一致性cache中,大幅减少逻辑层对存储层的访问。虽然一个用于终端——后台数据同步,一个用于后台cache的一致性保证,场景大不相同。

但我们仔细分析就会发现,两个场景都是利用 sequence 可靠递增的性质来实现数据的一致性保证,这就要求我们的 seqsvr 保证分配出去的 sequence 是稳定递增的,一旦出现回退必然导致各种数据错乱、消息消失;另外,这两个场景都非常普遍,我们在使用微信的时候会不知不觉地对应到这两个场景:小明给小红发消息、小红拉黑小明、小明发一条失恋状态的朋友圈,一次简单的分手背后可能申请了无数次 sequence。

微信目前拥有数亿的活跃用户,每时每刻都会有海量 sequence 申请,这对 seqsvr 的设计也是个极大的挑战。那么,既要 sequence 可靠递增,又要能顶住海量的访问,要如何设计 seqsvr 的架构?我们先从 seqsvr 的架构原型说起。

6、具体的技术架构原型

不考虑 seqsvr 的具体架构的话,它应该是一个巨大的64位数组,而我们每一个微信用户,都在这个大数组里独占一格8 bytes 的空间,这个格子就放着用户已经分配出去的最后一个 sequence:cur_seq。每个用户来申请sequence的时候,只需要将用户的cur_seq+=1,保存回数组,并返回给用户。

3

▲ 图1:小明申请了一个sequence,返回101

6.1 预分配中间层

任何一件看起来很简单的事,在海量的访问量下都会变得不简单。前文提到,seqsvr 需要保证分配出去的sequence 递增(数据可靠),还需要满足海量的访问量(每天接近万亿级别的访问)。满足数据可靠的话,我们很容易想到把数据持久化到硬盘,但是按照目前每秒千万级的访问量(~10^7 QPS),基本没有任何硬盘系统能扛住。

后台架构设计很多时候是一门关于权衡的哲学,针对不同的场景去考虑能不能降低某方面的要求,以换取其它方面的提升。仔细考虑我们的需求,我们只要求递增,并没有要求连续,也就是说出现一大段跳跃是允许的(例如分配出的sequence序列:1,2,3,10,100,101)。

于是我们实现了一个简单优雅的策略:

  • 1)内存中储存最近一个分配出去的sequence:cur_seq,以及分配上限:max_seq;
  • 2)分配sequence时,将cur_seq++,同时与分配上限max_seq比较:如果cur_seq > max_seq,将分配上限提升一个步长max_seq += step,并持久化max_seq;
  • 3)重启时,读出持久化的max_seq,赋值给cur_seq。
4

▲ 图2:小明、小红、小白都各自申请了一个sequence,但只有小白的max_seq增加了步长100

这样通过增加一个预分配 sequence 的中间层,在保证 sequence 不回退的前提下,大幅地提升了分配 sequence 的性能。实际应用中每次提升的步长为10000,那么持久化的硬盘IO次数从之前~10^7 QPS降低到~10^3 QPS,处于可接受范围。在正常运作时分配出去的sequence是顺序递增的,只有在机器重启后,第一次分配的 sequence 会产生一个比较大的跳跃,跳跃大小取决于步长大小。

6.2 分号段共享存储

请求带来的硬盘IO问题解决了,可以支持服务平稳运行,但该模型还是存在一个问题:重启时要读取大量的max_seq数据加载到内存中。

我们可以简单计算下,以目前 uid(用户唯一ID)上限2^32个、一个 max_seq 8bytes 的空间,数据大小一共为32GB,从硬盘加载需要不少时间。另一方面,出于数据可靠性的考虑,必然需要一个可靠存储系统来保存max_seq数据,重启时通过网络从该可靠存储系统加载数据。如果max_seq数据过大的话,会导致重启时在数据传输花费大量时间,造成一段时间不可服务。

为了解决这个问题,我们引入号段 Section 的概念,uid 相邻的一段用户属于一个号段,而同个号段内的用户共享一个 max_seq,这样大幅减少了max_seq 数据的大小,同时也降低了IO次数。

5

▲ 图3:小明、小红、小白属于同个Section,他们共用一个max_seq。在每个人都申请一个sequence

的时候,只有小白突破了max_seq上限,需要更新max_seq并持久化

目前 seqsvr 一个 Section 包含10万个 uid,max_seq 数据只有300+KB,为我们实现从可靠存储系统读取max_seq 数据重启打下基础。

6.3 工程实现

工程实现在上面两个策略上做了一些调整,主要是出于数据可靠性及灾难隔离考虑:

1)把存储层和缓存中间层分成两个模块 StoreSvr 及 AllocSvr 。StoreSvr 为存储层,利用了多机 NRW 策略来保证数据持久化后不丢失; AllocSvr 则是缓存中间层,部署于多台机器,每台 AllocSvr 负责若干号段的 sequence 分配,分摊海量的 sequence 申请请求。

2)整个系统又按 uid 范围进行分 Set,每个 Set 都是一个完整的、独立的 StoreSvr+AllocSvr 子系统。分 Set 设计目的是为了做灾难隔离,一个 Set 出现故障只会影响该 Set 内的用户,而不会影响到其它用户。

6

▲ 图4:原型架构图

7、本篇小结

写到这里把 seqsvr 基本原型讲完了,正是如此简单优雅的模型,可靠、稳定地支撑着微信五年来的高速发展。五年里访问量一倍又一倍地上涨,seqsvr 本身也做过大大小小的重构,但 seqsvr 的分层架构一直没有改变过,并且在可预见的未来里也会一直保持不变。

原型跟生产环境的版本存在一定差距,最主要的差距在于容灾上。像微信的 IM 类应用,对系统可用性非常敏感,而 seqsvr 又处于收发消息、朋友圈等功能的关键路径上,对可用性要求非常高,出现长时间不可服务是分分钟写故障报告的节奏。

7

本文的下篇《微信技术分享:微信的海量IM聊天消息序列号生成实践(容灾方案篇)》会讲讲 seqsvr 的容灾方案演变。另:《微信团队分享:来看看微信十年前的IM消息收发架构,你做到了吗》一文中提到的利用sequence序列号实现消息防丢机制的原理,也可以一并阅读之。

8、相关资料

[1] 零基础IM开发入门(四):什么是IM聊天系统的消息时序一致性?

[2] IM消息送达保证机制实现(一):保证在线实时消息的可靠投递

[3] IM消息送达保证机制实现(二):保证离线消息的可靠投递

[4] 如何保证IM实时消息的“时序性”与“一致性”?

[5] IM单聊和群聊中的在线状态同步应该用“推”还是“拉”?

[6] IM群聊消息如此复杂,如何保证不丢不重?

[7] 浅谈移动端IM的多点登陆和消息漫游原理

[8] IM群聊消息究竟是存1份(即扩散读)还是存多份(即扩散写)?

[9] 一套亿级用户的IM架构技术干货(下篇):可靠性、有序性、弱网优化等

[10] 融云技术分享:全面揭秘亿级IM消息的可靠投递机制

[11] 阿里IM技术分享(七):闲鱼IM的在线、离线聊天数据同步机制优化实践

[12] 转转平台IM系统架构设计与实践(一):整体架构设计

[13] 如何保障分布式IM聊天系统的消息有序性(即消息不乱)

[14] 微信团队分享:来看看微信十年前的IM消息收发架构,你做到了吗

即时通讯技术学习:

- 移动端IM开发入门文章:《新手入门一篇就够:从零开发移动端IM

- 开源IM框架源码:https://github.com/JackJiang2011/MobileIMSDK备用地址点此

(本文同步发布于:http://www.52im.net/thread-1998-1-1.html

posted @ 2026-05-19 18:07 Jack Jiang 阅读(27) | 评论 (0)编辑 收藏

本文由37手游黄子键分享,有排版和内容优化等。

1、引言

本文介绍了37手游基于B站goim框架自研长连接系统的实践。系统采用分层设计,支持多协议和发布/订阅机制,用于直播弹幕、实时推送等场景,实现了高性能与业务适配。

cover_opti

2、长连接对于大部分公司的意义

实时的响应总是让人兴奋的,就如你在微信里看到对方正在输入,如你在王者峡谷里一呼百应,如你们在直播弹幕里不约而同的 666,它们的背后都离不开长连接技术的加持。

每个互联网公司里几乎都有一套长连接系统,它们被应用在消息提醒、即时通讯、推送、直播弹幕、游戏、共享定位、股票行情等等场景。而当公司发展到一定规模,业务场景变得更复杂后,更有可能是多个业务都需要同时使用长连接系统。

3、长连接是什么?

长连接,在百科上的定义:指在一个连接上可以连续发送多个数据包,在连接保持期间,如果没有数据包发送,需要双方发链路检测包。

严格上来说:长连接是一种概念,它指的是在网络发送,接收双方保持一个持续连接的状态,双方都可以发送或接收消息(全双工)。

当然,长连接系统听起来好像高深莫测,但实际不可能说完全脱离于我们实际公司的业务去出发设计,这就引出来我们今天的主题—— 长连接技术在37手游内是如何设计以及实践的?

4、技术痛点

从服务端而言:缺乏在SDK内实时推送通知用户的能力,如防沉迷的弹窗通过http定时轮询来实现,给服务造成很大的压力

从客户端而言:也缺乏低成本告知服务端自身在线的能力,如维持用户在线状态靠客户端定时上报心跳到防沉迷服务实现。

5、搭建背景

业务背景:手游的SDK需要提供内嵌直播弹幕的功能,供玩家在看直播的时候进行沟通发言,业界一般会用到长连接来进行实时的推送,以降低服务的轮训和请求。

从业务上而言:直播弹幕需求由于初始量级很少,不用通过长连接的形式也能实现具体业务逻辑;但出于平台的拓展和能力考虑,长连接的能力是必须具备的。

长连接系统的这次搭建,本质是通过SDK内嵌直播弹幕为切入点,从0到1,为平台提供了完整的一套实时推送触达用户的能力。

从以上角度出发:我们便着手想要设计一个高可用且高性能的长连接系统提供给我们使用。

6、方案选型

1

 

从实际上而言,我们考虑三个方向。

1)云服务:

市面上可购买的服务如环信等,大多数都以即时聊天通讯为主,长连接往往只是附带产品,过于偏向于社交业务,在花钱的同时也很难适应到自身游戏业务。

2)开源框架:

b站的goim框架、NettyChat框架、MobileIMSDK框架等,好处是免费且能快速接入,但业务还是不相适应,且语言栈和技术栈不一定相契合。

2

 

3)自研:

开发成本高,且容易踩坑。基础组件完善,统一框架好进行监控和问题查询。且能充分契合自身业务进行拓展,并将数据源掌控在自己手中。

4)结论:

出于扩展性的考虑,肯定是自研的方式更加合适,但完全自研相应的成本和不确定性会非常高,因此最终的选型方案为借鉴b站的goim框架设计和部分代码,并做了符合自身技术栈和业务架构的改善。

可认为是基于开源框架的自研方案的形式完成了长连接这个系统的落地。

7、goim技术概况

7.1 goim是什么?为什么借鉴它?

goim是b站开源研发的一个支持集群的im及实时推送服务。业务上为直播间的弹幕发送场景。

主要考虑到:

  • 1)技术栈契合:语言栈为Golang ,消息队列为kafka,缓存设计为redis;
  • 2)高性能:有压测报告,性能设计有保障;
  • 3)多协议支持:websocket、tcp。

7.2 goim的模块?

3

如上图所示:

  • 1)comet:用于跟端上保连,在内存中存储订阅信息;
  • 2)logic:用于处理鉴权,在线房间等业务逻辑;
  • 3)business:业务服务;
  • 4)balancer:负载均衡模块;
  • 5)discovery:服务发现模块;
  • 6)job:kafka用于削峰。redis用于缓存房间信息;
  • 7)logic和comet的通讯:采用rpc,优化性能。

从上面的goim的设计而言,我们可以总结出长连接的设计原则。

长连接架构的设计总是大同小异的,通用的有这几点:

  • 1)业务层次分明:分接入层,逻辑层,存储层,服务发现层;通过这几层,实现业务解耦
  • 2)协议通用:传输的数据协议必须在所有服务内进行通讯,并支持扩展
  • 3)上行和下行收敛:上行和下行都会有一个对应的网关来进行收敛消息的收敛
  • 4)消息削峰:通过队列来将发送信息削峰。并使接入层和逻辑层解藕

8、手游长连接系统的设计实践

根据以上的通用设计原则,我们不难得出,需要针对goim的架构如何做适配才能实际满足我们的业务需求,下面我们将会一一介绍。

8.1 架构改动

4

从架构而言,我们改动的点不多:

  • 1)cient获取连接节点:手游内无统一的服务发现模块,但有外层LB,因此通过LB来实现comet节点负载均衡
  • 2)推送消息:同上,消费者获取节点时需要到logic服务中查询,而不是discovery
  • 3)服务通讯协议:由于手游内架构通讯协议的统一,接入层和逻辑层的通讯由RPC转为http

8.2 逻辑改动

1)鉴权机制:客户端第一次连接上comet的时候,会发送鉴权上行。comet会解析客户端传输的数据,若包体协议或对应的签名错误,comet会将会直接主动断连

2)心跳机制:comet会有心跳计时器,若客户端无定时上报心跳,则认为该连接已经超时,直接断开。这种业务的心跳主要是为了防止僵尸连接的存在。

3)回包机制:客户端每发送一次上行操作,comet都会有对应的消息回包给端上。端上可根据回包,来知道自己鉴权,心跳,或者订阅,退订的操作是否成功,从而决定是否进行重试。

4)发布/订阅机制:

我们在观看goim的源码时,发现goim适用于直播,群体推送以房间为维度,带有强业务属性,因此我们针对该部分抽象出发布/订阅机制。将房间抽象为topic,修改进房/出房动作为  订阅/退订。

将所有的通知抽象为业务事件,客户端想要接受到哪个事件过来的消息时,可发送对应的订阅上行。单个连接订阅的事件不做限制,对某个用户或某个事件范围内的用户推送消息时,comet会根据事件去取到推送的用户,只有用户订阅了才会收到消息。

5)内存设计:

  • a. bucket维护消息通道和事件的信息;
  • b. 一个session对应一个用户连接;
  • c. 根据sessionid做一致性哈希来选择落到那个bucket上;
  • d. bucket有两个map,一个是session map,一个是topic map;
  • e. 所有bucket都会开启一个chan做监听,广播的时候,会通知到所有bucket,所有bucket再取出某个事件的所有连接进行下发。
5

8.3 总体交互

6

8.4 总体特点

因此,我们可以总结出来,我们手游长连接系统的总体特点:

  • 1)纯golang实现;
  • 2)多协议支持:websocket和tcp;
  • 3)可拓扑结构:主要模块均无状态,可横向扩展;
  • 4)消息支持单推/群推,消息协议业务可自定义;
  • 5)发布/订阅机制,事件可业务自定义。

9、性能评估

在说性能之前,我们先抛出一个疑问:协程数过多实际占用的是什么?连接数过多是否影响CPU?

从实际上来说:长连接的性能瓶颈一般卡在接入层,因此以接入层为评估维度,通过全链路压测得出来结果。

如下:

  • 1)压测参数:3000连接+ 3000 qps的实时推送;
  • 2)推送内容:{msg:test}  ;
  • 3)推送类型:群推;
  • 4)推送持续时长:5分钟 ;
  • 5)资源使用:1核2G的容器;
  • 6)CPU的使用:达到100%。

目前采用的长连接系统,通过压测结果发现,本身的连接数的维持和实时推送实际影响到是机器两个维度的性能,推送量影响到的是CPU,连接数影响到的是内存。分别提高两个参数对相应的内存,CPU的影响并不大。

10、实际应用情况

直播弹幕:

7

 

悬浮球实时红点:

8

从实际上来说,接入的业务虽小,但基础能力已经具备。

11、本文小结

长连接系统从根本上来说,对应的设计都是大同小异的,我们应该更加关注的是对于自身业务的适配以及实现。

12、参考资料

[1] 以网游服务端的网络接入层设计为例,理解实时通信的技术挑战

[2] 知乎千万级并发的高性能长连接网关技术实践

[3] 手淘亿级移动端接入层网关的技术演进之路

[4] 喜马拉雅自研亿级API网关技术实践

[5] 石墨文档单机50万WebSocket长连接架构实践

[6] 小米小爱单机120万长连接接入层的架构演进

[7] B站基于微服务的API网关从0到1的演进之路

[8] 去哪儿网酒店高性能业务网关技术实践

[9] 百度基于Go的千万级统一长连接服务架构实践

[10] 揭秘腾讯公网TGW网关系统的技术架构演进

[11] 基于Netty的携程高性能网关异步改造实践

[12] 手把手教你写基于TCP的Socket长连接

[13] 正确理解IM长连接、心跳及重连机制,并动手实现

[14] 万字长文:手把手教你实现一套高效的IM长连接自适应心跳保活机制

[15] 用JWT技术解决IM系统Socket长连接的身份认证痛点

[16] TCP/IP详解 - 第11章·UDP:用户数据报协议

[17] TCP/IP详解 - 第17章·TCP:传输控制协议

[18] WebSocket从入门到精通,半小时就够!

[19] 快速理解TCP协议一篇就够

[20] 快速理解TCP和UDP的差异

[21] 一泡尿的时间,快速搞懂TCP和UDP的区别

[22] 到底什么是Socket?一文即懂!

[23] 我们在读写Socket时,究竟在读写什么?

[24] 假如你来设计TCP协议,会怎么做?

[25] 深入操作系统,一文搞懂Socket到底是什么

即时通讯技术学习:

- 移动端IM开发入门文章:《新手入门一篇就够:从零开发移动端IM

- 开源IM框架源码:https://github.com/JackJiang2011/MobileIMSDK备用地址点此

本文同步发布于:http://www.52im.net/thread-4907-1-1.html

posted @ 2026-05-06 22:27 Jack Jiang 阅读(48) | 评论 (0)编辑 收藏

1、关于RainbowChat

 1

RainbowChat是一套基于开源IM即时通讯聊天框架 MobileIMSDK 的产品级移动端IM系统RainbowChat源于真实运营的产品,解决了大量的屏幕适配、细节优化、机器兼容问题。RainbowChat可能是市面上提供im即时通讯聊天源码的,唯一一款同时支持TCP、UDP、WebSocket三种通信协议的IM产品。与姊妹产品 RainbowTalk 和 RainbowChat-Web 技术同源,历经考验。

2、关于MobileIMSDK开源工程

2

MobileIMSDK 是一套全平台开源IM即时通讯聊天框架,超轻量级、高度提炼,一套API优雅支持UDP 、TCP 、WebSocket 三种协议,客户端支持iOS、Android、H5、小程序、Uniapp、标准Java、纯血鸿蒙等,服务端基于Netty编写,性能卓越、易于扩展。

3

工程同步开源地址:

2、v12.0 版更新内容

此版更新内容更多历史更新日志):

(1)Android端主要更新内容全面适配Android 16、适配16KB page size、适配全面屏特性等】:

  • 1)[bug] 解决了两个表情占位符重复的问题;
  • 2)[bug] 解决了好友列表删除唯一好友后,一直转圈的问题;
  • 3)[bug] 优化了搜索聊天记录时,当首页“消息”中不存在该陌生人时,搜出的群聊详细中消息发送者昵称会用uid显示的问题;
  • 4)[bug] 解决了不支持分区存储的老手机转发的大文件消息,在新系统上无法下载的问题;
  • 5)[bug] 优化了存在多条置顶消息时,不是按置顶时间而是消息时间排序的问题;
  • 6)[新增] 二维码生成界面下方增加功能按钮;
  • 7)[新增] “用户信息”界面增加了“查看用户资料”按钮;
  • 8)[新增] 优化了世界频道的打开入口等;
  • 9)[新增] 去掉了“商城”模块,增加了“发现”页面;
  • 10)[优化] 将核心层提炼成独立的chatkit模块;
  • 11)[优化] 解决了独立chatkit后,好友信息中删除对方时,无法自动跳转到主页的问题;
  • 12)[优化] 现在不能删除首页列表中的“确认提醒”这个item了;
  • 13)[优化] 升级腾讯Bugly至4.1.9.3,解决上架国内应用市场的隐私合规问题;
  • 14)[优化] 登录和退出登录接口中废弃了osType字段;
  • 15)[优化] 优化了注册界面中关于服务端返回邮箱格式不正确的错误码的处理;
  • 16)[优化] 支持小窗、分屏显示;
  • 17)[优化] 只有好友才能查看对方的注册和登录时间;
  • 18)[优化] 查找好友时不再显示对方的在线状态;
  • 19)[优化提升targetSdkVersion至36,全面兼容Android 16
  • 20)[优化开发工程升级适配AGP 9.1最新版
  • 21)[优化] 升级权限框架以适配最新Android 16系统;
  • 22)[优化] 针对全部界面适配系统强制的Edge to Edge全面屏特性
  • 23)[优化] 解决了Android 16下聊天界面输入法弹出时会挡住消息输入框的问题;
  • 24)[优化] 解决基于PopupWindow实现的弹出界面底部在Edge to Edge全面屏特性下的显示问题;
  • 25)[优化] 加固一处因多线程安全问题导致的可能崩溃风险;
  • 26)[优化] 升级高德地图SDK至最新v11.1等,适配google play强制16KB page size问题
  • 27)[优化] 优化了位置消息搜索界面的搜索组件ui并提升了细节体验;
  • 28)[优化] 解决了进入了主页搜索界面在Android 16下不能自动弹出输入法,及优化了点击背景可收起软键盘;
  • 29)[优化] 删减了APP首次启动时的权限申请内容;
  • 30)[优化] 解决了Android 16下返回按钮事件捕获失败的问题;
  • 31)[优化] 聊天界面下方的功能面板图标美化等;
  • 32)[优化] 聊天文本框自动换行;
  • 33)[优化] 其它更具现代感的UI细节优化和体验等;

(2)服务端主要更新内容安全加固、新增接口等】:

  • 1)[bug] 解决了对接RainbowChat-Web产品时,网页端无法正常登录的问题;
  • 2)[优化] 加固了后端SQL防注入逻辑;
  • 3)[优化] 开启了WebSocket协议支持;
  • 4)[优化] 对离线数据表中的消息指纹字段增加了索引,提升查询性能;
  • 5)[优化] 优化了文件下载服务中存在利用文件名进行越权文件操作的安全隐患;
  • 6)[优化] 提供了一个校验token与uid一致性的安全性实现示例;
  • 7)[优化] 优化了原Android专用的登录接口【接口1009】,使之同时支持验证码、密码登录;
  • 8)[优化] 【接口1008-10-22】新增了“preview_count”字段;
  • 9)[优化] 将IDEA工程中applicationContextRoot改成了rainbowchat_pro/(方便开发环境跟生产环境一致);
  • 10)[优化] 优化了注册接口【接口1008-1-7】,增加了手机号和短信验证码支持;
  • 11)[新增] 数据库新增了注销登录相关字段;
  • 12)[新增] 新增注销登录接口;
  • 13)[新增] 新增获取验证码接口【接口1008-1-27】;
  • 14)[新增] 新增新的登录接口【接口1017】,同时支持ios等客户端的验证码、密码登录;
  • 15)[新增] 新增对接鸿蒙NEXT产品时支持华为Push Kit离线推送;

3、升级后的主要UI运行截图

 更多截图请查看:Android端运行截图iOS端运行截图

4_s100_p75

4、真机运行视频

(☞ 新窗口中查看真机运行视频

5

5、真机实拍截图

6_pct85

posted @ 2026-04-27 17:22 Jack Jiang 阅读(54) | 评论 (0)编辑 收藏

网易技术团队旭风分享,有排版优化和修订。

1、引言

一款社交产品的诞生,离不开即时通讯(IM)场景。随着团队业务版图在社交领域的布局,诞生了多个社交场景APP,涉及的IM场景,包含私聊、群聊、聊天室等。

这些IM场景,在消息流的展示形式上是极为相似的,同时每个业务又有着自己特殊的交互需求。基于此,我们对IM消息流能力做了标准化的构建,来减少IM功能的业务接入成本;同时也是为了统一各个业务的技术方案,减少跨业务开发的理解和维护成本。本文主要针对iOS端在IM消息流交互层的设计上,提供一些实践思路。

cover_opti

2、业界的实现方案

目前业界有各种即时通讯服务商提供的配套交互层解决方案,其大多以牺牲灵活性来满足快速集成需要,在定制能力上远不能胜任我们业务需要。

再诸如 MessageKit之类的社区IM框架,其在视觉交互表现上功能完备,能帮助我们快速、灵活搭建IM消息流结构,但业务需要的是一套完整的携带消息交互能力的方案,因此对此类框架,仍需要做不小的改造才能适应我们的业务(另一参考方案:MobileIMSDKGitee源码托管地址))。

3、我们的想法

对于一个IM消息流交互层方案,主要考虑几个方面:

  • 1)规范的消息流结构:提供消息流视图结构规范化的构建方式;
  • 2)标准的消息交互能力:统一消息交互能力,业务方按需使用,快速集成;
  • 3)业务拓展性:针对数据源、消息交互能力提供业务灵活拓展点;
  • 4)业务接入成本:内置通用交互方案,降低业务接入成本。

目前,我们存量业务中的IM场景,底层IM能力主要由云信引擎提供。同时又存在基于业务服务端,通过HTTP去交互的场景。

另外,还需要预留后期切换IM引擎的可能性,因此需要将交互层IM能力抽象出来。

此外,为了适应团队现状,减小业务接入成本,考虑将云信提供的交互能力内置在方案中。

4、整体设计

设计愿景:提供标准化的能力,同时对拓展开放。

我们期望一套通用的IM消息流能力,能够在方案上标准化。这里的标准化,主要包含消息流结构构建的标准化,以及消息交互能力的标准化。同时,方案需要在交互能力上适应不同业务场景,因此采用依赖注入的方式,提供业务定制能力。

按照职能划分,将框架整体分为了两层:

1

 

1)消息流结构层:负责消息流结构的构建,定义消息视图、布局、数据上的规范,提供业务层分别在「消息」、「会话」两个维度的配置能力。

2)消息交互层:提供消息能力、消息流、消息数据方面的交互能力,向下依赖交互接口,内置标准交互能力的同时,也支持业务按需注入交互实现。

5、聊天消息流的显示结构

5.1 消息组件

不同的业务场景,消息流样式表现必然有所差异。

下面列出了我们几个业务中的消息流界面:

2

如何设计一套通用的消息流视图结构,满足不同业务需要?经过对各个业务以及一些主流IM工具的观察,将消息视图结构设计成如下结构,是能够满足我们各个IM场景需要的(见下图)。

3

我将消息结构拆分成了5部分,对应5个消息组件  MessageView ,每个消息组件都支持业务对其「样式」、「显隐」、「布局」进行配置,从而满足不同场景定制需要。

MessageView作为基础消息组件,提供了一些标准能力,例如是否响应菜单动作 canPerformMenuAction 、视图重用回调时机 prepareForReuse 、尺寸策略等。

open class MessageView: MessageAbstractView {

  public var canPerformMenuAction = false

    open func refresh(with message: Message) {}

    open func prepareForReuse() {}

    open class func createSizeStrategy(message: Message, fittingSize: CGSize) -> MessageLayoutSizeStrategy? {

    // ...

    }

}

5.2 尺寸策略

消息组件尺寸作为消息流布局上不可或缺的要素,方案提供了多种尺寸计算策略 MessageLayoutSizeStrategy 。

具体是:

  • 1)自动布局计算策略:业务方对消息组件使用 AutoLayout 布局时使用,内部会依据约束自动计算好组件尺寸;
  • 2)SizeThatFit 策略:依据组件 SizeThatFit 方法返回的尺寸进行布局;
  • 3)自定义策略:提供自定义尺寸计算方式。

public protocol MessageLayoutSizeStrategy {

    func caclulateSize(_ sizeViewType: MessageView.Type,

                       message: Message,

                       fittingSize: CGSize) -> CGSize

}

 

public struct MessageAutoLayoutSizeStrategy: MessageLayoutSizeStrategy {

    public func caclulateSize(_ sizeViewType: MessageView.Type,

                              message: Message,

                              fittingSize: CGSize) -> CGSize {

    // ...省略其他代码

        return sizeView.systemLayoutSizeFitting(UIView.layoutFittingCompressedSize)

    }

 

}

 

public struct MessageSizeThatFitsStrategy: MessageLayoutSizeStrategy {

    public func caclulateSize(_ sizeViewType: MessageView.Type,

                              message: Message,

                              fittingSize: CGSize) -> CGSize  {

        // ...省略其他代码

        return sizeView.sizeThatFits(fittingSize)

    }

}

5.3 布局快照

我们还针对消息组件维度支持了布局快照。通常当一个消息组件尺寸固定,在交互过程中尺寸不会发生的情况下,打开布局快照,以减少布局计算消耗。同时也提供了快照清除的能力。

我们对多个消息流在快速滚动过程中的CPU峰值做了统计,在使用自动布局尺寸策略的情况下,开启布局快照,峰值降低了10%~20%。

4

5.4 交互事件

另外在手势交互上,对外暴露了各个消息组件的一系列交互事件。常见的场景例如单击浏览消息内容,长按展示消息菜单等。

方案内部提供了基于系统样式的长按菜单,并提供上层菜单配置能力,同时也可以基于暴露的长按手势事件来自定义菜单。

5.5 消息流

一个会话对应一个流,方案也提供了消息流在会话维度上的一些标准化配置。例如消息分页数量、是否自动拉取历史消息、是否开启增量刷新,以及在时间展示上的样式配置等。

此外为了减少列表重绘,消息流也支持增量刷新。通常情况下业务层不需要主动刷新列表,只需对消息数据进行增删改操作,内部会触发对数据源的「diff-update」计算,从而驱动列表的增量更新。

5

6、聊天消息交互层

6.1 概述

对于业务方而言,在消息交互上通常关心这么几点:

  • 1)提供了哪些标准化的交互能力;
  • 2)如何拓展自定义的交互实现;
  • 3)如何对交互流程进行干预。

结合团队现状,我们在方案内部内置了基于某信的IM交互能力,同时定义了相关交互接口,供业务方按需注入实现。

在实际业务中,一个APP内可能存在多个IM场景,因此交互能力支持按会话维度进行注入,各个会话之间的交互是相互隔离的。

6.2 消息源

不同的IM场景,消息数据来源可能存在差异。例如我们私聊、群聊的数据源来自云信数据同步服务,聊天室数据需要通过云信提供的历史消息接口拉取,另外也存在诸如通过业务服务端接口来拉取消息数据的场景。

因此方案上设置了数据源接口 SessionMessageProvider ,提供不同场景消息源的定制能力。

public protocol SessionMessageProvider {

    func messages(in session: Session,

                  anchorMessage: Message?,

                  limit: Int,

                  completion: @escaping ([Message]) -> Void)

}

方案设置了一个负责管理消息数据源的 DataManager 实例, 其依赖 SessionMessageProvider 提供的数据源。同时内置了基于云信的数据源获取实现,能够根据当前会话类型,获取私聊、群聊、聊天室的数据源。

如果当前场景是通过HTTP拉取消息的,则需要业务上层手动注入一个从接口获取数据源的 SessionMessageProvider 实例。

6

6.3 交互源

方案提供了IM标准交互能力,例如消息收发、消息撤回、保存等,以统一各业务交互姿势。

具体的交互源除了要考虑目前包含的云信及业务服务端,也要适应其他交互源,因此将交互实现部分也抽象出了接口 MessageServiceInterface 。业务根据当前实际场景,注入具体的交互实现即可。

下面列出了一些交互申明:

public protocol MessageServiceInterface {

    func send(message: Message, in session: Session, completion: @escaping MessageServiceInterfaceCompletion)

    func resend(message: Message, completion: @escaping MessageServiceInterfaceCompletion)

    func forward(message: Message, to session: Session, completion: @escaping MessageServiceInterfaceCompletion)

    func revoke(message: Message, completion: @escaping MessageServiceInterfaceCompletion)

    func save(message: Message, in session: Session, completion: @escaping MessageServiceInterfaceCompletion)

    func delete(message: Message, completion: @escaping MessageServiceInterfaceCompletion)

}

同样,我们也内置了一些通用交互方案,例如支持云信提供的私聊群聊交互能力,以及由中台提供的通用聊天室服务交互能力,以支持相关场景下快速接入。

7

6.4 交互钩子

在实际IM业务开发过程中,往往需要对交互流程做一些干预,或是在交互过程中做一些定制化的动作。因此方案也提供了一些交互钩子,支持「交互前置校验」、「交互前准备」。

以消息发送流程为例,提供了「发送前校验」、「发送准备」两个消息发送过程的回调钩子:

public protocol MessageServicePrechecker {

   // 消息发送前置校验 

    func shouldSend(message: Message, in session: Session) -> Bool

 

    // ...省略其他代码

}

 

public protocol MessageServicePreparation {

    /// 准备发送准备

    func prepareSend(message: Message, in session: Session, callback: @escaping MessageServicePreparationCallback)

 

    // ...省略其他代码

}

整体的发送流程如图所示:

8

前置校验阶段,用来作消息发送前的校验工作,根据实际状态决定消息是否可以发送。发送准备阶段,则可以在消息投递前做最后的准备工作,例如海外业务可以在这里处理消息资源附件上传Amazon,或是在此处对消息塞入一些客户端信息、反作弊Token等,支持异步操作。

7、业务接入能力

业务只需要在上层提供针对消息以及会话两个维度的配置,就能基于内置的交互能力,构建出一套基础的IM消息流能力。

在具体的消息样式呈现上,则通常需要业务层维护一组关于「消息类型-消息组件类型-消息结构」的映射关系。

具体关联如下:

9

在交互能力上,提供了IM场景的标准能力,业务可以按需使用。

另外,实际IM场景可能需要一些更为丰富的定制能力,则可以依据方案提供的消息数据源接口、消息交互接口来对具体交互实现进行定制。同时也可以使用相关的交互钩子对交互过程进行干预,以适应自己的业务。

8、本文小结

本文对团队IM场景的现状做了简单介绍,撇开具体实现细节,就如何搭建一套能够适应多业务需要的通用IM消息流交互层方案,提供了一些思考和实践经验。

从结果来看,该方案稳定支撑了团队多个IM场景,抹除各场景实现差异,有效降低了维护成本和新业务接入成本。

9、参考资料

[1] 零基础IM开发入门(一):什么是IM聊天系统?

[2] 一套海量在线用户的移动端IM架构设计实践分享(含详细图文)

[3] 一套原创分布式即时通讯(IM)系统理论架构方案

[4] 从游击队到正规军(二):马蜂窝旅游网的IM客户端架构演进和实践总结

[5] 社交软件红包技术解密(十):手Q客户端针对2020年春节红包的技术实践

[6] 微信团队分享:来看看微信十年前的IM消息收发架构,你做到了吗

[7] 携程技术分享:亿级流量的办公IM及开放平台技术实践

[8] 百度公共IM系统的Andriod端IM SDK组件架构设计与技术实现

[9] 转转平台IM系统架构设计与实践(一):整体架构设计

[10] 一年撸完百万行代码,企业微信的全新鸿蒙NEXT客户端架构演进之路

[11] 转转客服IM聊天系统背后的技术挑战和实践分享

[12] B站IM消息系统的新架构升级实践

[13] 企业微信针对百万级组织架构的客户端性能优化实践

[14] 企业微信的IM架构设计揭秘:消息模型、万人群、已读回执、消息撤回等

[15] 从客户端的角度来谈谈移动端IM的消息可靠性和送达机制

[16] 现代移动端网络短连接的优化手段总结:请求速度、弱网适应、安全保障

[17] IM消息ID技术专题(一):微信的海量IM聊天消息序列号生成实践(算法原理篇)

[18] IM开发干货分享:有赞移动端IM的组件化SDK架构设计实践

[19] 阿里技术分享:闲鱼IM基于Flutter的移动端跨端改造实践

[20] IM开发干货分享:万字长文,详解IM“消息“列表卡顿优化实践

[21] IM开发干货分享:IM客户端不同版本兼容运行的技术思路和实践总结

[22] 百度统一socket长连接组件从0到1的技术实践

[23] 淘宝移动端统一网络库的架构演进和弱网优化技术实践

[24] 抖音技术分享:飞鸽IM桌面端基于Rust语言进行重构的技术选型和实践总结

[25] 大型IM工程重构实践:企业微信Android端的重构之路

即时通讯技术学习:

- 移动端IM开发入门文章:《新手入门一篇就够:从零开发移动端IM

- 开源IM框架源码:https://github.com/JackJiang2011/MobileIMSDK备用地址点此

本文同步发布于:http://www.52im.net/thread-4905-1-1.html

posted @ 2026-04-20 18:43 Jack Jiang 阅读(36) | 评论 (0)编辑 收藏

Jack Jiang的 Mail: jb2011@163.com, 联系QQ: 413980957, 微信: hellojackjiang