跳到主要内容

Republish

如果某个 NotificationMessage 因为网络丢包客户端没收到, republish 让服务端从缓存里重发:

pub fn Subscription::republish(&self, retransmit_sequence_number: u32) -> StatusCode;
一般无需调用

正常情况下 SDK 内部 AutoPublish 处理 SequenceNumber Ack, 客户端无感. 本 API 仅在特殊场景 (主动补包 / 调试) 使用.

何时用​

  • 客户端检测到 SequenceNumber 不连续 (gap), 主动补
  • 临时网络故障后, 想拿回这段时间的数据
  • 调试期 / 测试 SDK Republish 行为

用法​

let st = sub.republish(12345);
if st.is_good() {
    println!("Server confirmed retransmit, data will arrive in next Publish");
} else {
    eprintln!("Republish failed: {}", st);
}

注意​

  • 服务端只缓存最近 N 条 NotificationMessage (典型 N = 10), 超出的拿不回
  • republish 是请求服务端 "下次 Publish 时重发", 不是直接拿数据
  • 重发的数据通过正常 DataChange 回调收到, 客户端无需特殊处理
  • 失败码 BAD_MESSAGE_NOT_AVAILABLE 表示该 SequenceNumber 已超出缓存
  • 当前实现不解析返回的 NotificationMessage 内容; 数据会通过下次正常 Publish 收到

与 transfer_subscriptions 的区别​

API含义
republish服务端记得 Subscription, 只是某条消息漏了
transfer_subscriptionsSession 重连后接管旧 Session 的订阅

详见 Session 总览.

下一步​