FirebaseMessaging.onMessage监听中StreamController无法正常工作

核心原因 #

你在initState中创建了新的NotificationService实例，而监听FirebaseMessaging.onMessage的是另一个独立实例，两个实例的_streamController完全隔离，导致消息无法跨实例传递。

解决方案 #

1. 将NotificationService改为单例模式 #

确保整个应用内只有一个NotificationService实例，让_streamController全局共享：

class NotificationService {
  // 单例实例
  static final NotificationService _instance = NotificationService._internal();
  
  // 工厂构造函数返回单例
  factory NotificationService() => _instance;
  
  NotificationService._internal();
  
  // 用broadcast流支持多订阅者（推荐）
  final StreamController<RemoteMessage> _streamController = StreamController.broadcast();

  Stream<RemoteMessage> notificationStream() {
    return _streamController.stream;
  }

  // 统一初始化Firebase消息监听
  void initFirebaseListener() {
    FirebaseMessaging.onMessage.listen((message) {
      _streamController.add(message);
      print(message.notification?.body ?? 'empty body');
    });
  }

  // 释放资源避免内存泄漏
  void dispose() {
    _streamController.close();
  }
}

2. 全局初始化消息监听 #

在应用启动时完成Firebase监听的初始化，确保监听和页面使用同一个实例：

void main() async {
  WidgetsFlutterBinding.ensureInitialized();
  await Firebase.initializeApp();
  // 初始化消息监听
  NotificationService().initFirebaseListener();
  runApp(const MyApp());
}

3. 修改页面流获取逻辑 #

页面中使用单例实例的流，保证和监听用的是同一个_streamController：

class _HomePageState extends State<HomePage> {
  late Stream<RemoteMessage> _stream;
  
  @override
  void initState() {
    _stream = NotificationService().notificationStream();
    super.initState();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: const Text('Home')),
      body: StreamBuilder(
        stream: _stream,
        builder: (context, snapshot) {
          if (snapshot.hasData) {
            return Text(snapshot.data!.notification?.body ?? 'empty body');
          }
          return const Text('empty snapshot');
        },
      ),
    );
  }
}

额外提示 #

• 若需要多个组件监听消息，必须用StreamController.broadcast()，普通StreamController仅支持单个订阅者。
• 在应用生命周期结束时，记得调用NotificationService().dispose()关闭流，防止内存泄漏。

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