跳到主要内容

自动重连

概述​

OPC UA Server 维护重启 / 网络抖动时 Session 失效。SDK 内部把所有 RPC 都包了一层重试机制:

  1. 调底层 RPC, 命中 BadSessionClosed / BadSessionIdInvalid / BadSecureChannelClosed
  2. 自动调 reconnect() 重建 SecureChannel + Session
  3. 重连成功重试一次
  4. 仍失败 → 抛 OpcUaException (Safe 版本折叠为 StatusCode)

业务侧无需处理, 重连结果通过 ua.events() 通道推 Reconnecting / Reconnected。

API​

方法 / 事件类别读写说明
ua.reconnect()方法写手动触发
events.onReconnecting(listener)事件读重连开始
events.onReconnected(listener)事件读重连成功
events.onDisconnected(listener)事件读断开
events.onSessionLost(listener)事件读Session 失效预警

代码示例​

import com.darra.opcua.*;

try (DarraOpcUa ua = new DarraOpcUa("opc.tcp://localhost:4840")) {
    ua.events().onReconnecting(e ->
        System.out.println("重连中... " + e.endpointUrl));

    ua.events().onReconnected(e ->
        System.out.println("已恢复"));

    ua.events().onSessionLost(e ->
        logger.warn("Session 失效: " + e.message + " (" + e.statusCode + ")"));

    ua.connect();

    // 业务代码完全不需要 try/catch 重连
    while (running) {
        ReadResult rr = ua.readSafe("ns=2;s=Temp");
        // 即使中途服务端重启, readSafe 已自动重连+重试
        Thread.sleep(1000);
    }
}

重连策略​

  • 单次 RPC 最多重连 1 次
  • 重连超时 = 构造时 connectTimeoutMs (默认 10000)
  • 多 RPC 并发触发时内部串行化
  • 完全失败由业务侧通过 disconnected 事件提示用户

与订阅自恢复​

Session 重连后 SDK 自动:

  1. 尝试 transferSubscriptions(oldSubId) 转移
  2. 失败 → 用缓存的 MonitoredItemSpec 重建全部 MI

详见 订阅自恢复。

跨语言对照​

C#PythonJavaC++RustC
ua.Reconnect()ua.reconnect()ua.reconnect()ua.Reconnect()ua.reconnect()DarraUa_Session_Reconnect

下一步​