Бенчмарки

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

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

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

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

Два сценария различаются типом подписки. Для каждого сообщения подписки Shared сервер ведёт счётчик повторных доставок, а для подписки Exclusive не ведёт. Оба сценария используют один консьюмер, поэтому их разделяет именно этот учёт, а не стоимость совместного чтения.

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

Второй график считает, во что обходится одно сообщение на потоке сервиса: инструкции под callgrind и выделения памяти под DHAT, в установившемся режиме. Каждый сценарий - сервис на PulsarBroker против того же брокера, с подпиской Shared на персистентный топик. В счёт входят диспетчеризация фреймворка, код этого крейта и работа клиента pulsar, соединение и консьюмер которого выполняются на рантайме сервиса. Брокер - другой процесс, и в счёт он не входит. «Холодный старт» - разовая стоимость подключения, подписки и получения первого сообщения.

Результаты

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

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

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

-4%-2%0%+2%+4%

Exclusive subscription, 128 B JSON, ack each

• неразличимо
• неразличимо (упирается в брокер)

Сырой клиент

27 594 msg/s (27 518)

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

27 656 msg/s (27 554)

RustStream

27 652 msg/s (27 586)

Shared subscription, 128 B JSON, ack each

• неразличимо
• неразличимо (упирается в брокер)

Сырой клиент

27 720 msg/s (27 716)

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

27 662 msg/s (27 548)

RustStream

27 710 msg/s (27 408)

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

Сценарий	Сырой клиент	Крейт брокера	RustStream	Оверхед
Exclusive subscription, 128 B JSON, ack each	27 594 msg/s (27 518)	27 656 msg/s (27 554) (неразличимо к клиенту)	27 652 msg/s (27 586)	неразличимо (упирается в брокер)
Shared subscription, 128 B JSON, ack each	27 720 msg/s (27 716)	27 662 msg/s (27 548) (неразличимо к клиенту)	27 710 msg/s (27 408)	неразличимо (упирается в брокер)

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

AMD Ryzen 9 7900X 12-Core Processor, x86_64, 427-5912 MHz, 12 physical, 24 logical, 62.4 GiB, unknown, Linux 7.2.11-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-pulsar default (none), ruststream macros,json. ruststream-pulsar 0.7.0, ruststream 0.7.0, измерено 2026-10-18.

Инструкции

0100 тыс.200 тыс.

Выделения

02040

shared subscription, JSON decode into a small struct, ack each

58 724,1

18,9

Инструкции

58 724,1

Выделения

18,9

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

603 714 / 277

reply through this crate's publisher, broker receipt awaited

120 058,1

38

Инструкции

120 058,1

Выделения

38

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

622 642 / 293

shared subscription in batches of 64, assembled on the client

59 643,5

18,2

Инструкции

59 643,5

Выделения

18,2

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

614 552 / 281

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

Сценарий	Инструкции	Выделения	Холодный старт
shared subscription, JSON decode into a small struct, ack each	58 724,1	18,9	603 714 / 277
reply through this crate's publisher, broker receipt awaited	120 058,1	38	622 642 / 293
shared subscription in batches of 64, assembled on the client	59 643,5	18,2	614 552 / 281

Машина

Процессор	AMD Ryzen 9 7900X 12-Core Processor
Архитектура	x86_64
Частота	427-5912 MHz
Ядра	12 physical, 24 logical
Память	62.4 GiB
Скорость памяти	unknown
Операционная система	Linux 7.2.11-x64v3-xanmod1-1
Брокер	apachepulsar/pulsar:4.1.2 in Docker on localhost
Круговая задержка	0.047 ms round trip
Компилятор	1.99.0
Профиль сборки	bench, inheriting release (opt-level = 3, lto = fat, codegen-units = 16, debug = line-tables-only)
Фичи	ruststream-pulsar 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 этой версии, который записывает рецепт бенчмарков. Как они сняты, объясняет страница Методология, а какие выводы они позволяют сделать, - страница Числа.