自动重连

概述

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

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

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

API

方法 / 事件	类别	读写	说明
ua.reconnect()	方法	写	手动触发
events.on_reconnecting(cb)	事件	读	重连开始
events.on_reconnected(cb)	事件	读	重连成功
events.on_disconnected(cb)	事件	读	断开
events.on_session_lost(cb)	事件	读	Session 失效预警

代码示例

use opcua::DarraOpcUa;
use std::time::Duration;

let ua = DarraOpcUa::new("opc.tcp://localhost:4840")?;

ua.events().on_reconnecting(|e| {
    println!("重连中... {}", e.endpoint_url);
});
ua.events().on_reconnected(|e| {
    println!("已恢复");
});
ua.events().on_session_lost(|e| {
    eprintln!("Session 失效: {} ({:?})", e.message, e.status_code);
});

ua.connect()?;

// 业务代码完全不需要 try 重连
loop {
    let (_st, _dv) = ua.read_safe("ns=2;s=Temp", AttributeId::Value);
    // 即使中途服务端重启, read_safe 已自动重连+重试
    std::thread::sleep(Duration::from_secs(1));
}

重连策略

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

与订阅自恢复

Session 重连后 SDK 自动:

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

详见 订阅自恢复。

跨语言对照

C#	Python	Java	C++	Rust	C
ua.Reconnect()	ua.reconnect()	ua.reconnect()	ua.Reconnect()	ua.reconnect()	DarraUa_Session_Reconnect

下一步

• Safe API
• Subscription 自恢复