NATS

tip

支持 JetStreaming
支持 WebSocket - 能够利用 HTTP 基础设施
支持 JWT Auth
支持 Auth Resolver - 通过 nats service 监听实现自定义 auth
支持 Group Consumer
支持 RPC -> Load Balance - Request/Reply
支持 KV
支持 ObjectStore

nats-io/nats-server 是什么？
- 偏向通讯协议，用作消息队列
- 默认没有持久化
- 协议支持 MQTT, NATS, WebSocket
- 集成 JetStream - 替代 STAN
  - 支持 KV、ObjectStore
  - 支持持久化
端口
- 4222 客户端
- 8222 HTTP 管理和信息上报
- 6222 集群路由
- 7422 Leaf Node
参考
- nats-io/nats-architecture-and-design
  - ADR - Architecture and Design Docs
- nats-io/natscli
  - 命令行工具
- nats-io/nsc
  - nats 账号管理功能
- compare-nats
- Client Protocol
SDK
- nats.go
- nats.java
- nats.net
- Javascript
  - nats.ws
  - nats.deno
  - nats.js
    - NPM nats
- nats.c
- nats.py
- nats.rs
Demo
- nats://demo.nats.io:4222
- demo.nats.io:7422
- wss://demo.nats.io:8443
- https://demo.nats.io:8222/varz
- https://demo.nats.io:8222/healthz
- https://demo.nats.io:8222/connz
  - limit, offset, state
- https://demo.nats.io:8222/routez?subs=true
- https://demo.nats.io:8222/gatewayz
- https://demo.nats.io:8222/leafz?subs=true
- https://demo.nats.io:8222/subsz
- https://demo.nats.io:8222/acountz?acc=$G
- https://demo.nats.io:8222/accstatz?unused=false
- https://demo.nats.io:8222/jsz

# Docker
# 服务端 - 大约 10mb
docker run --rm -it --name nats -p 4222:4222 -p 6222:6222 -p 8222:8222 nats:alpine -js

# macOS
brew install nats-server
nats-server

# nats 工具需要额外 tap 或者直接下载 https://github.com/nats-io/natscli/releases
brew tap nats-io/nats-tools
brew install nats-io/nats-tools/nats
nats --help

nats account info
nats rtt

Notes

Subject-Based Messaging
- Subject 名字 [a-z0-9.]+
- 级/层/token
- 建议不超过 16 层
- 通过 a.b 方式实现级联
- 单层匹配 a.*.c - 匹配 a.b.c
- 多层匹配 a.b.> - 匹配 a.b.c.d
- *.*.c.> - 匹配 a.b.c.d
Publish-Subscribe
Queue Groups / Queue Subscribe / Consumer Group
- Kafka Consumer Group 概念
- 多个 consumer 共享消费位置
- queue 表示这个 group - 有唯一的名字
- 如果不设置 durable 则会在 consumer 关闭完时移除 queue 信息
- durable 为一个 consumer 的名字
- 当所有 consumer unsub 时，也会移除 queue 信息
ACK
- 响应一条消费的消息
- 返回 +ACK
Sequence Numbers
Leaf Nodes
- 路由消息到其他集群
gateways
- 连接多个集群组成 full mesh

nats-top

nats-io/nats-top

Notes​

nats-top​

Notes

nats-top