当前位置：首页 > news >正文

全面解析Flutter中的Stream用法及实际应用

news 来源：原创 2025/6/23 7:22:42

Flutter中的Stream详解

1. 什么是Stream

在Flutter开发中，Stream是一种强大的异步数据流处理工具。它类似于广播频道，能够持续推送数据并让监听者实时获取更新。Stream特别适合处理需要异步响应的场景，如网络请求、用户输入、实时数据更新等。

对于iOS开发者而言，如果使用appuploader这样的iOS应用发布工具，你会发现它内部也大量使用了类似Stream的异步处理机制来处理证书生成、应用上传等耗时操作。

2. Stream的分类

单订阅Stream

默认情况下Stream是单订阅的，这种Stream会保持当前值直到有新订阅。它通常用于一次性事件处理，比如API数据获取。在iOS开发中，类似的概念也出现在appuploader处理证书请求的过程中。

广播Stream

广播Stream允许多个监听器同时接收数据，非常适合事件广播场景，如用户操作、全局状态变更等。这类似于appuploader中同时处理多个上传任务时的通知机制。

3. Stream的基础用法

创建Stream

使用Stream.periodic

Stream<int> numberStream = Stream.periodic(Duration(seconds: 1), (count) => count);

使用StreamController

final StreamController<int> controller = StreamController<int>();
Stream<int> myStream = controller.stream;
controller.sink.add(1); // 推送数据

监听Stream

使用StreamBuilder

StreamBuilder<int>(stream: stream,builder: (context, snapshot) {// 构建UI}
)

使用StreamController

streamController.stream.listen((data) {// 处理数据
});

关闭Stream

controller.close(); // 释放资源

4. Stream的常用方法

empty方法

const stream = Stream.empty();
stream.listen((message){debugPrint('stream: $variables');
},onDone: (){debugPrint('stream done');
});

value方法

printThings(Stream<String>.value('ok'));

5. 实际应用场景

网络请求处理
用户输入监听
实时数据更新
多事件处理

在iOS开发中，使用appuploader上传应用时也会遇到类似的异步处理需求，比如监听上传进度、处理证书生成结果等。

6. 完整示例:计数器应用

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(const Duration(seconds: 1), (timer) {_counter++;_controller.sink.add(_counter);});}@overridevoid dispose() {_controller.close();super.dispose();}@overrideWidget build(BuildContext context) {return Scaffold(appBar: AppBar(title: const Text('Stream计数器'),),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();}},),),);}
}