2.3.2 流处理