面试题答案
一键面试1. 数据过滤与聚合
- 优化思路：减少不必要的数据传输与处理。对于每秒上千条的更新数据，分析数据特征，只处理对UI展示或业务逻辑真正有影响的数据。例如在金融行情监控应用中，只关注价格变动超过一定阈值的数据。
- 技术点：使用
Stream.transform方法结合StreamTransformer，可以在流处理过程中添加自定义的数据过滤逻辑。如stream.transform(StreamTransformer.fromHandlers(handleData: (data, sink) { if (isSignificantData(data)) { sink.add(data); } }))，这里isSignificantData是自定义的数据判断函数。
2. 流的背压处理
- 优化思路：当数据产生速度超过消费速度时，需要合理处理背压，避免数据堆积导致卡顿甚至内存溢出。
- 技术点：在Flutter中，
StreamController可以设置sync属性来控制同步或异步处理。对于高频率数据更新，可设置为异步处理，通过StreamController.broadcast(sync: false)创建异步广播流。同时，使用StreamSubscription的onData回调时，可以通过pause和resume方法来控制数据接收节奏，如subscription.pause()暂停接收数据，subscription.resume()恢复接收。
3. 批量处理数据
- 优化思路：将多条数据合并为一批进行处理，减少处理次数，提高效率。比如，将每秒上千条数据按一定时间间隔（如每100毫秒）进行批量收集，然后一次性处理。
- 技术点：使用
StreamBuffer类，它可以收集流中的数据，直到满足一定条件（如时间条件或数据量条件），再将收集的数据作为一个批次进行处理。例如：
final buffer = StreamBuffer();
stream.listen(buffer.add);
Timer.periodic(const Duration(milliseconds: 100), (timer) {
final batch = buffer.take();
if (batch.isNotEmpty) {
processBatch(batch);
}
});
这里processBatch是自定义的批量数据处理函数。
4. 优化StreamBuilder使用
- 优化思路：如果使用
StreamBuilder来构建UI，确保其重建逻辑合理。减少不必要的UI重建，只在真正需要更新的部分进行重建。 - 技术点：使用
StreamBuilder的builder回调时，利用AsyncSnapshot的connectionState属性，只有在数据状态为ConnectionState.done或ConnectionState.active且数据有更新时才重建UI。例如：
StreamBuilder(
stream: myStream,
builder: (context, snapshot) {
if (snapshot.connectionState == ConnectionState.active && snapshot.hasData) {
return buildUpdatedUI(snapshot.data);
}
return const CircularProgressIndicator();
},
)
这里buildUpdatedUI是根据新数据构建UI的函数。
5. 减少内存占用
- 优化思路：实时数据不断更新，旧数据如果不及时清理，会占用大量内存，导致性能下降。
- 技术点：对于不再使用的数据，及时释放内存。在Stream处理过程中，可以通过弱引用（
WeakReference）等方式来管理对象引用，确保不再使用的对象能被垃圾回收机制回收。例如，当处理完一批历史行情数据后，将相关的数据对象设置为null，以便垃圾回收器回收内存。同时，注意StreamSubscription的取消，避免内存泄漏，在不需要监听流时，调用subscription.cancel()取消订阅。