URL de conexión

nats://<IP_DE_LA_VM>:30422

‍

Con autenticación por token

nats://<AUTH_TOKEN>@<IP_DE_LA_VM>:30422

‍

ℹ️ Si no configuraste el token al desplegar, búscalo en los outputs del deployment en el portal de Cuemby.

‍

Verificar conectividad con nats CLI

# Instalar nats CLI
curl -sf https://binaries.nats.dev/nats-io/natscli/nats@latest | sh

# Verificar conexión
nats server info --server nats://<AUTH_TOKEN>@<IP_DE_LA_VM>:30422

# Publicar un mensaje de prueba
nats pub mi.subject "hola mundo" --server nats://<AUTH_TOKEN>@<IP_DE_LA_VM>:30422

# Suscribirse a un subject
nats sub mi.subject --server nats://<AUTH_TOKEN>@<IP_DE_LA_VM>:30422

‍

Connection strings por lenguaje

// Go (nats.go)
nc, _ := nats.Connect("nats://<IP_DE_LA_VM>:30422",
    nats.Token("<AUTH_TOKEN>"))

# Python (nats-py)
nc = await nats.connect("nats://<IP_DE_LA_VM>:30422",
    token="<AUTH_TOKEN>")

// Node.js (nats.ws / nats.js)
const nc = await connect({
    servers: "<IP_DE_LA_VM>:30422",
    token: "<AUTH_TOKEN>"
});

‍

Monitoring UI

NATS expone un dashboard de métricas en tiempo real en el puerto 30822:

http://<IP_DE_LA_VM>:30822/

‍

Endpoints útiles:

# Info general del servidor
curl http://<IP_DE_LA_VM>:30822/varz

# Estado de JetStream
curl http://<IP_DE_LA_VM>:30822/jsz

# Conexiones activas
curl http://<IP_DE_LA_VM>:30822/connz

# Ver el pod de NATS
kubectl get pods -A | grep nats

# Ver log de instalación
tail -f /var/log/cuemby/bootstrap.log

# Verificar que los puertos están escuchando
ss -tlnp | grep -E '30422|30822'

‍

Output esperado:

NAME                          READY   STATUS    RESTARTS
nats-jetstream-xxxxxxxxx      1/1     Running   0        ← Running ✓

# Crear un stream
nats stream add MI_STREAM \
  --subjects "eventos.>" \
  --storage file \
  --server nats://<AUTH_TOKEN>@<IP_DE_LA_VM>:30422

# Ver streams existentes
nats stream ls --server nats://<AUTH_TOKEN>@<IP_DE_LA_VM>:30422

# Publicar un mensaje persistido
nats pub eventos.nuevo "{'id': 1, 'tipo': 'registro'}" \
  --server nats://<AUTH_TOKEN>@<IP_DE_LA_VM>:30422

# Crear un consumer y leer mensajes
nats consumer add MI_STREAM MI_CONSUMER \
  --server nats://<AUTH_TOKEN>@<IP_DE_LA_VM>:30422

‍

💡 Tip: JetStream usa --storage file para persistencia en disco y --storage memory para máxima velocidad sin persistencia. Para producción usa siempre file.