复制ChronicleChannel的Wire至2个Appender后数据异常的技术咨询

问题根源 #

你遇到的问题核心是原Wire的读取指针在copyTo操作后发生偏移。copyTo会从当前指针位置开始复制数据，完成后指针停在数据末尾，导致后续操作第一个Appender时，原Wire已无有效可读取数据。另外，如果Wire基于流实现，可能存在底层数据源共享的情况，导致两个Appender的数据无法独立工作。

修复方案 #

方案1：复制前重置原Wire指针 #

每次调用copyTo前，将原Wire指针重置到起始位置，确保全量复制所有数据：

// 重置原Wire指针到开头
dc.wire().reset();
try (DocumentContext dc2 = pub.appender.writingDocument()) {
    dc.wire().copyTo(dc2.wire());                               
}

// 再次重置指针，保证第二次复制的完整性
dc.wire().reset();
try(DocumentContext dcallw = puball.appender.writingDocument()){                                
    dc.wire().copyTo(dcallw.wire());
}

try(DocumentContext dcallr = puball.tailer.readingDocument()){
    String ss = dcallr.wire().readEvent(String.class);
}

方案2：使用Wire副本执行复制 #

若原Wire不支持重置，或不想修改原指针状态，可创建原Wire的副本（通过duplicate()方法），用副本完成copyTo操作，避免影响原Wire的状态：

try (DocumentContext dc2 = pub.appender.writingDocument()) {
    dc.wire().duplicate().copyTo(dc2.wire());                               
}

try(DocumentContext dcallw = puball.appender.writingDocument()){                                
    dc.wire().duplicate().copyTo(dcallw.wire());
}

try(DocumentContext dcallr = puball.tailer.readingDocument()){
    String ss = dcallr.wire().readEvent(String.class);
}

额外验证点 #

• 确认copyTo方法是否会复制Wire的所有元数据与事件，部分实现可能仅复制当前指针到末尾的数据，需确保是全量复制。
• 检查Appender配置，保证每个Appender使用独立的底层存储（如独立文件、内存缓冲区），避免因数据共享导致互相影响。

内容的提问来源于stack exchange，提问作者Liu Leo