2

问题：如何获取展位发布者连接和断开的活跃度通知？

背景：我正在使用 OpenDDS 实现，其中我有一个数据类型 (dt) 的发布者和订阅者，使用相同的主题，位于不同的计算机上。

订阅方的阅读器已经覆盖了on_data_available(...)和的实现on_liveliness_changed(...)。我的订阅者首先启动，导致回调on_liveliness_changed(...)，说没有可用的作者。当发布者启动时，我会收到一个新的回调，告诉我有一个可用的作者，并且当发布者发布时，on_data_available(...)会调用它。到目前为止，一切都按预期工作。

发布者上的作者具有on_publication_matched(...). 启动发布on_publication_matched(...)者时，由于我们已经启动了订阅者，因此会被调用。

问题是当发布者断开连接时，我on_liveliness_changed(...)在阅读器端没有得到回调，当发布者再次启动时我也没有得到新的回调。

我试图通过设置readerQos.liveliness.lease_duration. 但结果是on_data_available(...)永远不会被调用，唯一的回调on_liveliness_changed(...)是在启动时，告诉我没有发布者。

DDS::DataReaderQos readerQos;
DDS::StatusKind mask = DDS::DATA_AVAILABLE_STATUS | DDS::LIVELINESS_CHANGED_STATUS |  DDS::LIVELINESS_LOST_STATUS ; 
m_subscriber->get_default_datareader_qos( readerQos );
DDS::Duration_t t = { 3, 0 };
readerQos.liveliness.lease_duration = t;
m_binary_Reader = static_cast<binary::binary_tdatareader( m_subscriber->create_datareader(m_Sender_Topic,readerQos,this, mask, 0, false) );

/克里斯托弗

4

1 回答 1

4

好吧，猜猜这里没有多少 DDS 用户。

经过一些研究，我发现只有满足此兼容性标准时才会发生读取器/写入器匹配：提供的租约持续时间 <= 请求的租约持续时间

解决方案是设置 writer QoS 以提供相同的活力。可能有一种方法可以检查请求的读取器 QoS 是否可以由相应的写入器提供，如果没有，请使用“较低”的 QoS，我还没有尝试过。

在 on_liveliness_changed 回调方法中，我只是评估了 LivelinessChangedStatus 中的 alive_count。

/克里斯托弗

于 2009-12-16T08:02:22.523 回答