nats

NATS 消息系统命令行

补充说明

nats CLI 连接 NATS 服务器，发布/订阅消息并管理 JetStream 流和消费者。核心 NATS 是至多一次投递，JetStream 才提供持久化和确认。

常用示例

nats server check
nats context add local --server nats://127.0.0.1:4222
nats pub app.events '{"id":1}'
nats sub 'app.>' --count 10
nats stream add ORDERS --subjects 'orders.>' --storage file --retention limits
nats stream ls
nats consumer add ORDERS worker --pull --deliver all --ack explicit
nats consumer next ORDERS worker

易错点与排错

• 核心 NATS 不持久化；需要可靠投递时用 JetStream。
• subject 通配符 * 匹配单层，> 匹配多层；写错会收不到消息。
• JetStream 消费者要确认 ack；不 ack 会重投或堆积。
• --deliver all 会从最早消息开始；生产消费者通常从 new 或指定序列开始。
• 认证、TLS 和 account 权限配置错误会表现为连接失败或权限拒绝。
• 集群模式要确认路由和 JetStream 副本数；单节点不是高可用。
• 流和消费者的 retention/limits 配置会影响磁盘和重放行为。

相关命令

• nats-server — 服务端
• pulsar — 另一种消息系统
• kafka-topics — Kafka 主题管理