保存ChronicleQueue的消费者/裁剪者读取偏移量

Question

我正在探索ChronicleQueue来保存我的一个应用程序中生成的事件。我想在经过一些处理后，将保存的事件按其原始发生顺序发布到不同的系统。我有多个应用程序实例，每个实例都可以运行一个单线程appender来将事件添加到ChronicleQueue。尽管跨实例排序是必要的，但我想理解以下两个问题。

String file = "myPath";
try (ChronicleQueue cq = SingleChronicleQueueBuilder.binary(file).build()) {
  for(int i = 0 ;i<10;i++){
    cq.acquireAppender().writeText("test"+i);
  }
}


try (ChronicleQueue cq = SingleChronicleQueueBuilder.binary(file).build()) {
    ExcerptTailer atailer = cq.createTailer("a");
    System.out.println(atailer.readText());
    System.out.println(atailer.readText());
    System.out.println(atailer.readText()); 
}

2）还需要一些建议，如果有一种方法来保持跨实例的事件顺序。

Answer 1

使用命名的tailer应该确保tailer只读取一条消息一次。如果你有一个不发生这种情况的例子，你能创建一个测试来重现它吗？

写入时队列中条目的顺序是固定的，所有的tailer都以相同的顺序看到相同的消息，没有任何选择。