安装
npm install stream
yarn add stream
pnpm add stream
bun add stream
README
相关教程
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 实现任务队列。