6.2.4 构建实时流处理服务