如何判断PeerJS中peer.connect()是否成功建立连接？

核心事件机制梳理 #

首先明确PeerJS的事件边界：

• DataConnection的open事件是连接成功建立的官方标志，触发时双方已完成握手，连接处于可用状态。
• 连接建立阶段的错误（如目标Peer不存在、网络连通失败）不会触发DataConnection的error事件，这类错误会统一触发Peer实例的全局error事件——这正是你遇到的核心痛点。

优化后的异步连接实现 #

我们可以通过全局错误与目标PeerID关联+超时控制解决问题，无需低效轮询：

// 存储待处理连接的Promise拒绝回调，key为目标peerid
const pendingConnections = new Map();

// 给Peer实例绑定全局错误处理器
peer.on('error', (err) => {
  // 匹配PeerJS标准的连接失败错误格式
  const match = err.message.match(/cannot connect to peer (\w+)/);
  if (match) {
    const targetPeerId = match[1];
    const rejectCallback = pendingConnections.get(targetPeerId);
    if (rejectCallback) {
      rejectCallback(new Error(`连接${targetPeerId}失败：${err.message}`));
      pendingConnections.delete(targetPeerId);
    }
  }
});

async function connect(to, timeout = 10000) {
  return new Promise((resolve, reject) => {
    // 超时兜底：避免Promise无限pending
    const timeoutTimer = setTimeout(() => {
      reject(new Error(`连接${to}超时`));
      pendingConnections.delete(to);
    }, timeout);

    const conn = peer.connect(to);

    // 连接成功触发：监听open事件
    conn.on('open', () => {
      clearTimeout(timeoutTimer);
      connections.set(to, conn);
      pendingConnections.delete(to);
      resolve(conn);
    });

    // 处理连接建立后的运行时错误（如中途断开、发送失败）
    conn.on('error', (err) => {
      clearTimeout(timeoutTimer);
      reject(err);
      pendingConnections.delete(to);
    });

    // 保存当前连接的拒绝回调，用于全局错误匹配
    pendingConnections.set(to, reject);
  });
}

关键细节说明 #

1. 替代假设的success事件：用官方定义的open事件作为连接成功的判断依据，这是最可靠的信号。
2. 精准错误关联：通过正则匹配全局错误消息中的PeerID，将错误精准映射到对应的连接请求，避免无差别错误处理。
3. 超时机制：防止因网络波动等问题导致连接请求无限等待，提升代码健壮性。
4. 事件职责划分：DataConnection的error事件仅处理连接建立后的运行时错误，和连接阶段错误明确区分。

发送函数的健壮性优化 #

可以增加连接状态检查，避免在连接未就绪时发送数据：

function send(to, data) {
  const conn = connections.get(to);
  if (!conn) throw new Error('无可用连接');
  if (conn.open !== true) throw new Error('连接未就绪');
  
  conn.send(data);
}

这种方案完全基于事件驱动，无需额外调用Peer服务器接口，效率和可靠性远高于轮询或试探性发消息的方案。

内容的提问来源于stack exchange，提问作者user3331344