Watch 机制：持久 Watch 与 Revision 追溯

从 ZooKeeper 的痛点说起

ZooKeeper 的一次性 Watch 设计导致在通知到达与重新注册之间的时间窗口内可能会错过事件。对于需要审计或事件溯源的场景中间状态被丢弃是无法接受的。

持久 Watch 与 Revision

etcd v3 的 Watch 是持久化的。除非主动取消或连接断开，否则会持续推送所有后续变更。每次写入都会分配全局递增的 Revision也可以从任意历史 Revision 开始监听，从而保证不丢失事件。

如果你在高并发环境下遇到 “ErrCompacted” 错误。说明你尝试从已被压缩的 Revision 继续 Watch，此时必须先全量同步后再恢复。

watchableStore 内部实现

• synced watchers：已经追上最新 revision 的 watcher，实时接收事件。
• unsynced watchers：请求从历史 revision 开始监听，需要后台 goroutine 逐步追赶至最新状态。
• victims：channel 满时暂挂起的事件，稍后重试。

.3a Put 请求完整 Watch 触发链路

sequenceDiagram
participant C as 客户端
participant API as gRPC API层
participant R as Raft模块
participant F as Follower
participant MVCC as MVCC存储引擎
participant W as watchableStore
说到C->API，Put
说到API->R。Propose日志条目
R->F这方面，MsgApp复制
说到F-->R，多数派ACK
R->MVCC: Apply已提交条目
MVCC->MVCC: treeIndex插入revision
MVCC->MVCC: BoltDB写入KV
MVCC->W: 通知synced watchers
W->C的观点是，推送WatchEvent
API-->C: 返回OK

WatchStream 多路复用

一个 gRPC 双向流可承载多条 Watch，每条有独立 watch_id，从而减少连接数和网络开销。客户端可共享同一连接进行多个前缀或单 key 的监控。

Watch 事件类型与顺序保证

与 ZooKeeper Watch 本质区别对比表格

Lease 机制：分布式场景下的 TTL 管理

Lease 基本概念与生命周期操作:

stateDiagram-v2
--> Granted : Grant
Granted --> Active : 附加key
Active --> Active : KeepAlive续约
Active --> Expired : TTL耗尽，无续约
Active --> Revoked : 主动撤销
Expired --> KeysDeleted : 自动删除所有关联key
Revoked --> KeysDeleted : 立即删除所有关联key
KeysDeleted --> 

• **注意**：Lease 在 Leader 切换后会被自动重置 TTL。如不想让此行为影响业务，请使用 ::lease-checkpointing::true::lease-checkpoint-persist=true::node-leader-election=true::node-lease-txns=true::node-lease-checkpoint=false::node-lease-checkpoint-timeout=30s::node-lease-checkpoint-window=10s::node-lease-checkpoint-window-count=1000::... 
• **警告**：KeepAlive 必须持续消费，否则会导致 channel 阻塞，使得续约请求永远无法发送至服务器，从而导致 Lease 自动过期。务必在生产环境中使用循环消费 KeepAlive 响应，例如： go for ka := range keepAliveCh { if ka == nil { fmt.Println break } fmt.Printf }
• **实战提醒**：当你的服务需要快速响应节点失效时建议使用 ::lease-timeout-sec=30s::node-heartbeat-sec=1s::... 
• **高可用提示**：在 Kubernetes 集群中。kubelet 使用 Node Lease 替代 NodeStatus 更新，以减轻 etcd 负担。每个节点维持一个 Lease，每秒心跳一次如果你看到大量 “ErrCompacted” 或 “Key not found” 错误。请检查 Node Lease 是否正常续约。若出现节点频繁离线，启动 kubelet 时请先执行 `etcdctl lease revoke --force NODE_LEASE_ID` 再重新创建。以避免旧 Lease 泄漏造成数据冗余。
• *示例代码*: 服务注册 & KeepAlive 简易实现 ： go package main import ( "context" "fmt" "log" "time"

  clientv3 "go.etcd.io/etcd/client/v3"
  

  ) func main { cli。err := clientv3.New(clientv3.Config{ Endpoints: string{"http://127.0.0.1:2379"},DialTimeout: time.Second * 5,}) if err!= nil { log.Fatal } defer cli.Close

  // 创建一个 TTL 为30秒的 Lease
  resp。err := cli.Grant,30)
  if err!= nil {
  log.Fatal
  }
  id := resp.ID
  key := "/services/api/instance-" + strconv.FormatInt.UnixNano。10)
  if _,err = cli.Put,key,"running",clientv3.WithLease);err，= nil {
  log.Fatal
  }
  // 自动续约 - 每秒一次 KeepAlive
  ch,_ := cli.KeepAlive。id)
  for ka := range ch {
  if ka == nil {
  log.Println
  break
  }
  fmt.Printf
  }
  

  }
  • 如果你的服务实例需要按需扩容/缩容，可将 `/services/api/instance-…​` 前缀统一管理，并使用 `clientv3.WithPrefix` 在 etcd 中批量查询。

    MVCC 存储引擎：treeIndex 与 BoltDB 的双层架构