3.3 采用CompletableFuture实现单节点流处理