NATS JetStream保留与流治理

--- title: NATS JetStream保留与流治理 keywords: - JetStream - Retention - Stream - Consumer - replicas description: 通过 JetStream 的保留策略与流/消费者配置，控制消息存储与投递保障并实现高可用。 categories: - 文章资讯 - 技术教程 --- # NATS JetStream保留与流治理 ## 概览 - JetStream 为 NATS 提供持久化与流功能，支持不同保留策略与副本配置。 - 通过消费者控制投递策略、确认与重试，实现可靠处理。 - 在集群与多副本下提升可用性与容灾能力。 ## 技术参数（已验证） - 流：定义 `subjects`、`storage`（File/Memory）、`retention`（Limits/Interest/WorkQueue）、`max_msgs/max_bytes/max_age`、`replicas`。 - 消费者：设置 `deliver_policy`（All/Last/New/ByStartSequence/ByStartTime）、`ack_policy`（Explicit/None/All）、`max_deliver` 与 `ack_wait`。 - 高可用：`replicas>=3` 在集群中提升容灾；记录 leader 选举与滞后。 - 观测：`nats stream/consumer` 命令与监控端点；记录丢弃与重试。 - 安全：限制主题与访问；在多租户中隔离流与消费者。 ## 实战清单 - 按业务选择保留策略与存储类型；设置副本与容量阈值。 - 配置消费者投递与确认策略；验证重试与准确性。 - 建立监控与告警；在升级与故障演练中验证恢复。 - Importance: 以存储与投递治理提升可靠性与可用性。