Эта страница переведена с английского языковой моделью. При любом расхождении верен английский оригинал.
Путь
Этапы, через которые проходит одна доставка от потока брокера до подтверждения, в том порядке, в каком их выполняет рантайм.
Схема текстом
- Поток подписки открывается один раз, при старте → Цикл диспетчеризации доставка в переиспользуемой ячейке
- Цикл диспетчеризации доставка в переиспользуемой ячейке → Слои приёма первый добавленный - самый внешний
- Слои приёма первый добавленный - самый внешний → Декодирование кодек монтирования или байты
- Декодирование кодек монтирования или байты → Обработчик подписчика async fn под #[subscriber]
- Обработчик подписчика async fn под #[subscriber] → Ответ кодируется в буфер цикла
- Ответ кодируется в буфер цикла → Преобразования публикации в порядке цепочки
- Преобразования публикации в порядке цепочки → Слои публикации вокруг каждой публикации
- Слои публикации вокруг каждой публикации → Издатель отправляет ответ брокеру
- Издатель отправляет ответ брокеру → Подтверждение ack или повтор, если ответ не ушёл
Подписка и издатель ответа определяются один раз, при старте приложения, по подключённому брокеру. На этом пути ничто не ищет подписку или издателя заново для каждого сообщения.
Слои приёма охватывают декодирование, поэтому слой видит доставку, даже если её содержимое не декодируется. Такое содержимое не доходит до обработчика: её судьбу решает политика отказов.
Обработчик без ответа подтверждает доставку сразу после своего тела. Обработчик, который вернул исход с ошибкой, ответ не публикует. Если ответ не удалось опубликовать, доставка уходит на повтор, и запрос не теряется.
Ответ уходит туда, куда велит его тип. Издателю, который только читает байты, рантайм одалживает собственный буфер цикла, и ответ ничего не выделяет. Издатель, который байты сохраняет, получает свой буфер.