异步流处理

java 框架实现异步流处理：使用 rxjava 创建可观测对象，表示数据流。订阅并观察可观测对象以接收流元素。利用 rxjava 运算符转换和处理流，例如映射、过滤和归约。通过案例演示异步流处理，如实时统计网站流量，包括日志收集、数据转换