基准测试

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

与裸客户端对照

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

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

圆点如果出现在零点左侧，表示该循环比裸客户端更快。裸循环一次只持有一次投递，它解码和结算时没有任何东西在读套接字。本 crate 的订阅则提前读取，读进一个深度等于链路信用的通道，所以循环要下一次投递时，它已经在手里了。

代码的开销

第二张图统计一条消息在服务线程上的开销：稳态下 callgrind 测得的指令数和 DHAT 测得的内存分配次数。每个场景都是一个基于 AmqpBroker、连接同一个 Broker 的服务。计数包括框架的分发、本 crate 的代码，以及 fe2o3-amqp 客户端的分帧和解码，它们作为连接的任务运行在该线程上。Broker 是另一个进程，它的工作都不计入。冷启动 是连接服务、附加订阅并取得第一次投递一次性付出的开销。

结果

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

• 裸客户端
• Broker crate
• RustStream
• 各轮，从最佳到最慢
• 最佳一轮
• 中位一轮
• 轮次的波动范围
• 无法区分

ruststream-amqp 0.7.0 on ruststream 0.7.0, AMD Ryzen 9 7900X 12-Core Processor, Linux 7.2.10-x64v3-xanmod1-1, apache/activemq-artemis:latest-alpine in Docker on localhost, 测量于 2026-10-18. 这些数字是怎样测得的

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

queue, 512 B JSON, accept each

• +2.5%
• 无法区分

裸客户端

182,362 msg/s (182,123)

Broker crate

177,811 msg/s (175,870)

RustStream

178,312 msg/s (176,666)

以表格显示数字

场景	裸客户端	Broker crate	RustStream	额外开销
queue, 512 B JSON, accept each	182,362 msg/s (182,123)	177,811 msg/s (175,870) （比客户端 +2.5%）	178,312 msg/s (176,666)	无法区分

代码的开销

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-amqp default (none), ruststream macros,json. ruststream-amqp 0.7.0, ruststream 0.7.0, 测量于 2026-10-18.

指令数

05万10万

内存分配

050

queue, JSON decode into a small struct, accept each

28,063.9

17.1

指令数

28,063.9

内存分配

17.1

冷启动

222,777 / 228

reply through this crate's publisher, accepted by the broker

60,353.8

46.1

指令数

60,353.8

内存分配

46.1

冷启动

238,499 / 260

queue in batches of 64, assembled on the client

28,743.1

17.4

指令数

28,743.1

内存分配

17.4

冷启动

230,614 / 232

以表格显示数字

场景	指令数	内存分配	冷启动
queue, JSON decode into a small struct, accept each	28,063.9	17.1	222,777 / 228
reply through this crate's publisher, accepted by the broker	60,353.8	46.1	238,499 / 260
queue in batches of 64, assembled on the client	28,743.1	17.4	230,614 / 232

机器

处理器	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
Broker	apache/activemq-artemis:latest-alpine in Docker on localhost
编译器	1.99.0
构建配置	bench, inheriting release (opt-level = 3, lto = fat, codegen-units = 16, debug = line-tables-only)
特性	ruststream-amqp default (none), ruststream macros,json
RUSTFLAGS	none (the recipe clears RUSTFLAGS, so the numbers are not tied to this CPU)
往返时间	52 us (median of 20000 sends waiting for their disposition)
Valgrind	3.25.1

数字来自本版本的 docs/benchmarks/results.json，由基准测试命令写入。方法论说明它们是怎样测得的，数字说明可以从中得出什么结论。