Активное создание NATS-потребителя при создании сеанса для предотвращения потери сообщений

FixMediaService
Порезанный
25 апреля 2026 г. в 17:56 UTC
Автор
Kamo
Обещать
436811a

Ранее NATS JetStream push-потребитель создавался только при клиенте STOMP. Отправить /app/chat/subscribe С помощью DeliverPolicy. Новые сообщения, опубликованные до Потребитель постоянно теряется, вызывая сообщения посетителей и изменения имени. Никогда не появляется в камо-интернале, если агент не был подписан первым. Извлеките логику подписки NATS в ChatSessionSubscriptionManager обеспечивает подписку, фиксирует идентификатор, сериализованный как строка, чтобы избежать потери точности JS CockroachDB unique rowid IDs - Делегаты ChatWebSocketController подписываются на Сессию() менеджеру - Звонки PublicChatService обеспечивают Подписку() сразу после создания MediaSession (поэтому потребитель существует до появления первого сообщения посетителя) и снова в sendSupportMessage() в качестве запасного варианта

Все изменения

Как вы видите судоходство?

Каждое из этих обновлений автоматически попадает в ваше рабочее пространство. Начните бесплатно и смотрите, как он растет неделю за неделей.

Начните бесплатно навсегдаПосмотреть цены