基准测试

ruststream-pulsar 在每条消息上的开销：与裸 pulsar 客户端对照的吞吐量，以及它自身代码的指令数和内存分配次数。

与裸客户端对照

第一张图在真实的 Pulsar Broker 上把同一个场景用三种方式运行。裸客户端 直接驱动一个 pulsar crate 的消费者。Broker crate 用一个自己的循环驱动本 crate 的订阅，上面没有运行时。RustStream 是用户写的服务：应用里的一个 #[subscriber] 处理器。第一项差值是本 crate 比它所封装的客户端多付出的开销，第二项是运行时在其上增加的开销。

每个循环画成一条横条，从最佳一轮延伸到最慢的一轮，圆点标出最佳一轮，缺口标出中位一轮。坐标轴的零点是裸客户端的最佳一轮，圆点在零点右侧表示更慢。空心圆点表示该循环与裸客户端的差异小于各轮的波动范围。图表下方的表格列出最佳一轮，括号里是中位数。

两个场景的区别在于订阅类型。服务器为 Shared 订阅的每条消息保存一个重新投递计数，Exclusive 订阅则不保存。两个场景都只运行一个消费者，所以区分它们的是这项记账，而不是共享的开销。

代码的开销

第二张图统计一条消息在服务线程上的开销：稳态下 callgrind 测得的指令数和 DHAT 测得的内存分配次数。每个场景都是一个基于 PulsarBroker、连接同一个 Broker 的服务，使用持久化主题上的一个 Shared 订阅。计数包括框架的分发、本 crate 的代码，以及 pulsar 客户端的工作，客户端的连接和消费者都运行在服务的运行时上。Broker 是另一个进程，不计入。冷启动 是建立连接、订阅并取得第一条消息一次性付出的开销。

结果

与裸客户端对照各循环比裸客户端最佳一轮低多少

• 裸客户端
• Broker crate
• 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

• 无法区分
• 无法区分 (受 Broker 限制)

裸客户端

27,594 msg/s (27,518)

Broker crate

27,656 msg/s (27,554)

RustStream

27,652 msg/s (27,586)

Shared subscription, 128 B JSON, ack each

• 无法区分
• 无法区分 (受 Broker 限制)

裸客户端

27,720 msg/s (27,716)

Broker crate

27,662 msg/s (27,548)

RustStream

27,710 msg/s (27,408)

以表格显示数字

场景	裸客户端	Broker crate	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)	无法区分 (受 Broker 限制)
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)	无法区分 (受 Broker 限制)

代码的开销

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.

指令数

010万20万

内存分配

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
Broker	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，由基准测试命令写入。方法论说明它们是怎样测得的，数字说明可以从中得出什么结论。