基准测试

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

与裸客户端对照

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

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

两个场景对应两种模型。在 Core NATS subject 上，服务器推送每条匹配的消息，不结算任何东西。在 JetStream 拉取消费者上，客户端成批请求消息，并确认每一条，路径一页用图说明了这一点。

代码的开销

第二张图统计一条消息在服务线程上的开销：稳态下 callgrind 测得的指令数和 DHAT 测得的内存分配次数。每个场景都是一个基于 NatsBroker 的服务，读取同一台服务器上的一个 JetStream 拉取消费者。服务运行在一个线程上，async-nats 的连接任务也在这个线程上运行，因此计数包括框架、本 crate 以及客户端自己在套接字上的工作。生产者的线程不计入。冷启动 是连接、查找流、创建消费者并取得第一条消息一次性付出的开销。

结果

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

裸客户端
Broker crate
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. 这些数字是怎样测得的

Core NATS, 512 B JSON

无法区分
无法区分

JetStream pull consumer, 512 B JSON, ack each

无法区分
无法区分

以表格显示数字

场景	裸客户端	Broker crate	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.

指令数

内存分配

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

8,679.9

7.1

JetStream pull consumer, reply published by NatsPublisher on Core NATS

12,165.1

11.1

JetStream fetches of 64, ack each

8,469.6

6.4

以表格显示数字

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

与裸客户端对照​

代码的开销​

结果​

机器​

与裸客户端对照

代码的开销

结果

机器