Flutter中StreamBuilder无法更新Firestore数据问题求助

你当前的代码中，_uid和_usersStream是在State类实例化时就固定赋值的，切换用户后这个State并未被重建，导致Stream始终监听着上一个用户的Firestore数据，因此页面会显示旧内容。给StreamBuilder加Key无法解决问题，因为Stream本身没有更新。

以下两种方法都能解决用户切换后的数据更新问题：

方法一：监听Auth状态变化动态更新Stream #

通过监听FirebaseAuth的用户状态变化，在用户登录/切换时重新创建对应的Firestore流：

class UserInformation extends StatefulWidget {
  @override
  _UserInformationState createState() => _UserInformationState();
}

class _UserInformationState extends State<UserInformation> {
  StreamSubscription? _authSubscription;
  Stream<QuerySnapshot>? _usersStream;

  @override
  void initState() {
    super.initState();
    // 监听用户登录状态变化
    _authSubscription = FirebaseAuth.instance.authStateChanges().listen((user) {
      setState(() {
        if (user != null) {
          // 用户登录/切换时，更新Firestore流
          _usersStream = FirebaseFirestore.instance
              .collection('Users')
              .doc(user.uid)
              .collection('UserData')
              .snapshots();
        } else {
          // 用户退出，清空流
          _usersStream = null;
        }
      });
    });
  }

  @override
  void dispose() {
    _authSubscription?.cancel(); // 取消订阅避免内存泄漏
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    if (_usersStream == null) {
      return const Text("请登录");
    }

    return StreamBuilder<QuerySnapshot>(
      stream: _usersStream,
      builder: (BuildContext context, AsyncSnapshot<QuerySnapshot> snapshot) {
        if (snapshot.hasError) {
          return const Text('Something went wrong');
        }

        if (snapshot.connectionState == ConnectionState.waiting) {
          return const Text("Loading");
        }

        return ListView(
          children: snapshot.data!.docs
              .map((DocumentSnapshot document) {
                Map<String, dynamic> data =
                    document.data()! as Map<String, dynamic>;
                return ListTile(
                  title: Text(data['full_name']),
                  subtitle: Text(data['company']),
                );
              })
              .toList()
              .cast(),
        );
      },
    );
  }
}

方法二：通过父组件传递用户并利用didUpdateWidget更新流 #

让父组件监听用户状态，将当前用户传递给UserInformation，并在用户变化时更新流：

父组件代码 #

StreamBuilder<User?>(
  stream: FirebaseAuth.instance.authStateChanges(),
  builder: (context, snapshot) {
    if (snapshot.hasData) {
      return UserInformation(
        key: Key(snapshot.data!.uid), // 用户切换时强制重建组件
        user: snapshot.data!,
      );
    } else {
      return LoginPage();
    }
  },
)

UserInformation组件修改 #

class UserInformation extends StatefulWidget {
  final User user;
  const UserInformation({super.key, required this.user});

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

class _UserInformationState extends State<UserInformation> {
  late Stream<QuerySnapshot> _usersStream;

  @override
  void initState() {
    super.initState();
    _initUserStream();
  }

  // 初始化用户数据Stream
  void _initUserStream() {
    _usersStream = FirebaseFirestore.instance
        .collection('Users')
        .doc(widget.user.uid)
        .collection('UserData')
        .snapshots();
  }

  // 当组件接收的user参数变化时，更新Stream
  @override
  void didUpdateWidget(covariant UserInformation oldWidget) {
    super.didUpdateWidget(oldWidget);
    if (oldWidget.user.uid != widget.user.uid) {
      setState(() {
        _initUserStream();
      });
    }
  }

  @override
  Widget build(BuildContext context) {
    return StreamBuilder<QuerySnapshot>(
      stream: _usersStream,
      builder: (BuildContext context, AsyncSnapshot<QuerySnapshot> snapshot) {
        if (snapshot.hasError) {
          return const Text('Something went wrong');
        }

        if (snapshot.connectionState == ConnectionState.waiting) {
          return const Text("Loading");
        }

        return ListView(
          children: snapshot.data!.docs
              .map((DocumentSnapshot document) {
                Map<String, dynamic> data =
                    document.data()! as Map<String, dynamic>;
                return ListTile(
                  title: Text(data['full_name']),
                  subtitle: Text(data['company']),
                );
              })
              .toList()
              .cast(),
        );
      },
    );
  }
}

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