Flutter StreamBuilder无法更新内部Stateful/StatelessWidget问题求助

你自定义的StatefulWidget存在参数使用错误：

• State子类的构造方法仅会在组件第一次创建挂载时执行一次，你在_Test的构造方法中手动存储了父组件传入的chat_room_object和message_object，后续StreamBuilder触发刷新传入新参数时，State类中存储的旧参数不会自动更新，因此界面不会刷新。
• Flutter的State类自带widget属性，可直接访问父组件传入的最新参数，无需手动存储副本。

你只需要修改自定义Test组件的实现即可，无需调整StreamBuilder部分的逻辑：

// 修复后的Test组件
class Test extends StatefulWidget {
  // 建议给参数指定明确类型，此处按原有逻辑保留dynamic也可正常运行
  final dynamic chat_room_object;
  final dynamic message_object;
  const Test(this.chat_room_object, this.message_object, {Key? key})
      : super(key: key);

  @override
  _Test createState() => _Test();
}

class _Test extends State<Test> {
  // 删除State构造方法中手动接收、存储参数的逻辑，直接通过widget访问父组件传参
  @override
  Widget build(BuildContext context) {
    return ListView.builder(
      itemCount: widget.message_object.length,
      itemBuilder: (context, i) {
        return Text(widget.message_object[i].message.toString());
      },
    );
  }

  // 如果需要在参数更新时执行额外逻辑（比如新消息到来滚动到底部），可重写didUpdateWidget生命周期
  @override
  void didUpdateWidget(covariant Test oldWidget) {
    super.didUpdateWidget(oldWidget);
    if (oldWidget.message_object.length != widget.message_object.length) {
      // 此处写自定义逻辑即可
      debugPrint("消息列表已更新");
    }
  }
}

以下是脱离Firebase依赖的本地测试示例，可直接运行验证效果：

import 'dart:async';
import 'package:flutter/material.dart';

void main() => runApp(const MyApp());

class MyApp extends StatelessWidget {
  const MyApp({super.key});

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(title: const Text('StreamBuilder嵌套StatefulWidget示例')),
        body: const StreamTestPage(),
      ),
    );
  }
}

class StreamTestPage extends StatefulWidget {
  const StreamTestPage({super.key});

  @override
  State<StreamTestPage> createState() => _StreamTestPageState();
}

class _StreamTestPageState extends State<StreamTestPage> {
  // 模拟每秒新增一条消息的Stream
  final StreamController<List<String>> _messageController = StreamController();
  final List<String> _messageList = [];

  @override
  void initState() {
    super.initState();
    Timer.periodic(const Duration(seconds: 1), (timer) {
      _messageList.add('消息${_messageList.length + 1}');
      _messageController.add(List.from(_messageList));
      if (_messageList.length >= 10) timer.cancel();
    });
  }

  @override
  void dispose() {
    _messageController.close();
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return StreamBuilder<List<String>>(
      stream: _messageController.stream,
      builder: (context, snapshot) {
        if (!snapshot.hasData) return const Center(child: CircularProgressIndicator());
        return MessageList(messageList: snapshot.data!);
      },
    );
  }
}

// 嵌套的StatefulWidget
class MessageList extends StatefulWidget {
  final List<String> messageList;
  const MessageList({super.key, required this.messageList});

  @override
  State<MessageList> createState() => _MessageListState();
}

class _MessageListState extends State<MessageList> {
  @override
  Widget build(BuildContext context) {
    // 直接通过widget.messageList访问最新参数
    return ListView.builder(
      itemCount: widget.messageList.length,
      itemBuilder: (context, index) {
        return ListTile(title: Text(widget.messageList[index]));
      },
    );
  }
}

内容的提问来源于stack exchange，提问作者user16754196