NATS. Queue Group

Queue Groups Π² NATS β€” ΠΌΠ΅Ρ…Π°Π½ΠΈΠ·ΠΌ распрСдСлСния сообщСний ΠΌΠ΅ΠΆΠ΄Ρƒ подписчиками Π² Ρ€Π°ΠΌΠΊΠ°Ρ… ΠΎΠ΄Π½ΠΎΠΉ Ρ‚Π΅ΠΌΡ‹ (subject). ΠŸΠΎΠ·Π²ΠΎΠ»ΡΠ΅Ρ‚ Ρ€Π΅Π°Π»ΠΈΠ·ΠΎΠ²Π°Ρ‚ΡŒ ΠΏΠ°Ρ‚Ρ‚Π΅Ρ€Π½ Β«ΠΊΠΎΠ½ΠΊΡƒΡ€Π΅Π½Ρ‚Π½Ρ‹Ρ… ΠΏΠΎΡ‚Ρ€Π΅Π±ΠΈΡ‚Π΅Π»Π΅ΠΉΒ» (competing consumers).

flowchart LR
    A(["Publisher"]) -- msq 1,2,3 --> B(("Queue"))
    B -- msq 2 --> C1(["Subscriber"])
    B -- msq 1 --> C2(["Subscriber"])
    B -- msq 3 --> C3(["Subscriber"])

Как Ρ€Π°Π±ΠΎΡ‚Π°Π΅Ρ‚

  • НСсколько подписчиков ΠΎΠ±ΡŠΠ΅Π΄ΠΈΠ½ΡΡŽΡ‚ΡΡ Π² Π³Ρ€ΡƒΠΏΠΏΡƒ ΠΏΠΎ ΠΎΠ±Ρ‰Π΅ΠΌΡƒ queue name.
  • КаТдоС сообщСниС ΠΏΠΎΠ»ΡƒΡ‡Π°Π΅Ρ‚ Ρ‚ΠΎΠ»ΡŒΠΊΠΎ ΠΎΠ΄ΠΈΠ½ подписчик ΠΈΠ· Π³Ρ€ΡƒΠΏΠΏΡ‹ (балансировка Π½Π°Π³Ρ€ΡƒΠ·ΠΊΠΈ).
  • ΠŸΠΎΠ΄ΠΏΠΈΡΡ‡ΠΈΠΊΠΈ ΠΈΠ· Ρ€Π°Π·Π½Ρ‹Ρ… queue groups ΠΏΠΎΠ»ΡƒΡ‡Π°ΡŽΡ‚ всС сообщСния ΠΏΠΎ Ρ‚Π΅ΠΌΠ΅ (ΠΊΠ°ΠΊ ΠΎΠ±Ρ‹Ρ‡Π½Ρ‹Π΅ подписчики).

Source:: https://docs.nats.io/nats-concepts/core-nats/queue