如何检测与Peer的连接存活状态？BusinessNetworkConnection技术问询

嘿，这个问题我之前在项目里也遇到过——确实，BusinessNetworkConnection本身没提供现成的连接丢失事件，每次操作前调用ping()确实有点啰嗦。给你几个更优雅的解决思路：

1. 定时自动Ping + 状态缓存 #

这是兼容性最好的方案，不用依赖底层实现细节：

• 启动一个定时任务（比如每30秒），自动调用BusinessNetworkConnection.ping()，同时维护一个全局连接状态变量（比如isConnected）。
• 所有业务操作前直接读取这个缓存的状态，不用每次都调用ping()。一旦检测到连接断开，还能触发自定义回调（比如通知用户、自动尝试重连）。

示例代码（JavaScript环境）：

let isConnected = true;
const pingInterval = setInterval(async () => {
  try {
    await businessNetworkConnection.ping();
    isConnected = true;
  } catch (err) {
    isConnected = false;
    // 触发自定义的连接丢失事件，比如通知前端
    emit('connectionLost', err);
    // 可选：自动尝试重连逻辑
    await attemptReconnect();
  }
}, 30000); // 30秒执行一次

// 业务操作前直接检查缓存状态
async function executeBusinessLogic() {
  if (!isConnected) {
    throw new Error('连接已断开，请检查网络后重试');
  }
  // 执行你的业务操作，比如查询资产、提交交易
  const assetRegistry = await businessNetworkConnection.getAssetRegistry('org.example.Asset');
  return await assetRegistry.getAll();
}

2. 监听底层WebSocket的状态变化 #

如果需要实时感知连接断开（不用等ping的间隔），可以直接监听BusinessNetworkConnection底层的WebSocket连接事件：

• BusinessNetworkConnection底层依赖fabric-sdk，而fabric-sdk和Peer的通信大多基于WebSocket。你可以获取到底层的WebSocket实例，然后监听它的close、error事件。

示例代码（注意：不同fabric-network版本的底层结构可能略有差异，需要根据你的版本调整）：

// 获取第一个Peer实例（如果有多个Peer，可以遍历处理）
const peer = businessNetworkConnection._network._channel._client._peerPool.getPeers()[0];
const wsConnection = peer._endpoint._ws; // 拿到底层WebSocket连接

// 监听连接关闭事件
wsConnection.on('close', (code, reason) => {
  isConnected = false;
  console.log(`Peer连接已关闭：${code} - ${reason}`);
  emit('connectionLost', { code, reason });
});

// 监听连接错误事件
wsConnection.on('error', (err) => {
  isConnected = false;
  console.error('Peer连接出错：', err);
  emit('connectionLost', err);
});

⚠️ 注意：这种方法依赖SDK的底层实现，版本更新后可能需要调整代码，但胜在实时性强。

3. 封装业务操作的通用函数 #

把所有需要和Peer交互的操作都封装到一个通用函数里，统一处理连接检查和异常捕获，业务代码不用关心连接细节：

• 这个函数内部会先检查缓存的连接状态，如果状态异常，会先执行一次ping()确认，然后再执行业务逻辑；如果遇到连接相关的错误，自动更新状态并抛出友好提示。

示例代码：

async function withConnectionGuard(fn) {
  try {
    // 先检查缓存状态，异常时主动ping确认
    if (!isConnected) {
      await businessNetworkConnection.ping();
      isConnected = true;
    }
    // 执行传入的业务逻辑
    return await fn();
  } catch (err) {
    // 判断是否为连接相关错误
    if (err.message.includes('disconnected') || err.message.includes('connection failed')) {
      isConnected = false;
      throw new Error('连接已丢失，请稍后重试');
    }
    // 其他错误直接抛出
    throw err;
  }
}

// 业务代码使用示例
async function queryAllAssets() {
  return await withConnectionGuard(async () => {
    const registry = await businessNetworkConnection.getAssetRegistry('org.example.Asset');
    return await registry.getAll();
  });
}

总结 #

• 如果追求稳定性和兼容性，优先选「定时Ping+状态缓存」方案；
• 如果需要实时感知连接变化，可以尝试「监听底层WebSocket」方案；
• 如果想让业务代码更简洁，「封装通用函数」能帮你把连接逻辑统一管理。

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