英文版本为准
本页译自英文，由模型翻译。若与英文原文存在差异，以英文原文为准。
设计
ruststream-lapin 所处的位置：位于 RustStream 运行时和 lapin 客户端之间，一个连接，每个订阅一个信道。
以文字阅读本图
- 你的服务: #[subscriber] 订阅者处理器; RustStream::new(..) .with_broker(..)
- RustStream 核心: 运行时：分发、工作分区、结算
- ruststream-lapin: LapinSubscriber 产出 LapinMessage; LapinPublisher, ConfirmsPublisher, ServerTxPublisher; LapinBroker 配置; RabbitQueue, RabbitQuorumQueue, RabbitExchange; LapinRequester
- lapin: 连接 每个 Broker 一个; 每个订阅 一个信道; 共用的发布信道； 发布者确认、事务 和请求各有自己的
- #[subscriber] 订阅者处理器 → 运行时：分发、工作分区、结算: 挂载到
- 运行时：分发、工作分区、结算 → LapinSubscriber 产出 LapinMessage: 轮询流
- LapinSubscriber 产出 LapinMessage → 每个订阅 一个信道
- LapinPublisher, ConfirmsPublisher, ServerTxPublisher → 共用的发布信道； 发布者确认、事务 和请求各有自己的
- LapinRequester → 共用的发布信道； 发布者确认、事务 和请求各有自己的
- 每个订阅 一个信道 → RabbitMQ 节点
- 共用的发布信道； 发布者确认、事务 和请求各有自己的 → RabbitMQ 节点
本 crate 在 lapin 之上实现核心的 Broker trait，lapin 是一个纯 Rust 的 AMQP 0.9.1 客户端。它上面的运行时对每个 Broker 都相同。所有 RabbitMQ 特有的内容都在本 crate 中：队列描述符、结算所发送的帧、重试的去向，以及三种发布模式。
一个 Broker 打开一个连接。每个订阅在自己的信道上消费，所以它的预取窗口和它的错误都只属于它自己。发后即忘的发布者共用一个信道。发布者确认模式的发布者、事务发布者和请求方各自在首次使用时打开自己的信道，因为确认模式、事务和回复消费者都是信道状态。
信道错误只关闭一个信道，连接保持不变。发布者的信道在下一次使用时重新打开，所以一次发往不存在的交换机的发布不会让服务停止发布。
LapinBroker 默认什么都不声明。这时描述符说明服务期望的拓扑，缺少的队列会让它的订阅失败。declare_topology(true) 让每个订阅依次声明它的交换机、队列和绑定。
请求方在 Broker 建立连接时所在的运行时上，用一个任务读取回复，与哪个线程发出第一个请求无关。