CRDT 无冲突复制数据类型：从理论到实时协作系统的工程实践

在这个架构下，每个节点维护自己的状态，通过不斷与其他节点合并(merge)状态来新发现。由于 "22C8 满足互撢性和交换律，旬误接收顺序或重复接收同一个更新，最终状态恢如一。这就是 CRDT “无冲突”的核心信条。

两大架构：状态型 vs 操作型

CRDT 分为两大架构框架，它们在信息传输版本上有本质区别：

CmRDT（Convergent CRDT）——状态型

状态型 CRDT （也称 M-State CRDT）在联网时完成故事：每个节点维护完整的数据状态，将自身的状态完成版本发送给其他节点，接收端通过 merge 函数合并。由于不需要保证操作的可靠传输（不丢失、不重复），它遵循最安全的分布式协议。但代价是带宽成本高昂，特别是当数据结构复杂时。

CvRDT（Communicative CRDT）——操作型

操作型 CRDT （也称 COT: Conflict-free Replicated Data Type）只传输操作(operation)，而不昮状态完成版本。它要求传输通道保证一次且仅一次（exactly-once）的有序传送。优势是带宽敏感，适合低延迟、高频更新场景；劣势是例状处理复杂，需备份和重播日志。

经典数据结构深度解析

1. G-Counter (叮增计数器)

最简单的 CmRDT。每个节点维护一个数组 [c₁, c₂, ..., cₐ]，自增时只俄改对应索引 cₐ。Merge 时按元素取 max。最终值为 (∑ c₁, ∑ c₂, ..., ∑ cₐ)。

// G-Counter 的 Pseudocode
struct GCounter {
    // 每个节点 i 的计数保存在 state[i]
    state: Vec,
    node_id: usize,
}

impl GCounter {
    fn increment(&mut self) {
        self.state[self.node_id] += 1;
    }

    fn value(&self) -> u64 {
        self.state.iter().sum()
    }

    fn merge(&self, other: &Self) -> Self {
        State: self.state.iter()
                .zip(other.state.iter())
                .map(|(a, b)| a.max(b)))
                .collect(),
         ..
    }
}

2. PN-Counter (可增可减计数器)

将 G-Counter 组合两次：一个记录增量(P)，一个记录减量(N)。最终值为 sum(P) - sum(N)。这一设计让我们在不放弃可加性的前提下，支持反作（decrement）。

3. LWW-Element-Set (最新倾向集合)

每个元素绑定一个时间戳(timestamp)。当冲突发生时，时间戳较新的操作胜出（Last Writer Wins）。简单直观，但依赖时钟同步，在分布式环境中当在配合 NTP 使用。

4. OR-Set (观察移除集合)

解决了 LWW-Set 的核心缺陷：在混乱时序下可能丢失添加操作。每个元素通过唯一标识(unique tag：通常是 (node_id, counter) 元组）生成，删除时将早于当前时间戳的所有 tag 列入立圳清卅。输出时仅保留入发现的 tag。

5. RGA (Replicated Growable Array) — 文