📚 课程目录第3章版本管理概述

3. 版本管理概述：版本号策略、乐观锁与悲观锁、时间戳版本控制

在倒排索引的版本管理中，核心挑战在于：如何在不中断查询服务的前提下，安全、高效地更新索引数据。版本管理机制决定了系统能否正确处理并发写入、检测冲突、以及实现索引的快照与回滚。本节从版本号策略、锁机制、时间戳控制三个维度展开，为后续的嵌套文档版本化奠定基础。

3.1 版本号策略

版本号是索引文档或段（Segment）的全局或局部标识符，用于追踪变更顺序与数据新鲜度。常见的版本号策略包括：

策略类型	实现方式	适用场景	典型问题
单调递增整数	全局原子计数器（如 Redis INCR、数据库自增 ID）	单主节点写入、文档级版本控制	分布式环境下计数器瓶颈
UUID / 哈希	基于内容或时间戳生成唯一标识	去中心化写入、离线合并	无法直接比较新旧顺序
混合版本号	高位时间戳 + 低位序列号（如 `1710000001_0001`）	分布式索引段管理	需要时钟同步或逻辑时钟

  实践建议： 在倒排索引的段合并场景中，推荐使用单调递增整数作为段版本号，配合段元数据中的min_version和max_version字段，可以快速判断某个文档版本是否存在于当前段中。

3.2 乐观锁与悲观锁

锁机制决定了系统在并发写入时如何处理冲突。两种锁策略在索引版本管理中有截然不同的应用模式：

悲观锁（Pessimistic Locking）：在写入前先获取锁，阻塞其他写入者，直到当前操作完成。适用于写冲突概率高或写入代价极高的场景（如全量索引重建）。
乐观锁（Optimistic Locking）：不阻塞写入，但在提交时检查版本号是否被其他写入者修改。适用于读多写少或冲突概率低的场景（如文档级增量更新）。

版本冲突检测公式（乐观锁）：
写入条件：current_version == expected_version
写入动作：new_version = current_version + 1
失败处理：重试整个操作或返回冲突错误给客户端。

以下流程图对比了两种锁机制在索引写入中的典型路径：

3.3 时间戳版本控制

时间戳版本控制使用系统时钟或逻辑时钟（如 Lamport 时钟、Vector Clock）作为版本标识。其核心优势在于天然支持时间维度的查询（如“查询某个时间点之前的索引快照”）。

物理时间戳：直接使用 System.currentTimeMillis() 或 NTP 同步时间。简单直观，但存在时钟回拨风险。
逻辑时间戳：使用单调递增的计数器，不依赖物理时钟。适合分布式环境，但无法直接映射到真实时间。
混合时间戳：高位为物理时间戳，低位为逻辑计数器。兼顾时间语义与单调性。

时钟回拨陷阱： 在分布式倒排索引系统中，如果节点 A 的时钟比节点 B 快 2 秒，A 写入的版本时间戳可能被 B 误判为“未来版本”，导致索引合并时出现版本乱序。解决方案：使用逻辑时钟或引入最大时钟偏移容忍度（如 5 秒窗口）。

3.4 三种策略对比总结

维度	版本号策略	乐观锁 / 悲观锁	时间戳版本控制
冲突检测	版本号比较	CAS 或锁状态	时间戳先后比较
并发吞吐	高（无锁）	乐观锁高 / 悲观锁低	高（无锁）
时钟依赖	无	无	物理时间戳依赖时钟
回滚能力	需额外快照表	需记录操作日志	天然支持时间点回滚
典型应用	Elasticsearch 文档版本	数据库行锁 / 索引段锁	时序数据库、事件溯源

3.5 领域驱动设计中的版本管理映射

在领域驱动设计（DDD）视角下，版本管理不应仅被视为技术实现细节，而应作为领域概念显式建模：

值对象（Value Object）：Version 作为值对象，封装版本号、时间戳、操作类型等属性，具备不可变性。
聚合根（Aggregate Root）：索引文档作为聚合根，其版本号控制整个聚合的并发边界。
领域事件（Domain Event）：DocumentVersioned 事件记录每次版本变更的上下文（操作人、变更原因、前驱版本）。

领域建模示例：

// 版本值对象
public class DocumentVersion : ValueObject
{
    public long VersionNumber { get; }
    public DateTime Timestamp { get; }
    public string OperationType { get; } // "CREATE" | "UPDATE" | "MERGE"

    public bool IsNewerThan(DocumentVersion other) =>
        VersionNumber > other.VersionNumber;
}

// 聚合根中的版本控制
public class IndexDocument : AggregateRoot
{
    public DocumentVersion CurrentVersion { get; private set; }

    public void ApplyUpdate(UpdateCommand cmd, DocumentVersion expectedVersion)
    {
        if (!CurrentVersion.Equals(expectedVersion))
            throw new ConcurrencyConflictException("版本冲突");

        // 执行领域逻辑...
        CurrentVersion = new DocumentVersion(
            CurrentVersion.VersionNumber + 1,
            DateTime.UtcNow,
            "UPDATE"
        );
        AddDomainEvent(new DocumentVersioned(this.Id, CurrentVersion));
    }
}