NATS JetStream 持久消费者与 Ack 重试策略实战

创建流与持久消费者（CLI）：

nats stream add ORDERS --subjects orders.* --storage file --retention limits --max-age 72h --replicas 1
nats consumer add ORDERS worker --filter orders.created --pull --ack explicit --max-deliver 5

Node.js 订阅处理（手动确认）：

import { connect } from 'nats'
const nc = await connect({ servers: 'nats://127.0.0.1:4222' })
const js = nc.jetstream()

const sub = await js.subscribe('orders.created', { durable: 'worker', manualAck: true })
for await (const m of sub) {
  try {
    const data = JSON.parse(m.string())
    // 业务处理...
    m.ack()
  } catch (e) {
    // 未 ack 将触发重投递，受 max-deliver 控制
  }
}