订阅自恢复

概述

Session 重连后, 服务端 Subscription 可能仍存活也可能已被清理。SDK 两步走:

1. transfer_subscriptions — 把旧 SubscriptionId 转给新 Session
2. Recreate — 失败时, 按缓存重建 Sub + 全部 MI

业务侧无需手动处理。

API

方法 / 事件	类别	读写	说明
ua.transfer_subscriptions(old_sub_ids, send_initial_values)	方法	写	转移订阅
events.on_subscription_lost(cb)	事件	读	订阅丢失
events.on_subscription_restored(cb)	事件	读	订阅恢复

代码示例

use opcua::{
    DarraOpcUa, AttributeId, MonitoringMode,
    DataChangeFilter, DeadbandType,
};

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

ua.events().on_subscription_lost(|e| {
    eprintln!("订阅丢失: sub_id={}", e.subscription_id);
});
ua.events().on_subscription_restored(|e| {
    println!("订阅已恢复: {}", e.source);
});

ua.connect()?;

// 创建 sub + MI, 全程不变
let sub = ua.create_subscription(500)?;
let filter = DataChangeFilter {
    deadband_type: DeadbandType::Absolute, deadband_value: 0.5,
    ..Default::default()
};
let mi = sub.add("ns=2;s=Temp", AttributeId::Value, 200.0,
    MonitoringMode::Reporting, 10, true, Some(&filter))?;

sub.on_data_changed(|args| {
    println!("{:?} @ {:?}", args.value.value, args.value.source_timestamp);
});

// 拔网线 30 秒, 看日志:
// reconnecting → reconnected → subscription_restored
// 数据自动续上, filter 也保留

// 手动 transfer
let rcs = ua.transfer_subscriptions(&[sub.subscription_id()], true)?;

恢复流程

重连成功
   ↓
对每个本地 Subscription:
  1. transfer_subscriptions(old_sub_id)
     ├─ Good → subscription_restored 事件
     └─ BadSubscriptionIdInvalid → 进入 2
  2. create_subscription(original_params) 拿新 sub_id
  3. 按本地 _mi_cache 重建所有 MI
     - sampling_interval / mode / queue_size / discard_oldest
     - DataChangeFilter
     - EventFilter
     - Triggering Links
  4. subscription_restored 事件

缓存的字段

_mi_cache 保留: NodeId / AttributeId / SamplingInterval / Mode / QueueSize / DiscardOldest / DataChangeFilter / EventFilter。

恢复时全部重放, 服务端 mi id 会变, 业务侧应使用 client_handle 而非 server-side id 对账。

最佳实践

• 业务用 client_handle, 不要持久化 mi id
• 监听 on_subscription_restored
• 不要在 on_subscription_lost 里手动 recreate
• 关键参数变更后 pause 再 resume

跨语言对照

C#	Python	Java	C++	Rust	C
TransferSubscriptions	transfer_subscriptions	transferSubscriptions	TransferSubscriptions	transfer_subscriptions	DarraUa_Session_TransferSubscriptions

下一步

• 自动重连
• Republish