Proaktywnie tworzyć konsumenta NATS podczas tworzenia sesji, aby zapobiec utracie wiadomości

FixMediaService
Szycy
25 kwietnia 2026 17:56 UTC
Autor
Kamo
Pochęt się
436811a

Wcześniej konsument NATS JetStream został utworzony tylko wtedy, gdy klient STOMP Wysłano /app/chat/subskrypcja. Z DeliverPolicy.Nowe, wszelkie wiadomości publikowane przed Istnieje konsument jest trwale utracony – powodując zmiany wiadomości odwiedzających i nazwy Nigdy nie pojawia się w kamo-internal, chyba że agent został subskrybentem. - Wyodrębnij logikę subskrypcji NATS do ChatSessionSubscriptionManager (idempotent Upewnij sięSubstenkcja, naprawy id serializowane jako String, aby uniknąć precyzyjnej utraty JS CockroachDB unique_rowid IDs) - ChatWebSocketController delegaci subskrybująToSession() do menedżera - PublicChatService połączenia gwarantująSubskrypcja () zaraz po utworzeniu MediaSession (tak więc konsument istnieje przed przybyciem pierwszej wiadomości odwiedzającej) I jeszcze raz w sendSupportMessage() jako fallback

Wszystkie zmiany

Jak to, co widzisz żeglugę?

Każda z tych aktualizacji automatycznie ląduje w miejscu pracy. Zacznij za darmo i obserwuj, jak rośnie tydzień po tygodniu.

Start Free ForeverZobacz ceny