Бенчмарки

Во что ruststream-nats обходится на каждом сообщении: пропускная способность против сырого клиента async-nats, инструкции и выделения памяти его кода.

Против сырого клиента

Первый график прогоняет каждый сценарий тремя способами на настоящем сервере NATS. «Сырой клиент» напрямую работает с async-nats. «Крейт брокера» читает подписку этого крейта собственным циклом, без рантайма. «RustStream» - сервис, который пишет пользователь: обработчик #[subscriber] в приложении. Первая разность показывает, сколько этот крейт стоит поверх клиента, которого он оборачивает, а вторая - сколько сверху добавляет рантайм.

Каждый цикл изображён полосой от лучшего круга до самого медленного: точка отмечает лучший круг, засечка - медиану. Ноль оси - лучший круг сырого клиента, и точка правее нуля значит, что цикл медленнее. Пустая точка отмечает цикл, у которого разница с сырым клиентом меньше разброса кругов. Таблица под графиком печатает лучший круг, а в скобках медиану.

Два сценария - это две модели. На субъекте Core NATS сервер сам отправляет каждое подходящее сообщение и ничего не завершает. На pull-консьюмере JetStream клиент запрашивает сообщения пакетами и отправляет подтверждение на каждое, как показывает страница Путь.

Стоимость кода

Второй график считает, во что обходится одно сообщение на потоке сервиса: инструкции под callgrind и выделения памяти под DHAT, в установившемся режиме. Каждый сценарий - сервис на NatsBroker, который читает pull-консьюмер JetStream на том же сервере. Сервис работает в одном потоке, и задача соединения async-nats выполняется там же, поэтому в счёт входят фреймворк, этот крейт и собственная работа клиента с сокетом. Поток издателя в счёт не входит. «Холодный старт» - разовая стоимость подключения, поиска стрима, создания консьюмера и получения первого сообщения.

Результаты

Против сырого клиентаНасколько каждый цикл отстаёт от лучшего круга сырого клиента

• Сырой клиент
• Крейт брокера
• RustStream
• круги, от лучшего до самого медленного
• лучший круг
• медианный круг
• разброс кругов
• неразличимо

ruststream-nats 0.7.0 on ruststream 0.7.0, AMD Ryzen 9 7900X 12-Core Processor, Linux 7.2.10-x64v3-xanmod1-1, nats:2-alpine in Docker on localhost, измерено 2026-10-18. Как сняты числа

-40%-20%0%+20%+40%

Core NATS, 512 B JSON

• неразличимо
• неразличимо

Сырой клиент

1 569 899 msg/s (1 539 255)

Крейт брокера

1 471 311 msg/s (1 394 551)

RustStream

1 489 165 msg/s (1 414 937)

JetStream pull consumer, 512 B JSON, ack each

• неразличимо
• неразличимо

Сырой клиент

226 164 msg/s (218 628)

Крейт брокера

220 256 msg/s (217 097)

RustStream

220 367 msg/s (215 485)

Показать числа таблицей

Сценарий	Сырой клиент	Крейт брокера	RustStream	Оверхед
Core NATS, 512 B JSON	1 569 899 msg/s (1 539 255)	1 471 311 msg/s (1 394 551) (неразличимо к клиенту)	1 489 165 msg/s (1 414 937)	неразличимо
JetStream pull consumer, 512 B JSON, ack each	226 164 msg/s (218 628)	220 256 msg/s (217 097) (неразличимо к клиенту)	220 367 msg/s (215 485)	неразличимо

Стоимость кода

AMD Ryzen 9 7900X 12-Core Processor, x86_64, 427-5912 MHz, 12 physical, 24 logical, 62.4 GiB, unknown, Linux 7.2.10-x64v3-xanmod1-1, 1.99.0, 3.25.1, bench, inheriting release (opt-level = 3, lto = fat, codegen-units = 16, debug = line-tables-only), ruststream-nats default (none), ruststream macros,json. ruststream-nats 0.7.0, ruststream 0.7.0, измерено 2026-10-18.

Инструкции

010 тыс.20 тыс.

Выделения

01020

JetStream pull consumer, JSON decode into a small struct, ack each

8 679,9

7,1

Инструкции

8 679,9

Выделения

7,1

Холодный старт

292 434 / 295

JetStream pull consumer, reply published by NatsPublisher on Core NATS

12 165,1

11,1

Инструкции

12 165,1

Выделения

11,1

Холодный старт

297 315 / 300

JetStream fetches of 64, ack each

8 469,6

6,4

Инструкции

8 469,6

Выделения

6,4

Холодный старт

316 037 / 322

Показать числа таблицей

Сценарий	Инструкции	Выделения	Холодный старт
JetStream pull consumer, JSON decode into a small struct, ack each	8 679,9	7,1	292 434 / 295
JetStream pull consumer, reply published by NatsPublisher on Core NATS	12 165,1	11,1	297 315 / 300
JetStream fetches of 64, ack each	8 469,6	6,4	316 037 / 322

Машина

Процессор	AMD Ryzen 9 7900X 12-Core Processor
Архитектура	x86_64
Частота	427-5912 MHz
Ядра	12 physical, 24 logical
Память	62.4 GiB
Скорость памяти	unknown
Операционная система	Linux 7.2.10-x64v3-xanmod1-1
Брокер	nats:2-alpine in Docker on localhost
Круговая задержка	68.3 us (median of 30000 request/reply round trips on one connection)
Компилятор	1.99.0
Профиль сборки	bench, inheriting release (opt-level = 3, lto = fat, codegen-units = 16, debug = line-tables-only)
Фичи	ruststream-nats default (none), ruststream macros,json
RUSTFLAGS	none (the recipe clears RUSTFLAGS, so the numbers are not tied to this CPU)
Valgrind	3.25.1

Числа берутся из файла docs/benchmarks/results.json этой версии, который записывает рецепт бенчмарков. Как они сняты, объясняет страница Методология, а какие выводы они позволяют сделать, - страница Числа.