Эта страница переведена с английского языковой моделью. При любом расхождении верен английский оригинал.
Путь
Путь сообщения SQS через сервис RustStream: получение, доставка, обработчик, ответ и удаление, по одному сообщению или пакетами.
Схема текстом
- По одному: ReceiveMessage 10, ожидание 20 с; Канал вмещает один пакет; SqsMessage выдаются по одному; Обработчик декодирует и выполняет; Ответ: SendMessage или Publish в SNS; ack DeleteMessage
- Пакетами: ReceiveMessage размер n, до 10; Канал вмещает один пакет; Vec<SqsMessage> никогда не пуст; Обработчик пакетов один вызов на пакет; Каждому элементу свой DeleteMessage
- ReceiveMessage 10, ожидание 20 с → Канал вмещает один пакет: пакет
- Канал вмещает один пакет → SqsMessage выдаются по одному
- SqsMessage выдаются по одному → Обработчик декодирует и выполняет
- Обработчик декодирует и выполняет → Ответ: SendMessage или Publish в SNS
- Ответ: SendMessage или Publish в SNS → ack DeleteMessage
- ReceiveMessage размер n, до 10 → Канал вмещает один пакет
- Канал вмещает один пакет → Vec<SqsMessage> никогда не пуст
- Vec<SqsMessage> никогда не пуст → Обработчик пакетов один вызов на пакет
- Обработчик пакетов один вызов на пакет → Каждому элементу свой DeleteMessage
Задача приёма запрашивает десять сообщений за одно получение, со всеми атрибутами сообщения и системными атрибутами, и ждёт до 20 секунд. Тайм-аут видимости она называет, только когда его называет дескриптор. Длинный опрос, который закончился ничем, ничего не выдаёт, поэтому пакет никогда не бывает пустым. Канал вмещает один пакет, поэтому задача приёма опережает обработчики не больше чем на одно получение.
Каждое сообщение становится SqsMessage. Тело копируется
из ответа SDK, а атрибуты сообщения становятся заголовками, вместе с группой сообщений и счётчиком
получений. Доставка также запускает продление своей видимости. На сообщение приходится несколько
выделений памяти, а во что обходится одно сообщение, публикует страница
Бенчмарки.
Подписка, которая обрабатывает сообщения по одному, разбирает пакет и выдаёт его сообщения по порядку. Пакетная подписка запрашивает собственный размер, но не больше десяти, и её обработчик принимает весь пакет за один вызов. Каждое сообщение пакета всё равно удаляется отдельным вызовом.
Ответ кодируется в буфер, который цикл диспетчеризации использует повторно.
SqsPublisher берёт этот буфер телом одного вызова
SendMessage, а SnsPublisher - телом одного вызова
Publish. Адрес очереди или ARN темы разрешается один раз и кешируется.
Доставка завершается после ответа. Каждое завершение проходит через клиенты SDK того рантайма, который его выполняет, а что делает каждый исход, показывает страница Завершение.