Aeron Replaymerge永远不会合并

Question

我的replaymerge被困在状态from_live_join中，然后由于没有进度而出现。它添加了无问题的实时目的地（我看到相应的订阅出现在Aeron-Stat中，onimageavailable调用回调）。 最终它完全赶上了，但没有过渡到下一个状态。

进行了调查后，我发现有问题的检查在功能应该stopandremovereplay其中> image.activetransportcount（）＆gt; = 2是错误的，因为image.activetransportcount（）停留在1。如果不是为此，请检查replaymerge将成功。

这是我的replaymerge参数：

replayChannel = "aeron:udp"
replayDestination = "aeron:udp?endpoint=localhost:0"
liveDestination = "aeron:udp?endpoint=localhost:0|control=localhost:12345"

我已经尝试了Java客户端和C ++客户端。我想念什么？

编辑： 客户端上的Aeron-stat给出了这样的外观：

 42:                    1 - rcv-local-sockaddr: 41 <some IP address>:54709
 43:          452,985,472 - sub-pos: 24 -106708072 3000 aeron:udp?control-mode=manual @0
 44:          452,985,472 - rcv-hwm: 28 -106708072 3000 aeron:udp?control-mode=manual
 45:          452,985,472 - rcv-pos: 28 -106708072 3000 aeron:udp?control-mode=manual
 46:                    1 - rcv-local-sockaddr: 41 0.0.0.0:39238
 47:          452,971,520 - sub-pos: 24 -106708098 3000 aeron:udp?control-mode=manual @452971520
 48:          452,985,472 - rcv-hwm: 89 -106708098 3000 aeron:udp?control-mode=manual
 49:          452,971,520 - rcv-pos: 89 -106708098 3000 aeron:udp?control-mode=manual

第一个驱动程序订阅来自replayDestination。所有的数字都会如您期望的那样上升，就像普通的重播一样。

第二个是来自添加的livedestination。一旦创建，它根本就不会赶上，这与我上面的初步评估相反。 sub-pos和rcv-pos被困在452971520的初始位置，但是rcv-hwm与该位置一起上升重播订阅。这不是表明正在收到数据，但未在实时目的地订阅中阅读？

我注意到replaymerge＃image被简单地定义为，

image = subscription.imageBySessionId((int)replaySessionId);

因此我试图对sisscription我传递给replaymerge构造器，以便这两个图像都会在内部进行投票。那无济于事。

Answer 1

我解决了我的问题（在传递给replaymerge是特定于会话ID。

Aeron代码库中的文件replaymergetest.java可以使用它来

private final String publicationChannel = new ChannelUriStringBuilder()
    // ...
    .tags("1," + PUBLICATION_TAG)
    // ...
    ;

private final String replayChannel = new ChannelUriStringBuilder()
    .media(CommonContext.UDP_MEDIA)
    .isSessionIdTagged(true)
    .sessionId(PUBLICATION_TAG)
    .build();

，以便将重播频道的会话ID设置为publication与TAG publication_tag关联的publication。在出版媒体驱动程序和订阅媒体驱动程序的情况下，这也有效，但您仍然必须以某种方式将出版标签传达给订户，这可能会带来不便。

因此，我要寻求的解决方案是从录制的记录描述符中获取会话ID要重播，在较早的时候，我发现使用Aeronarchive＃listrecordingsforuri（或类似）发现录音。

此gist 这是一个工作的显示了一个工作Replaymerge 跨媒体。