Zum Inhalt springen

Änderungen von Dokument NATS - Technisches Setup

Zuletzt geändert von Daniel Herrmann am 2025/12/14 16:20
Von Version 1.1 Icon
bearbeitet von Daniel Herrmann
am 2025/09/08 08:42
Änderungskommentar: Es gibt keinen Kommentar für diese Version
Auf Version Icon 2.1 Icon
bearbeitet von Daniel Herrmann
am 2025/09/08 08:44
Änderungskommentar: Es gibt keinen Kommentar für diese Version

Zusammenfassung

Details

Icon Seiteneigenschaften
Inhalt
... ... @@ -6,11 +6,9 @@
6 6  
7 7  NATS kann grob in zwei Varianten unterteilt werden, **NATS Core** und **NATS JetStream**.
8 8  
9 -(% style="" data-start="0" data-end="347" %)
10 10  NATS Core ist das Grundsystem von NATS und bietet schnelle, leichtgewichtige Kommunikationsmöglichkeiten wie Publish/Subscribe, Request/Reply und Queueing. Dabei werden Nachrichten in der Regel nur flüchtig übertragen: Geht ein Empfänger offline, gehen die Nachrichten verloren. Der Fokus liegt auf extrem niedriger Latenz und hoher Performance.
11 11  
12 -(% style="" data-start="349" data-end="822" data-is-last-node="" data-is-only-node="" %)
13 -NATS JetStream erweitert NATS Core um Funktionen wie (% data-start="402" data-end="483" %)**Persistenz, wiederholtes Lesen von Nachrichten und zeitversetzte Verarbeitung**(%%). Nachrichten können gespeichert werden, was eine zuverlässige Zustellung, Wiederholungen und komplexe Workflows ermöglicht. JetStream ist damit besonders geeignet für Szenarien, in denen eine dauerhafte Verarbeitung oder Event-Sourcing erforderlich ist, während Core eher für schnelle, vorübergehende Nachrichtenübertragung optimiert ist.
11 +NATS JetStream erweitert NATS Core um Funktionen wie **Persistenz, wiederholtes Lesen von Nachrichten und zeitversetzte Verarbeitung**. Nachrichten können gespeichert werden, was eine zuverlässige Zustellung, Wiederholungen und komplexe Workflows ermöglicht. JetStream ist damit besonders geeignet für Szenarien, in denen eine dauerhafte Verarbeitung oder Event-Sourcing erforderlich ist, während Core eher für schnelle, vorübergehende Nachrichtenübertragung optimiert ist.
14 14  
15 15  == {{id name="NATSSetup-JetStreamkonfiguration"/}}JetStream konfiguration ==
16 16  
... ... @@ -48,3 +48,49 @@
48 48  Consumer sind eine Auswahl / Ansicht von Teilen eines Streams. Details finden sich wieder in der NATS Dokumentation: [[https:~~/~~/docs.nats.io/nats-concepts/jetstream/consumers>>url:https://docs.nats.io/nats-concepts/jetstream/consumers||shape="rect"]]
49 49  
50 50  Consumer können entweder persistent sein (dauerhaft, ein Client kann dann den bestehenden Consumer neben) oder flüchtig (ephemeral), in diesem Fall wird der Consumer beim Erstellen des Clients (beispielsweise durch N8n) angelegt. In der Regel werden Consumer durch einen Filter auf bestimmte Subjects beschränkt, diese dürfen sich nicht überschneiden.
49 +
50 += {{id name="NATSSetup-Troubleshooting"/}}Troubleshooting =
51 +
52 +JetStream
53 +
54 +{{code language="shell"}}
55 +$ nats context select mksp-jsadmin
56 +$ nats stream ls
57 +╭─────────────────────────────────────────────────────────────────────────────────────╮
58 +│ Streams │
59 +├────────────────┬─────────────┬─────────────────────┬──────────┬──────┬──────────────┤
60 +│ Name │ Description │ Created │ Messages │ Size │ Last Message │
61 +├────────────────┼─────────────┼─────────────────────┼──────────┼──────┼──────────────┤
62 +│ backend_events │ │ 2025-09-08 08:36:19 │ 0 │ 0 B │ never │
63 +{{/code}}
64 +
65 +Sys
66 +
67 +{{code language="shell"}}
68 +$ nats context select mksp-sysadmin
69 +$ nats server report connections
70 +
71 +╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮
72 +│ Top 5 Connections out of 5 by subs │
73 +├─────┬──────────────────────────┬──────────────┬─────────┬───────────────────┬─────────┬────────┬─────────┬──────────┬──────────┬───────────┬──────┤
74 +│ CID │ Name │ Server │ Cluster │ IP │ Account │ Uptime │ In Msgs │ Out Msgs │ In Bytes │ Out Bytes │ Subs │
75 +├─────┼──────────────────────────┼──────────────┼─────────┼───────────────────┼─────────┼────────┼─────────┼──────────┼──────────┼───────────┼──────┤
76 +│ 10 │ │ mksp-nats-01 │ │ 172.18.0.37:47950 │ MKSP │ 18m7s │ 0 │ 0 │ 0 B │ 0 B │ 0 │
77 +│ 12 │ │ mksp-nats-01 │ │ 172.18.0.39:46446 │ MKSP │ 18m7s │ 10 │ 0 │ 4.5 KiB │ 0 B │ 0 │
78 +│ 9 │ │ mksp-nats-01 │ │ 172.18.0.37:47934 │ MKSP │ 18m7s │ 0 │ 0 │ 0 B │ 0 B │ 1 │
79 +│ 11 │ │ mksp-nats-01 │ │ 172.18.0.33:37156 │ MKSP │ 18m7s │ 0 │ 10 │ 0 B │ 4.5 KiB │ 1 │
80 +│ 22 │ NATS CLI Version 0.2.4 │ mksp-nats-01 │ │ 10.1.253.1:60153 │ SYS │ 0s │ 2 │ 1 │ 210 B │ 933 B │ 1 │
81 +├─────┼──────────────────────────┼──────────────┼─────────┼───────────────────┼─────────┼────────┼─────────┼──────────┼──────────┼───────────┼──────┤
82 +│ │ Totals for 5 connections │ │ │ │ │ │ 12 │ 11 │ 4.8 KiB │ 5.5 KiB │ 3 │
83 +╰─────┴──────────────────────────┴──────────────┴─────────┴───────────────────┴─────────┴────────┴─────────┴──────────┴──────────┴───────────┴──────╯
84 +
85 +╭──────────────────────────────────────╮
86 +│ Connections per server │
87 +├──────────────┬─────────┬─────────────┤
88 +│ Server │ Cluster │ Connections │
89 +├──────────────┼─────────┼─────────────┤
90 +│ mksp-nats-01 │ │ 5 │
91 +╰──────────────┴─────────┴─────────────╯
92 +{{/code}}
93 +
94 +\\
Icon Confluence.Code.ConfluencePageClass[0]
Id
... ... @@ -1,1 +1,1 @@
1 -207814662
1 +207814663
URL
... ... @@ -1,1 +1,1 @@
1 -https://wiki.makerspace-darmstadt.de/spaces/PROJ/pages/207814662/NATS Setup
1 +https://wiki.makerspace-darmstadt.de/spaces/PROJ/pages/207814663/NATS Setup