Chronicle Queue文件名、文件增长处理及滚动分割配置技术咨询

1. 写入磁盘的文件名格式 #

Chronicle Queue的磁盘文件分为数据文件和索引文件，命名规则基于cycle（周期段）：

• 数据文件：{队列根目录}/{队列名称}-{cycle编号}.cq4（默认后缀.cq4对应Chronicle Queue 4.x版本）
• 索引文件：{队列根目录}/{队列名称}-{cycle编号}.cq4i
  其中cycle编号是递增数值，对应不同周期段（默认按自然日划分，每个日期对应一个独立cycle）。

2. 文件持续增长的处理方案 #

当单个cycle文件持续膨胀时，可通过以下方式处理：

• 清理旧cycle文件：已被完全消费的旧cycle数据/索引文件可直接删除，不会影响当前写入的cycle，可结合消费进度定期清理历史文件。
• 缩短滚动周期：将默认的按天滚动调整为按小时、分钟滚动，减少单个文件的容量上限。
• 启用大小触发滚动：配置文件大小阈值，达到阈值时自动生成新文件，避免单个文件无限增长。

3. 配置滚动分割模式 #

Chronicle Queue原生支持滚动分割模式，通过RollingChronicleQueue实现，可配置多种滚动策略：

按时间滚动 #

使用内置时间周期策略，示例如下：

RollingChronicleQueue queue = SingleChronicleQueueBuilder.binary("/data/queue")
    .rollCycle(RollCycles.HOURLY) // 每小时生成新文件
    // 可选策略：RollCycles.DAILY（默认）、RollCycles.MINUTELY等
    .build();

按文件大小滚动 #

自定义基于文件大小的滚动策略，设置单个文件的最大容量：

// 单个文件达到100MB时触发滚动
SizeBasedRollCycle sizeCycle = new SizeBasedRollCycle(1024 * 1024 * 100);
RollingChronicleQueue queue = SingleChronicleQueueBuilder.binary("/data/queue")
    .rollCycle(sizeCycle)
    .build();

自定义滚动策略 #

若内置策略不满足需求，可实现RollCycle接口，自定义滚动触发条件（比如结合时间和大小的复合策略）。

内容的提问来源于stack exchange，提问作者0penJava