Chatto Realtime实时协议v4详解WebSocketProtobuf的快照、事件与断线恢复【免费下载链接】chattoA fully-featured team and group chat application that you can easily selfhost.项目地址: https://gitcode.com/gh_mirrors/chatt/chattoChatto 是一个可自托管的全功能团队与群组聊天应用其 Realtime 实时协议 v4 使用 WebSocket 传输 Protobuf 二进制帧通过精确快照 语义事件 15分钟断线恢复游标三件套让消息、反应、房间变更等在毫秒级送达所有在线客户端。本文将从零讲透这套实时协议的工作机制。Chatto 是什么一个单二进制自托管聊天服务器Chatto 用单个 Go 二进制嵌入 NATS JetStream 作为数据底座前端是 SvelteKit SPA开箱即用地提供频道、私信、线程、语音通话、文件附件与机器人生态。实时能力是聊天应用的灵魂别人发的消息立刻出现、在线状态即时点亮背后正是 realtime.proto 定义的实时协议在支撑。为什么实时层选择二进制 WebSocket Protobuf很多聊天产品用 JSON 文本帧而 Chatto 的实时端点GET /api/realtime走的是纯二进制 Protobuf 帧带来三个好处体积小紧凑的 varint 编码比 JSON 文本节省大量带宽对高频事件流尤其明显可演进Protobuf 字段号天然支持增量添加新字段客户端遇到不认识的新事件可以安全跳过不泄露内部结构公开事件使用独立的事件目录内部存储字段永远不会出现在公开帧中。一个容易混淆的细节protobuf 包名是chatto.realtime.v1这里的 v1 只是 schema 命名空间行为协议版本是 4且 v4 是服务器唯一接受的手shake版本。协议 v4 的 5 种帧一条连接完整生命周期整个协议异常简洁客户端只发一条消息之后永远只接收。帧类型方向作用RealtimeSubscribe客户端 → 服务器首帧声明协议版本 4、凭据、断线恢复游标、回退策略snapshot服务器 → 客户端当前时刻的精确授权内容快照至多一次event服务器 → 客户端授权后的语义事件消息、反应、房间变更……caught_up服务器 → 客户端标记追赶完成附交接游标此后进入纯直播heartbeat/close服务器 → 客户端存活探测 / 带重连指引的关闭指令完整定义见 RealtimeServerFrame。快照Snapshot一次性拿到当前状态冷启动或断线超过恢复窗口时服务器会先发一个原子快照帧内容都是此刻的权威状态服务器公开资料、你可见的全部房间目录与分组布局正在进行的语音通话快照资源引用到的用户资料⚠️ 快照有意保持有界消息历史、搜索结果、文件列表等大数据集不在其中客户端按需通过 ConnectRPC 拉取。且规则很严格——如果在caught_up到达前连接断了快照必须整体丢弃避免半个快照污染本地状态。语义事件Events所有客户端共享的公开事件目录RealtimeEvent的 oneof 联合就是公开事件目录涵盖message_posted、reaction_added、room_created、voice_call_started、user_typing等几十个变体定义在 events.proto 中。例如上图中用户发送照片后服务器完成图片处理时会向房间内每个客户端推送asset_processing_succeeded事件消息行里的图片随之立即可见——无需轮询。几个对新手很关键的设计事件携带游标的属于持久事件消息、反应、成员变更可重放恢复不带游标的正在输入、在线状态只是直播信号错过就错过⚡message_posted事件直接携带明文正文body_plaintext客户端可先显示临时消息行再异步补全附件、反应等详情️新增事件变体可安全忽略事件游标放在 oneof 之外老客户端遇到不认识的新事件照常推进游标无需升级。断线恢复15 分钟游标 三条安全回退路径这是 v4 最精巧的部分。每个事件和心跳都携带一个不透明恢复游标opaque resume cursor它是一个经认证加密的短令牌15 分钟过期绑定到具体用户与订阅范围短暂掉线重连时客户端把最后安全保存的游标放进RealtimeSubscribe.resume_cursor服务器重放游标之后的授权事件随后发caught_up告诉你实际走了哪条路径recovery结果含义RESUMED✅ 游标有效已补齐间隙事件哪怕零条也算SNAPSHOT 游标失效已下发全新精确快照LIVE_ONLY 直接从当前边界开始不发任何历史为防止重放拖垮服务器追赶过程有严格上限最多扫描 10,000 条事件序列、最多下发 2,000 条事件、30 秒总时限超限自动走你声明的回退路径绝不半截重放。当连接必须终止时close帧会给出机器可读的关闭码如SESSION_RENEWAL_REQUIRED需要续期会话、RESYNC_REQUIRED需丢弃游标重新同步以及建议的重试延迟客户端据此自动重连。设计哲学快照是现在是什么事件是发生了什么记住这句话就理解了 v4 的骨架快照陈述当前状态事件陈述领域变更二者各司其职、复用同一套公开资源消息。而命令、分页、历史消息等主动读取仍由 ConnectRPC 承担——实时流从不变成无界的资源转储。前端、机器人、第三方客户端如 chatto-client 集成包共享同一套事件词汇这正是 ADR-091 的核心决策。延伸阅读文档与源码路径协议定义realtime.proto帧与握手、events.proto事件目录功能设计FDR-045 实时事件流架构决策ADR-091、ADR-093 公开事件联合、ADR-094架构清单realtime-delivery.md服务端实现realtime.go前端传输层realtimeTransport.svelte.ts小结Chatto Realtime 协议 v4 用一条 WebSocket 连接、五种服务器帧把状态同步 变更推送 断线恢复三件事讲得清清楚楚快照负责冷启动游标负责短间隙恢复caught_up帧明确告知你此刻处于直播边界。无论你是自托管管理员、机器人开发者还是协议研究者这套协议都值得细细品味。【免费下载链接】chattoA fully-featured team and group chat application that you can easily selfhost.项目地址: https://gitcode.com/gh_mirrors/chatt/chatto创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考