目录
前言
1. 什么是Stream？
2. Stream的分类
1.单订阅Stream
2.广播Stream (Broadcast Stream)：
3. Stream的基础用法
1.创建
1.使用Stream.periodic
2.使用StreamController
2.监听
3.关闭Stream
4.Stream 转换与处理
1.map
2.asyncMap
5.实际应用场景
6.完整示例:计数器应用
前言
1. 什么是Stream？
在 Flutter 中，Stream 是一种用于处理异步数据流的工具。它的作用类似广播频道，允许连续推送数据流，并让其他部分实时监听这些数据。Stream 广泛应用于需要异步处理的场景，比如网络请求、用户输入、数据流实时更新等。
2. Stream的分类
在 Flutter 中，Stream 分为两类：
1.单订阅Stream
单订阅Stream(Single-Subscription Stream)一次只能有一个监听器（listener）。
通常用于一次性的事件，比如从 API 获取数据。
2.广播Stream (Broadcast Stream)：
广播(Broadcast Stream)允许多个监听器，可以同时向多个订阅者推送数据。
这种类型适合用于事件广播，比如用户操作、全局数据推送等。
3. Stream的基础用法
1.创建
可以使用 Stream 的构造方法，也可以通过 StreamController 自定义数据流。
1.使用Stream.periodic
我们可以使用Stream.periodic定时生成数据流:
Stream<int> numberStream = Stream.periodic(Duration(seconds: 1), (count) => count);
2.使用StreamController
Flutter还可以使用StreamController手动推送数据。
final StreamController<int> controller = StreamController<int>();
Stream<int> myStream = controller.stream;
controller.sink.add(1); // 推送数据
2.监听
使用 listen 方法可以轻松监听 Stream 的数据变化。
myStream.listen((data) {
print('Received: $data');
});
3.关闭Stream
使用 StreamController 时，在不再需要时调用 close 方法来释放资源，防止内存泄漏。
controller.close();
4.Stream 转换与处理
Stream 提供了许多用于数据流转换和处理的方法，比如 map、where、asyncMap 等。可以使用这些方法高效地处理流数据。
1.map
用于将数据流的每个元素映射成不同的值。
myStream.map((value) => value * 2).listen((data) {
print('Mapped Value: $data');
});
2.asyncMap
用于异步处理每个数据元素。
myStream.asyncMap((value) async {
return await Future.delayed(Duration(seconds: 1), () => value * 2);
}).listen((data) {
print('Async Mapped Value: $data');
});
5.实际应用场景
Flutter中Stream的应用场景如下：
- 网络请求：使用 Stream 可以轻松处理 HTTP 请求响应，尤其适合需要连续多次请求的场景。
- 用户输入监听：监听用户输入变化，比如搜索框的输入变化。
- 实时数据更新：比如股票、天气、聊天应用等需要实时数据推送的场景。
- 多事件处理：多个监听器同时监听并响应同一个事件源，比如按钮点击。
6.完整示例:计数器应用
下面是一个简单的计数器应用示例，展示了 Stream 在应用中如何工作：
import 'dart:async';import 'package:flutter/material.dart';class StreamMainPage extends StatefulWidget {const StreamMainPage({super.key,});@overrideState<StreamMainPage> createState() => _StreamMainPageState();
}class _StreamMainPageState extends State<StreamMainPage> {final StreamController<int> _controller = StreamController<int>();int _counter = 0;@overridevoid initState() {super.initState();// 使用 Timer.periodic 定时自增计数器Timer.periodic(const Duration(seconds: 1), (timer) {_counter++;_controller.sink.add(_counter);});}@overridevoid dispose() {_controller.close(); // 关闭 Stream 防止内存泄漏super.dispose();}@overrideWidget build(BuildContext context) {return Scaffold(appBar: AppBar(backgroundColor: Colors.purple,title: const Text('Stream用法',style: TextStyle(color: Colors.white,fontWeight: FontWeight.bold,fontSize: 16),),),body: Center(child: StreamBuilder<int>(stream: _controller.stream,builder: (context, snapshot) {if (snapshot.hasData) {return Text('Counter: ${snapshot.data}',style: const TextStyle(fontSize: 24));} else {return const CircularProgressIndicator();}},),),);}
}
7.总结
在 Flutter 中，Stream 是一种处理异步事件流的利器，适用于需要实时推送和监听数据的场景。通过 Stream 可以实现高效的数据流处理和转换，尤其适合需要异步响应的 UI 场景。在实际应用中，合理使用 Stream 可以使代码更加简洁和高效，也能够极大地改善用户体验。
