英文版本为准
本页译自英文，由模型翻译。若与英文原文存在差异，以英文原文为准。
管道
stdio 客户端在一个线程上读取标准输入，在另一个线程上写入标准输出，每条消息一行，整个进程共用。
以文字阅读本图
- 上一级 → stdin 线程 读取并解析一行: 行
- stdin 线程 读取并解析一行 → 按流键分发： 没有键的行 发给每个消费者
- 按流键分发： 没有键的行 发给每个消费者 → StdioConsumer 每个订阅一个
- StdioPublisher 需要时套上信封 → stdout 线程 编号，打时间戳
- stdout 线程 编号，打时间戳 → [time | key | seq] payload
- [time | key | seq] payload → 下一级
- stdout 线程 编号，打时间戳 → 按流键分发： 没有键的行 发给每个消费者
- 每个进程一个 stdin 线程和一个 stdout 线程： 关闭会结束其中的每个 stdio 流
一行的形式是 [timestamp | stream_key | sequence | shard_id] payload，方括号中的每个字段都是可选的。时间戳的格式为 YYYY-MM-DDTHH:MM:SS，允许带秒的小数部分。以 [WORD] 开头的行，读作流键为 WORD 的消息。
第一个订阅启动 stdin 线程。该线程读取一行，解析它的字段，然后交给该键的消费者。没有键的行发给每个消费者。因此，上一级标准输出上的一行杂散输出，会到达本级的每个订阅。本级启动时，本 crate 会扣住标准输入，直到它的第一个消费者出现，所以已经在等待的行不会丢失。
第一次发布启动 stdout 线程。它为每个键从零开始编号，以秒为精度打上写入时间，然后输出这一行。它会跳过空载荷，因此发布者拒绝空消息，而不是报告一行从未发出的内容。一行会改变的载荷放进信封。
虚线箭头是 loopback：stdout 线程还把每一行交给本进程自己的消费者。这样，一个 stdio 服务可以在一个进程里运行，测试正是这样做的。
两个线程都属于进程，而不属于某个 Broker。关闭会在每个订阅交付完已读取的行之后，结束进程持有的每个 stdio 消费者和生产者。标准输入结束时，stdin 线程停止，订阅仍保持打开。一行不是 UTF-8，或者方括号部分无法解析，都会使进程中止。