stream@0.0.1

Protocol Buffers gRPC 双向流

gRPC 双向流客户端和服务端独立读写适合实时通信。StreamObserver 回调处理。gRPC 内部流控窗口。本文实现聊天消息双向流。

Flutter BLoC 状态管理

Flutter BLoC 用事件触发状态变更 StreamBuilder 响应更新。BlocProvider 提供全局实例。适合复杂业务状态管理。本文实现登录流程 BLoC。

Apache Spark Structured Streaming

Spark Structured Streaming 用 DataFrame 做流处理支持事件时间和 Watermark。微批处理默认连续处理可选。适合实时 ETL 和监控。本文用 Spark 实时计算 PV。

MongoDB Change Streams 订阅变更

MongoDB Change Streams 监听集合的 INSERT/UPDATE/REPLACE 事件返回变更数据。基于 oplog。适合实时同步和通知。本文监听订单集合变更触发通知。

Redis 流 Stream 实现消息队列

Redis Stream 支持消息持久化和消费者组。XADD 添加 XREADGROUP 读取。ACK 确认已处理。适合轻量消息队列场景。本文用 Stream 实现任务队列。