"NATS JetStream 流与持久化订阅实践"

NATS JetStream 流与持久化订阅实践流与消费者（JS CLI）nats stream add ORDERS --subjects orders.* --storage file --retention limits nats consumer add ORDERS PROC --filter orders.created --ack explicit Node.js 示例import { connect, StringCodec } from 'nats'; const nc = await connect({ servers: 'nats://127.0.0.1:4222' }); const jsm = await nc.jetstream(); const sc = StringCodec(); await jsm.publish('orders.created', sc.encode(JSON.stringify({ id: 1 }))); const c = await jsm.consumers.get('ORDERS', 'PROC'); const iter = await c.fetch({ max_wait: 5000 }); for await (const m of iter) { m.ack(); } 总结JetStream 在 NATS 上提供流与持久化消费者，支持显式确认与多策略保留，适合可靠消息处理。