路径

一条 Pulsar 消息在 RustStream 服务中的路径：消费者、驱动任务、处理器、应答和确认。

以文字阅读本图

1. 客户端消费者 在流量许可内推送来的消息 → PulsarMessage，由驱动任务构建 载荷复制进 Bytes
2. PulsarMessage，由驱动任务构建 载荷复制进 Bytes → 分发 一个循环，或每个键一个工作分区
3. 分发 一个循环，或每个键一个工作分区 → 解码 从复制出的载荷读取
4. 解码 从复制出的载荷读取 → 订阅者的处理器 #[subscriber] 下的 async fn
5. 订阅者的处理器 #[subscriber] 下的 async fn → 应答 编码进交给客户端的缓冲区
6. 应答 编码进交给客户端的缓冲区 → PulsarPublisher 主题的生产者，等待回执
7. PulsarPublisher 主题的生产者，等待回执 → 结算 发给驱动任务
8. 结算 发给驱动任务 → 确认 写入连接，没有应答

客户端消费者持有 Broker 在流量许可范围内预先推送来的消息。订阅的驱动任务取出下一条，构建一个 PulsarMessage：它把载荷复制进一个 Bytes，保留主题名和消息 id（处理器通过它的上下文读取这两者），并把消息属性转换为消息头。消息的分区键变成 partition-key 消息头，工作分区读取的就是它。投递在一个容量为 16 的通道中等待，直到分发循环取走它。

处理器的应答编码进一个缓冲区，发布者把这个缓冲区交给客户端，不做复制。超过 max_message_size 的载荷在发送之前就会失败：客户端不检查大小，而服务器遇到过大的消息会断开整个连接。Broker 存储了消息并发回回执之后，发布才返回。应答发布失败时，这次投递以重试的方式结算。

投递在应答之后结算。结算回到驱动任务，由它交给客户端，客户端把它放入队列后调用即返回。客户端把确认写入连接，不等待任何应答。

基准测试统计这条路径在每条消息上的开销，以及其中有多少属于客户端。