信令服务器设计与实现WebRTC 不管信令SDP 和 ICE 候选怎么交换要自己实现。这篇讲信令服务器的作用、设计思路、消息类型、房间管理以及用 Node.js Socket.IO 实现一个最简信令服务器。大家好我是黒漂技术佬。WebRTC 标准只定义了媒体传输层信令部分完全不管——怎么交换 Offer/Answer、怎么交换 ICE 候选全靠自己实现。信令服务器就是干这个的在两端之间转发消息帮它们建立连接。虽然不参与媒体传输但它是整个 WebRTC 系统的指挥中心。这篇讲信令服务器的设计和实现从架构到代码。一、信令服务器是干什么的核心作用在 WebRTC 客户端之间转发控制消息帮助它们建立 P2P 连接。具体做什么房间管理创建/加入/离开房间成员管理谁在房间里、在线状态消息转发Offer、Answer、ICE 候选在用户之间转发会话控制开始通话、结束通话、拒绝接听为什么需要两个浏览器之间不知道对方在哪没法直接联系。需要一个中间人帮它们交换联系方式SDP 和 ICE 候选。连接建立之后媒体数据就直接 P2P 传了不再经过信令服务器。二、信令的消息类型1. 房间相关// 加入房间{type:join,roomId:123,userId:userA,name:张三}// 离开房间{type:leave,roomId:123,userId:userA}// 房间成员列表服务器下发{type:room-members,members:[...]}2. 媒体协商SDP// 发起呼叫Offer{type:offer,from:userA,to:userB,sdp:...}// 应答Answer{type:answer,from:userB,to:userA,sdp:...}3. ICE 候选// 转发 ICE 候选{type:ice-candidate,from:userA,to:userB,candidate:{...}}4. 会话控制// 呼叫{type:call,from:userA,to:userB}// 接听{type:accept,from:userB,to:userA}// 拒绝{type:reject,from:userB,to:userA}// 挂断{type:hangup,from:userA,to:userB}5. 状态通知// 用户加入{type:user-joined,user:{...}}// 用户离开{type:user-left,userId:xxx}// 静音/开关摄像头状态{type:mute-audio,userId:xxx,muted:true}三、技术选型通信方式方案优点缺点WebSocket双向实时标准要自己处理重连等Socket.IO封装好自动重连房间支持多一层依赖SSE HTTP POST简单双向麻烦长轮询兼容好效率低推荐 Socket.IO开发快自带房间、重连、心跳适合快速开发。生产环境也可以用原生 WebSocket更轻量。后端语言Node.js开发快和前端 JS 统一Socket.IO 生态好Go / Java高并发场景性能更好小项目 Node.js 足够大项目考虑 Go。四、最简实现Node.js Socket.IO服务端代码constexpressrequire(express);consthttprequire(http);const{Server}require(socket.io);constappexpress();constserverhttp.createServer(app);constionewServer(server,{cors:{origin:*}// 开发用生产要配具体域名});// 房间管理roomId - SetsocketIdconstroomsnewMap();io.on(connection,(socket){console.log(用户连接:,socket.id);// 加入房间socket.on(join,({roomId,userId,name}){socket.join(roomId);socket.data{userId,name,roomId};if(!rooms.has(roomId)){rooms.set(roomId,newMap());}rooms.get(roomId).set(userId,{id:socket.id,name});// 通知房间里其他人socket.to(roomId).emit(user-joined,{userId,name});// 返回房间成员constmembersArray.from(rooms.get(roomId).values());socket.emit(room-members,members);console.log(${name}加入房间${roomId});});// 转发 Offersocket.on(offer,(data){socket.to(data.to).emit(offer,{from:socket.data.userId,sdp:data.sdp});});// 转发 Answersocket.on(answer,(data){socket.to(data.to).emit(answer,{from:socket.data.userId,sdp:data.sdp});});// 转发 ICE 候选socket.on(ice-candidate,(data){socket.to(data.to).emit(ice-candidate,{from:socket.data.userId,candidate:data.candidate});});// 挂断socket.on(hangup,(data){socket.to(data.to).emit(hangup,{from:socket.data.userId});});// 断开连接socket.on(disconnect,(){const{userId,name,roomId}socket.data;if(roomIdrooms.has(roomId)){rooms.get(roomId).delete(userId);socket.to(roomId).emit(user-left,{userId});// 房间空了就删掉if(rooms.get(roomId).size0){rooms.delete(roomId);}}console.log(${name}断开连接);});});server.listen(3000,(){console.log(信令服务器运行在端口 3000);});前端代码constsocketio(http://localhost:3000);// 加入房间socket.emit(join,{roomId:test-room,userId:userA,name:用户A});// 有人加入socket.on(user-joined,(user){console.log(有人加入:,user.name);});// 收到 Offersocket.on(offer,async(data){awaitpc.setRemoteDescription(newRTCSessionDescription({type:offer,sdp:data.sdp}));// 创建 Answer...});// 收到 Answersocket.on(answer,async(data){awaitpc.setRemoteDescription(newRTCSessionDescription({type:answer,sdp:data.sdp}));});// 收到 ICE 候选socket.on(ice-candidate,async(data){awaitpc.addIceCandidate(newRTCIceCandidate(data.candidate));});// 发送 OfferfunctionsendOffer(targetId,sdp){socket.emit(offer,{to:targetId,sdp});}// 发送 ICE 候选functionsendIceCandidate(targetId,candidate){socket.emit(ice-candidate,{to:targetId,candidate});}五、信令服务器设计要点1. 房间模型一个房间多个用户一对一房间 2 人多人会议房间 N 人用房间做消息隔离不同房间互不干扰2. 用户标识每个用户有唯一 userId业务 IDsocket.id 是连接 ID重连会变不能当业务 ID 用维护 userId ↔ socketId 的映射3. 断线重连Socket.IO 自动重连重连后要重新加入房间、恢复状态或者用 session 机制重连后恢复会话4. 心跳与超时定期发心跳包检测死连接长时间没心跳就踢下线5. 消息转发安全校验发送者身份不能伪造 from只能转发给同一个房间的用户不能跨房间发消息6. 水平扩展用户多了一台服务器扛不住用 Redis AdapterSocket.IO 支持多台服务器之间通过 Redis Pub/Sub 同步消息前端连任意一台都能收到消息六、进阶功能1. 呼叫流程不是进房间就自动通话要有呼叫/接听的流程A → 呼叫 → B B → 接听 → 开始建连 B → 拒绝 → 结束2. 状态同步谁静音了、谁关摄像头了谁在说话语音活动检测网络状态好坏3. 房间属性房间密码最大人数房间类型一对一/多人4. 录制、转码等业务逻辑和媒体服务SFU/MCU配合。七、性能与扩展性单机能扛多少Node.js Socket.IO纯转发信令不处理媒体单机几千到上万连接没问题。信令消息量不大主要是连接数。水平扩展Socket.IO Redis Adapterconst{createAdapter}require(socket.io/redis-adapter);const{createClient}require(redis);constpubClientcreateClient({host:localhost,port:6379});constsubClientpubClient.duplicate();io.adapter(createAdapter(pubClient,subClient));多台服务器共享房间状态消息跨服务器转发。生产环境注意CORS配置正确的跨域HTTPS/WSS生产环境必须加密鉴权连接时校验 token不能随便连限流防止消息轰炸监控连接数、消息量、错误率八、常见坑坑 1用 socket.id 当用户 ID重连后 socket.id 会变用户就丢了。一定要用业务 userIdsocket.id 只是连接 ID。坑 2房间状态不同步多实例部署没配 adapterA 服务器上的用户收不到 B 服务器上的消息。坑 3没做鉴权谁都能连进来随便发消息有安全隐患。生产环境一定要加 token 校验。坑 4消息转发不校验A 可以给任意 B 发消息甚至跨房间。要校验目标用户是不是在同一个房间。坑 5断线后状态不清理用户断网了房间里还显示在线。要用心跳超时检测。坑 6信令顺序乱了网络延迟导致 ICE 候选比 Offer 先到addIceCandidate 会失败。处理的时候要注意等 setRemoteDescription 之后再加候选。九、信令服务器 vs 媒体服务器别搞混了信令服务器媒体服务器SFU/MCU作用转发控制消息转发/混流媒体数据流量很小都是文字消息很大所有音视频都过性能要求低单机扛很多高带宽和CPU消耗大必须有吗必须有一对一不需要多人才需要一对一通话只需要信令服务器媒体 P2P 直连。多人通话才需要 SFU/MCU 媒体服务器。十、本篇小结信令服务器WebRTC 的中间人转发 SDP 和 ICE 候选帮两端建立连接核心消息房间管理、Offer/Answer、ICE 候选、会话控制技术选型Socket.IO 开发快原生 WebSocket 更轻量Node.js 上手快设计要点房间模型、用户标识、断线重连、安全校验、水平扩展最简实现几十行 Node.js Socket.IO 就能跑起来生产环境注意鉴权、限流、HTTPS、监控、多实例扩展信令服务器 ≠ 媒体服务器一对一 P2P 不需要媒体服务器下一篇讲多人会议架构Mesh / SFU / MCU 三种方案对比多人视频通话怎么搞。我是黒漂技术佬。
信令服务器设计与实现
信令服务器设计与实现WebRTC 不管信令SDP 和 ICE 候选怎么交换要自己实现。这篇讲信令服务器的作用、设计思路、消息类型、房间管理以及用 Node.js Socket.IO 实现一个最简信令服务器。大家好我是黒漂技术佬。WebRTC 标准只定义了媒体传输层信令部分完全不管——怎么交换 Offer/Answer、怎么交换 ICE 候选全靠自己实现。信令服务器就是干这个的在两端之间转发消息帮它们建立连接。虽然不参与媒体传输但它是整个 WebRTC 系统的指挥中心。这篇讲信令服务器的设计和实现从架构到代码。一、信令服务器是干什么的核心作用在 WebRTC 客户端之间转发控制消息帮助它们建立 P2P 连接。具体做什么房间管理创建/加入/离开房间成员管理谁在房间里、在线状态消息转发Offer、Answer、ICE 候选在用户之间转发会话控制开始通话、结束通话、拒绝接听为什么需要两个浏览器之间不知道对方在哪没法直接联系。需要一个中间人帮它们交换联系方式SDP 和 ICE 候选。连接建立之后媒体数据就直接 P2P 传了不再经过信令服务器。二、信令的消息类型1. 房间相关// 加入房间{type:join,roomId:123,userId:userA,name:张三}// 离开房间{type:leave,roomId:123,userId:userA}// 房间成员列表服务器下发{type:room-members,members:[...]}2. 媒体协商SDP// 发起呼叫Offer{type:offer,from:userA,to:userB,sdp:...}// 应答Answer{type:answer,from:userB,to:userA,sdp:...}3. ICE 候选// 转发 ICE 候选{type:ice-candidate,from:userA,to:userB,candidate:{...}}4. 会话控制// 呼叫{type:call,from:userA,to:userB}// 接听{type:accept,from:userB,to:userA}// 拒绝{type:reject,from:userB,to:userA}// 挂断{type:hangup,from:userA,to:userB}5. 状态通知// 用户加入{type:user-joined,user:{...}}// 用户离开{type:user-left,userId:xxx}// 静音/开关摄像头状态{type:mute-audio,userId:xxx,muted:true}三、技术选型通信方式方案优点缺点WebSocket双向实时标准要自己处理重连等Socket.IO封装好自动重连房间支持多一层依赖SSE HTTP POST简单双向麻烦长轮询兼容好效率低推荐 Socket.IO开发快自带房间、重连、心跳适合快速开发。生产环境也可以用原生 WebSocket更轻量。后端语言Node.js开发快和前端 JS 统一Socket.IO 生态好Go / Java高并发场景性能更好小项目 Node.js 足够大项目考虑 Go。四、最简实现Node.js Socket.IO服务端代码constexpressrequire(express);consthttprequire(http);const{Server}require(socket.io);constappexpress();constserverhttp.createServer(app);constionewServer(server,{cors:{origin:*}// 开发用生产要配具体域名});// 房间管理roomId - SetsocketIdconstroomsnewMap();io.on(connection,(socket){console.log(用户连接:,socket.id);// 加入房间socket.on(join,({roomId,userId,name}){socket.join(roomId);socket.data{userId,name,roomId};if(!rooms.has(roomId)){rooms.set(roomId,newMap());}rooms.get(roomId).set(userId,{id:socket.id,name});// 通知房间里其他人socket.to(roomId).emit(user-joined,{userId,name});// 返回房间成员constmembersArray.from(rooms.get(roomId).values());socket.emit(room-members,members);console.log(${name}加入房间${roomId});});// 转发 Offersocket.on(offer,(data){socket.to(data.to).emit(offer,{from:socket.data.userId,sdp:data.sdp});});// 转发 Answersocket.on(answer,(data){socket.to(data.to).emit(answer,{from:socket.data.userId,sdp:data.sdp});});// 转发 ICE 候选socket.on(ice-candidate,(data){socket.to(data.to).emit(ice-candidate,{from:socket.data.userId,candidate:data.candidate});});// 挂断socket.on(hangup,(data){socket.to(data.to).emit(hangup,{from:socket.data.userId});});// 断开连接socket.on(disconnect,(){const{userId,name,roomId}socket.data;if(roomIdrooms.has(roomId)){rooms.get(roomId).delete(userId);socket.to(roomId).emit(user-left,{userId});// 房间空了就删掉if(rooms.get(roomId).size0){rooms.delete(roomId);}}console.log(${name}断开连接);});});server.listen(3000,(){console.log(信令服务器运行在端口 3000);});前端代码constsocketio(http://localhost:3000);// 加入房间socket.emit(join,{roomId:test-room,userId:userA,name:用户A});// 有人加入socket.on(user-joined,(user){console.log(有人加入:,user.name);});// 收到 Offersocket.on(offer,async(data){awaitpc.setRemoteDescription(newRTCSessionDescription({type:offer,sdp:data.sdp}));// 创建 Answer...});// 收到 Answersocket.on(answer,async(data){awaitpc.setRemoteDescription(newRTCSessionDescription({type:answer,sdp:data.sdp}));});// 收到 ICE 候选socket.on(ice-candidate,async(data){awaitpc.addIceCandidate(newRTCIceCandidate(data.candidate));});// 发送 OfferfunctionsendOffer(targetId,sdp){socket.emit(offer,{to:targetId,sdp});}// 发送 ICE 候选functionsendIceCandidate(targetId,candidate){socket.emit(ice-candidate,{to:targetId,candidate});}五、信令服务器设计要点1. 房间模型一个房间多个用户一对一房间 2 人多人会议房间 N 人用房间做消息隔离不同房间互不干扰2. 用户标识每个用户有唯一 userId业务 IDsocket.id 是连接 ID重连会变不能当业务 ID 用维护 userId ↔ socketId 的映射3. 断线重连Socket.IO 自动重连重连后要重新加入房间、恢复状态或者用 session 机制重连后恢复会话4. 心跳与超时定期发心跳包检测死连接长时间没心跳就踢下线5. 消息转发安全校验发送者身份不能伪造 from只能转发给同一个房间的用户不能跨房间发消息6. 水平扩展用户多了一台服务器扛不住用 Redis AdapterSocket.IO 支持多台服务器之间通过 Redis Pub/Sub 同步消息前端连任意一台都能收到消息六、进阶功能1. 呼叫流程不是进房间就自动通话要有呼叫/接听的流程A → 呼叫 → B B → 接听 → 开始建连 B → 拒绝 → 结束2. 状态同步谁静音了、谁关摄像头了谁在说话语音活动检测网络状态好坏3. 房间属性房间密码最大人数房间类型一对一/多人4. 录制、转码等业务逻辑和媒体服务SFU/MCU配合。七、性能与扩展性单机能扛多少Node.js Socket.IO纯转发信令不处理媒体单机几千到上万连接没问题。信令消息量不大主要是连接数。水平扩展Socket.IO Redis Adapterconst{createAdapter}require(socket.io/redis-adapter);const{createClient}require(redis);constpubClientcreateClient({host:localhost,port:6379});constsubClientpubClient.duplicate();io.adapter(createAdapter(pubClient,subClient));多台服务器共享房间状态消息跨服务器转发。生产环境注意CORS配置正确的跨域HTTPS/WSS生产环境必须加密鉴权连接时校验 token不能随便连限流防止消息轰炸监控连接数、消息量、错误率八、常见坑坑 1用 socket.id 当用户 ID重连后 socket.id 会变用户就丢了。一定要用业务 userIdsocket.id 只是连接 ID。坑 2房间状态不同步多实例部署没配 adapterA 服务器上的用户收不到 B 服务器上的消息。坑 3没做鉴权谁都能连进来随便发消息有安全隐患。生产环境一定要加 token 校验。坑 4消息转发不校验A 可以给任意 B 发消息甚至跨房间。要校验目标用户是不是在同一个房间。坑 5断线后状态不清理用户断网了房间里还显示在线。要用心跳超时检测。坑 6信令顺序乱了网络延迟导致 ICE 候选比 Offer 先到addIceCandidate 会失败。处理的时候要注意等 setRemoteDescription 之后再加候选。九、信令服务器 vs 媒体服务器别搞混了信令服务器媒体服务器SFU/MCU作用转发控制消息转发/混流媒体数据流量很小都是文字消息很大所有音视频都过性能要求低单机扛很多高带宽和CPU消耗大必须有吗必须有一对一不需要多人才需要一对一通话只需要信令服务器媒体 P2P 直连。多人通话才需要 SFU/MCU 媒体服务器。十、本篇小结信令服务器WebRTC 的中间人转发 SDP 和 ICE 候选帮两端建立连接核心消息房间管理、Offer/Answer、ICE 候选、会话控制技术选型Socket.IO 开发快原生 WebSocket 更轻量Node.js 上手快设计要点房间模型、用户标识、断线重连、安全校验、水平扩展最简实现几十行 Node.js Socket.IO 就能跑起来生产环境注意鉴权、限流、HTTPS、监控、多实例扩展信令服务器 ≠ 媒体服务器一对一 P2P 不需要媒体服务器下一篇讲多人会议架构Mesh / SFU / MCU 三种方案对比多人视频通话怎么搞。我是黒漂技术佬。
