当前位置:首页 >专题 >NATS JetStream Go 消息流工程

NATS JetStream Go 消息流工程
NATS JetStream Go

NATS JetStream Go 消息流工程

从 Stream、Consumer 到集群可靠性
NATS JetStream 为 Core NATS 增加持久化、回放、消费确认和高可用复制,适合构建轻量而可靠的事件流与任务分发系统。本专题以 Go 客户端为主线,覆盖 Stream 与 Consumer 建模、ack 与重投、Kubernetes 验证、集群法定人数、性能边界以及 KV/Object Store 等生产能力。

站内 Go/NATS 实战与故障排查

从发布消费到重放、性能与集群恢复

Golang开发:使用NATS构建可靠的消息队列
文章

Golang开发:使用NATS构建可靠的消息队列

从 Go 客户端出发理解 NATS 消息队列的可靠交付实践。
在Beego中使用NATS实现消息队列
文章

在Beego中使用NATS实现消息队列

展示 Go Web 服务接入 NATS 消息队列的应用方式。
使用 jscontext.newConsumer() 在 Golang 中创建 NATS 推送消费者
文章

使用 jscontext.newConsumer() 在 Golang 中创建 NATS 推送消费者

围绕 JetStream 推送消费者和 jscontext API 展开示例。
接收 NATS Jetstream 服务器的心跳消息的方法
文章

接收 NATS Jetstream 服务器的心跳消息的方法

讨论接收 JetStream 服务器心跳消息的处理方式。
NATS JetStream:如何请求 JetStream 重新发送主题 foo.* 中最新的消息?
文章

NATS JetStream:如何请求 JetStream 重新发送主题 foo.* 中最新的消息?

围绕主题匹配和历史消息重发排查 JetStream 请求流程。
Jetstream是否支持消息排序?
文章

Jetstream是否支持消息排序?

聚焦 JetStream 消息顺序与消费语义的边界。
nats JetStream 集群消费者没有法定人数,已停止
文章

nats JetStream 集群消费者没有法定人数,已停止

通过消费者无 quorum 的故障现象理解集群可用性。
NATS Jetstream 的性能
文章

NATS Jetstream 的性能

从性能角度观察 NATS JetStream 的吞吐与使用边界。

JetStream 上线前的常见问题

把可靠性、幂等、消费和存储边界说清楚

JetStream 和 Core NATS 应该怎么选?

Core NATS 适合低延迟、在线即收的即时消息;JetStream 适合需要持久化、回放、确认、重试或解耦生产与消费速度的场景。

ack 之后还会重复消费吗?

会。网络中断、ack 超时或服务在处理后确认前崩溃都可能导致重复投递,因此消费者必须设计幂等键、去重或事务性处理。

Stream 的复制因子是不是越高越好?

不是。复制因子提升容错和存储开销,也要求更多节点保持 quorum;应按故障域、数据价值、延迟和恢复目标选择。

Push Consumer 和 Pull Consumer 怎么选?

Push Consumer 上手简单,适合稳定的订阅回调;Pull Consumer 更便于批量拉取、背压、并发度和工作池控制,生产系统通常优先显式管理拉取节奏。

微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议 和 隐私政策
返回登录
  • 重置密码