从JDK8迁移至JDK11后，如何在ChronicleQueue 5中实现复制？

问题核心原因 #

Chronicle Queue v5将复制功能拆分到了独立的chronicle-queue-replication模块中，核心chronicle-queue包不再包含相关类，这就是你找不到ReplicatedQueue和ReplicatedQueueCfg的原因。

步骤1：引入复制模块依赖 #

需要在项目依赖中添加chronicle-queue-replication模块，以Maven为例：

<dependency>
    <groupId>net.openhft</groupId>
    <artifactId>chronicle-queue-replication</artifactId>
    <version>${chronicle-queue.version}</version> <!-- 版本需与v5核心包一致 -->
</dependency>

步骤2：实现原SourceQueue的功能（数据发送端） #

通过ReplicatedQueueCfg配置SOURCE角色，指定本地队列路径、远程接收端地址等参数，创建复制队列：

import net.openhft.chronicle.queue.replication.ReplicatedQueue;
import net.openhft.chronicle.queue.replication.ReplicatedQueueCfg;

// 配置Source端
ReplicatedQueueCfg sourceCfg = ReplicatedQueueCfg.builder()
        .basePath("/path/to/local/source-queue")
        .role(ReplicatedQueueCfg.Role.SOURCE)
        .remoteEndpoints("tcp://sink-host:port") // Sink端的地址
        .build();

try (ReplicatedQueue sourceQueue = ReplicatedQueue.create(sourceCfg)) {
    // 使用sourceQueue发送数据，和普通Chronicle Queue的写入方式一致
    try (ExcerptAppender appender = sourceQueue.acquireAppender()) {
        appender.writeText("复制的消息内容");
    }
}

步骤3：实现原SinkQueue的功能（数据接收端） #

配置SINK角色，指定本地队列路径和监听地址：

import net.openhft.chronicle.queue.replication.ReplicatedQueue;
import net.openhft.chronicle.queue.replication.ReplicatedQueueCfg;

// 配置Sink端
ReplicatedQueueCfg sinkCfg = ReplicatedQueueCfg.builder()
        .basePath("/path/to/local/sink-queue")
        .role(ReplicatedQueueCfg.Role.SINK)
        .listenAddress("tcp://0.0.0.0:port") // 监听的地址，对应Source端的remoteEndpoints
        .build();

try (ReplicatedQueue sinkQueue = ReplicatedQueue.create(sinkCfg)) {
    // 读取复制过来的数据，和普通Chronicle Queue的读取方式一致
    try (ExcerptTailer tailer = sinkQueue.createTailer()) {
        String message = tailer.readText();
        System.out.println("收到复制消息：" + message);
    }
}

注意事项 #

• 确保chronicle-queue核心包和chronicle-queue-replication模块的版本完全一致，避免兼容性问题。
• JDK11环境下，若使用JPMS模块系统，需在module-info.java中声明依赖：requires net.openhft.chronicle.queue.replication;

内容的提问来源于stack exchange，提问作者prashant mishra