Flutter Riverpod中ChangeNotifierProvider监听失效问题求助

核心问题分析 #

• notifyListeners()调用时机错误：当前仅在subscribePusher()初始化时调用了一次notifyListeners()，但Pusher收到事件时没有触发该方法，导致Riverpod无法感知Controller的状态变化。
• 未执行事件订阅：Provider初始化链中缺少subscribePusher()调用，Pusher事件绑定逻辑根本没执行。
• 页面监听逻辑有误：直接通过ref.watch获取eventStream无法触发Widget重建，因为ref.watch(pusherProvider)监听的是ChangeNotifier的状态更新，需要依赖notifyListeners()触发；若要处理流数据，需结合StreamBuilder。

修复步骤 #

1. 修正Pusher事件回调的状态通知 #

在Pusher收到事件时调用notifyListeners()，让Riverpod感知状态变化：

channel.bind(eventName, (PusherEvent? event) {
  debugPrint("xxxxxxxxx From pusher xxxxxxxxx");
  _inEventData.add(event!.data);
  prevChannelName = eventName;
  notifyListeners(); // 新增此行，触发Riverpod状态更新
});

2. 补全Provider初始化的订阅调用 #

修改Provider定义，加入事件订阅逻辑：

final pusherProvider= ChangeNotifierProvider<PusherController>((ref) => PusherController.instance
  ..setEventName('my-event')
  ..setChannelName('my-channel')
  ..initPusher()
  ..connectPusher()
  ..subscribePusher()); // 新增订阅调用

3. 调整页面监听逻辑 #

推荐两种实现方式：

方式一：结合ref.watch与StreamBuilder

用ref.watch感知Controller状态变化，同时用StreamBuilder处理事件流：

@override
Widget build(BuildContext context, WidgetRef ref) {
  final pusherController = ref.watch(pusherProvider);
  
  return StreamBuilder<String>(
    stream: pusherController.eventStream,
    builder: (context, snapshot) {
      if (snapshot.hasData) {
        debugPrint('received data: ${snapshot.data}');
        return Text('Received: ${snapshot.data}');
      }
      return const Text('Waiting for events...');
    },
  );
}

方式二：直接通过ref.read监听流

若无需依赖Controller的其他状态，可直接获取流并监听：

@override
Widget build(BuildContext context, WidgetRef ref) {
  final eventStream = ref.read(pusherProvider).eventStream;
  
  return StreamBuilder<String>(
    stream: eventStream,
    builder: (context, snapshot) {
      if (snapshot.hasData) {
        debugPrint('received data: ${snapshot.data}');
        return Text('Received: ${snapshot.data}');
      }
      return const Text('Waiting for events...');
    },
  );
}

额外优化：单例与Riverpod的兼容性 #

当前单例模式虽能运行，但Riverpod更推荐由Provider管理实例生命周期，可移除单例逻辑：

// 修改PusherController
class PusherController extends ChangeNotifier{
  // 移除单例相关代码
  PusherController();

  // 其余方法保持不变
}

// 修改Provider定义
final pusherProvider= ChangeNotifierProvider<PusherController>((ref) {
  final controller = PusherController();
  controller
    ..setEventName('my-event')
    ..setChannelName('my-channel')
    ..initPusher()
    ..connectPusher()
    ..subscribePusher();
  return controller;
});

这样能更好地利用Riverpod的生命周期管理，避免单例可能导致的状态不一致问题。

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