PeerJS Server事件处理：connection和disconnect事件的实战应用

PeerJS Server是专为PeerJS客户端设计的连接代理服务器，它通过connection和disconnect事件来管理客户端连接的生命周期。掌握这两个核心事件的使用方法，可以帮助开发者构建更稳定、更智能的WebRTC应用。

🔍 为什么需要连接事件处理？

在实时通信应用中，了解客户端的连接状态至关重要。PeerJS Server通过connection和disconnect事件提供了完整的连接生命周期管理：

• 连接建立时：获取新连接客户端的详细信息
• 连接断开时：及时清理资源并通知相关方
• 状态监控：实时跟踪在线用户数量
• 异常处理：检测和处理网络中断等异常情况

🚀 connection事件：连接建立时的处理

当有新的PeerJS客户端连接到服务器时，会触发connection事件。这个事件接收一个client对象作为参数，包含了连接客户端的完整信息。

基本使用示例

const { PeerServer } = require("peer");

const peerServer = PeerServer({
  port: 9000,
  path: "/myapp"
});

peerServer.on("connection", (client) => {
  console.log(`新客户端连接：${client.getId()}`);
  console.log(`客户端Token：${client.getToken()}`);
});

实战应用场景

1. 用户上线通知 当用户连接成功时，可以记录日志并通知其他相关服务。

2. 初始化消息队列 在src/instance.ts中，connection事件会检查并处理该客户端的待处理消息。

⚡ disconnect事件：连接断开时的处理

disconnect事件在客户端断开连接时触发，无论是主动断开还是网络异常导致的断开。

断开连接的原因

• 用户主动关闭页面
• 网络连接中断
• 客户端心跳超时
• 服务器主动断开

资源清理最佳实践

peerServer.on("disconnect", (client) => {
  const clientId = client.getId();
  console.log(`客户端断开连接：${clientId}`);
  
  // 清理相关资源
  realm.removeClientById(clientId);
  realm.clearMessageQueue(clientId);
});

🎯 高级实战技巧

1. 连接状态监控

结合connection和disconnect事件，可以构建完整的连接状态监控系统：

let connectedClients = 0;

peerServer.on("connection", (client) => {
  connectedClients++;
  console.log(`当前在线客户端：${connectedClients}`);
});

peerServer.on("disconnect", (client) => {
  connectedClients--;
  console.log(`当前在线客户端：${connectedClients}`);

2. 异常连接检测

在src/services/checkBrokenConnections/index.ts中实现了断连检测机制，确保及时清理无效连接。

3. 消息队列管理

当客户端断开后重新连接时，src/models/realm.ts中的消息队列机制可以确保重要消息不会丢失。

📊 性能优化建议

连接超时配置

• alive_timeout：设置连接保持超时时间（默认60000ms）
• expire_timeout：设置消息过期时间（默认5000ms）

并发连接限制

• concurrent_limit：限制最大并发连接数（默认5000）

🔧 集成现有Express应用

如果你已经有一个Express应用，可以轻松集成PeerJS Server：

const express = require("express");
const { ExpressPeerServer } = require("peer");

const app = express();
const server = app.listen(9000);

const peerServer = ExpressPeerServer(server, {
  path: "/myapp"
});

app.use("/peerjs", peerServer);

// 事件处理
peerServer.on("connection", (client) => {
  console.log(`新连接：${client.getId()}`);
});

peerServer.on("disconnect", (client) => {
  console.log(`连接断开：${client.getId()}`);
});

💡 常见问题解决方案

Q: 如何获取所有在线客户端？ A: 使用realm.getClientsIds()方法获取所有连接客户端的ID列表。

Q: 连接断开后如何重新建立？ A: PeerJS客户端会自动尝试重新连接，服务器端无需特殊处理。

Q: 如何自定义客户端ID生成？ A: 在配置中设置generateClientId选项，使用自定义的ID生成函数。

🎉 总结

PeerJS Server的connection和disconnect事件为开发者提供了强大的连接管理能力。通过合理使用这两个事件，你可以：

✅ 实时监控应用连接状态 ✅ 及时清理无效连接资源
✅ 构建更稳定的实时通信应用 ✅ 提供更好的用户体验

通过本文的实战指南，相信你已经掌握了PeerJS Server事件处理的核心技巧。现在就开始在你的项目中实践这些方法，构建更出色的WebRTC应用吧！ 🚀