Flutter Bloc：无Context时类中调用事件失败及初始化问题

在SocketRepository类中需要触发ChatBloc的事件，但没有Context可以获取Bloc实例。尝试用late声明ChatBloc但未初始化，导致报错：Unhandled Exception: LateInitializationError: Field 'chatbloc' has not been initialized。

相关代码：

SocketRepository 原代码 #

class SocketRepository {
  ...
  socket.on('receive_message', (jsonData) => {
    print('****** receive message called $jsonData'),
    // 需要触发ChatBloc事件，但没有Context
  });
  ...
}

ChatBloc 定义 #

class ChatBloc extends Bloc<ChatEvent, ChatState> {
  final DatabaseRepository _databaseRepository;
  final SocketRepository _socketRepository;
  
  ChatBloc(this._databaseRepository, this._socketRepository) : super(ChatInitial()) {
    on<LoadChat>((event, emit) async {
      // ...
    });
  }
}

错误尝试代码 #

class SocketRepository {
  late ChatBloc chatbloc;
  ...
  socket.on('receive_message', (jsonData) => {
    chatbloc.add(ReceiveMessage()),
    // ...
  });
}

核心问题是循环依赖：ChatBloc已依赖SocketRepository，若让SocketRepository直接反向依赖ChatBloc，会导致初始化死循环。推荐以下解耦方式实现需求：

方法1：使用回调函数解耦 #

在SocketRepository中定义消息接收回调，收到消息时触发回调；在ChatBloc初始化时注册该回调，内部触发Bloc事件。

修改SocketRepository #

class SocketRepository {
  // 定义消息接收回调
  Function(Map<String, dynamic>)? onMessageReceived;

  ...
  
  void initSocket() {
    socket.on('receive_message', (jsonData) {
      print('****** receive message called $jsonData');
      // 调用回调传递消息
      onMessageReceived?.call(jsonData);
    });
  }
}

修改ChatBloc #

class ChatBloc extends Bloc<ChatEvent, ChatState> {
  final DatabaseRepository _databaseRepository;
  final SocketRepository _socketRepository;
  
  ChatBloc(this._databaseRepository, this._socketRepository) : super(ChatInitial()) {
    // 注册Socket消息回调
    _socketRepository.onMessageReceived = (jsonData) {
      // 触发Bloc事件
      add(ReceiveMessage(jsonData));
    };
    
    on<LoadChat>((event, emit) async {
      // ...
    });
    
    // 处理ReceiveMessage事件
    on<ReceiveMessage>((event, emit) async {
      // 编写消息处理逻辑
    });
  }
}

方法2：使用Stream解耦 #

让SocketRepository暴露消息Stream，ChatBloc监听该Stream，收到消息时自动触发事件。这种方式更符合响应式编程思想，耦合度更低。

修改SocketRepository #

class SocketRepository {
  final _messageStreamController = StreamController<Map<String, dynamic>>.broadcast();
  
  // 对外暴露消息Stream
  Stream<Map<String, dynamic>> get messageStream => _messageStreamController.stream;

  ...
  
  void initSocket() {
    socket.on('receive_message', (jsonData) {
      print('****** receive message called $jsonData');
      // 将消息加入Stream
      _messageStreamController.add(jsonData);
    });
  }

  // 销毁时关闭StreamController，避免内存泄漏
  void dispose() {
    _messageStreamController.close();
  }
}

修改ChatBloc #

class ChatBloc extends Bloc<ChatEvent, ChatState> {
  final DatabaseRepository _databaseRepository;
  final SocketRepository _socketRepository;
  late StreamSubscription _messageSubscription;
  
  ChatBloc(this._databaseRepository, this._socketRepository) : super(ChatInitial()) {
    // 监听Socket的消息Stream
    _messageSubscription = _socketRepository.messageStream.listen((jsonData) {
      add(ReceiveMessage(jsonData));
    });
    
    on<LoadChat>((event, emit) async {
      // ...
    });
    
    on<ReceiveMessage>((event, emit) async {
      // 编写消息处理逻辑
    });
  }

  // 销毁Bloc时取消Stream订阅
  @override
  Future<void> close() {
    _messageSubscription.cancel();
    return super.close();
  }
}

不推荐方法：全局BlocProvider（耦合度高） #

若一定要直接在SocketRepository中获取ChatBloc实例，可使用全局BlocProvider，但会增加代码耦合度，不利于维护：

class SocketRepository {
  ...
  socket.on('receive_message', (jsonData) {
    print('****** receive message called $jsonData');
    // 通过全局Context获取Bloc（需确保App顶层已注入ChatBloc）
    final chatBloc = BlocProvider.of<ChatBloc>(globalContext);
    chatBloc.add(ReceiveMessage(jsonData));
  });
}

注意：需提前在App顶层通过BlocProvider注入ChatBloc，还要处理Context为空的情况，大型项目不建议使用。

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