我的OPCUAClient为何陷入‘panic’状态无法恢复？

问题背景 #

使用node-opcua搭建OPCUA客户端连接多个第三方服务器时，连接不稳定，多数情况下断开后能自动重连恢复，但偶尔会永久卡在panic状态，日志显示：

_repairConnection already in progress  panic

按代码逻辑，panic状态应短暂存在后切换为reconnecting，最终转为connected或disconnected，但实际无进展，重连停滞。当前环境：Node.js v16.16.0，node-opcua v2.117.0，代码实现与官方示例一致。

原因分析 #

这条日志说明_repairConnection被重复调用，而panic状态的设计初衷是防止并发进入修复流程。但如果修复流程内部出现异步操作挂起（比如网络请求超时未处理、Promise未resolve/reject），就会导致客户端一直卡在panic状态，无法触发后续状态切换。

解决方案 #

1. 显式配置重连策略
   不要将connectionStrategy设为undefined，显式配置重连间隔、超时和重试次数，确保重连流程有明确的终止和重试机制：

const client = OPCUAClient.create({
  securityMode: MessageSecurityMode.None,
  securityPolicy: SecurityPolicy.None,
  endpointMustExist: false,
  requestedSessionTimeout: 60000,
  keepSessionAlive: true,
  connectionStrategy: {
    initialDelay: 1000, // 首次重连延迟
    maxRetry: 10,      // 最大重试次数
    maxDelay: 10000    // 最大重连间隔
  }
});

2. 监听panic事件并手动干预
   当客户端进入panic状态时，手动重置客户端状态或重新初始化，打破停滞：

client.on("panic", () => {
  console.warn("Client entered panic state, resetting...");
  // 先断开现有连接
  client.disconnect().catch(() => {});
  // 延迟后重新连接
  setTimeout(async () => {
    try {
      await client.connect("<url>");
      // 重新创建session和subscription
      await recreateSessionAndSubscription(client);
    } catch (err) {
      console.error("Reconnection failed after panic:", err);
    }
  }, 5000);
});

// 封装session和subscription的重建逻辑
async function recreateSessionAndSubscription(client) {
  const session = await client.createSession({
    userName: "<userName>",
    password: "<password>",
    type: UserTokenType.UserName
  });
  
  const subscription = await session.createSubscription2({
    requestedPublishingInterval: 1000,
    requestedLifetimeCount: 1000,
    requestedMaxKeepAliveCount: 10,
    maxNotificationsPerPublish: 0,
    publishingEnabled: true,
    priority: 1
  });
  
  // 重新创建监控项
  const monitoredItems = await subscription.monitorItems(
    [
      {
        nodeId: '...',
        attributeId: AttributeIds.Value
      },
      {
        nodeId: '...',
        attributeId: AttributeIds.Value
      }
    ],
    {
      samplingInterval: 1000,
      discardOldest: true,
      queueSize: 100
    },
    TimestampsToReturn.Both
  );
  
  monitoredItems.on('changed', (monitoredItem, dataValue) => {
    // 你的处理逻辑
  });
}

3. 完善错误监听
   确保client、session、subscription的错误事件都被监听，避免未处理的错误导致Promise链挂起：

client.on("error", (err) => {
  console.error("Client error:", err);
});

session.on("error", (err) => {
  console.error("Session error:", err);
});

subscription.on("error", (err) => {
  console.error("Subscription error:", err);
});

4. 升级node-opcua版本
   v2.117.0属于较旧版本，后续版本可能修复了重连流程中的状态机bug，建议升级到最新稳定版（如v2.x的最新版本或v3.x）。

5. 避免并发重连触发
   在调用连接或修复操作前，检查客户端当前状态，确保只有在disconnected状态下才触发重连：

async function safeReconnect(client, url) {
  if (client.state !== "disconnected") {
    console.warn("Client is not in disconnected state, skipping reconnect");
    return;
  }
  try {
    await client.connect(url);
  } catch (err) {
    console.error("Safe reconnect failed:", err);
  }
}

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