当前位置:首页 >专题 >NATS JetStream Go 消息流工程
NATS JetStream Go
NATS JetStream Go 消息流工程
从 Stream、Consumer 到集群可靠性
NATS JetStream 为 Core NATS 增加持久化、回放、消费确认和高可用复制,适合构建轻量而可靠的事件流与任务分发系统。本专题以 Go 客户端为主线,覆盖 Stream 与 Consumer 建模、ack 与重投、Kubernetes 验证、集群法定人数、性能边界以及 KV/Object Store 等生产能力。
官网、快速开始、API 文档与 SDK
先把 JetStream 的数据模型和 Go 入口读准确
官方
JetStream 官方概念总览
解释 JetStream 的持久化、回放、消费确认和一致性边界。
官方
Streams 官方文档
说明 stream、subject、存储策略、保留策略和消息序列。
官方
Consumers 官方文档
覆盖 durable、ack、delivery policy、max deliveries 和 pull/push consumer。
官方
JetStream Developer 快速开始
从启用服务器、创建 stream 到发布和消费消息给出可运行路径。
官方
nats.go JetStream Go SDK
官方 Go 客户端的新 JetStream API、示例与实现入口。
官方
Go jetstream 包 API 参考
提供 Go 类型、方法、配置项和版本化 API 参考。
官方
JetStream 集群官方文档
说明 RAFT、复制因子、节点法定人数和集群配置。
官方
Key/Value Store 官方文档
说明以 JetStream 为持久化引擎的 KV bucket、版本与 watch。
官方
Object Store 官方文档
介绍基于 JetStream 的对象分片、传输、复制和存储 API。
JetStream 上线前的常见问题
把可靠性、幂等、消费和存储边界说清楚
JetStream 和 Core NATS 应该怎么选?
Core NATS 适合低延迟、在线即收的即时消息;JetStream 适合需要持久化、回放、确认、重试或解耦生产与消费速度的场景。
ack 之后还会重复消费吗?
会。网络中断、ack 超时或服务在处理后确认前崩溃都可能导致重复投递,因此消费者必须设计幂等键、去重或事务性处理。
Stream 的复制因子是不是越高越好?
不是。复制因子提升容错和存储开销,也要求更多节点保持 quorum;应按故障域、数据价值、延迟和恢复目标选择。
Push Consumer 和 Pull Consumer 怎么选?
Push Consumer 上手简单,适合稳定的订阅回调;Pull Consumer 更便于批量拉取、背压、并发度和工作池控制,生产系统通常优先显式管理拉取节奏。
相关专题
继续查看相近方向内容
查看更多
最新文章
-
- Datasets streaming 怎么在不下载全集时打乱样本
- 2分钟前 470浏览
-
- Go maps.EqualFunc 怎么比较值类型不同的映射
- 3分钟前 284浏览
-
- 栗子漫画产品站页面怎么核对?品牌标识、下载入口与版权年份说明
- 6分钟前 423浏览
-
- Go maps.Keys 的迭代结果为什么不能依赖顺序
- 10分钟前 304浏览
-
- kazumi自动连播怎么设置?播放行为开关与下一集衔接边界说明
- 15分钟前 302浏览
-
- Go x509.CertPool 为什么在不同系统里根证书数量不同
- 17分钟前 130浏览
-
- Docker Buildx 怎么给镜像同时生成 SBOM 和来源证明
- 19分钟前 335浏览
-
- LT画质助手修改后游戏里看不到选项怎么办?设置显示与实际生效边界
- 26分钟前 108浏览

