Flutter Bloc中第二个事件无法访问首个事件初始化的_client问题

问题场景 #

你创建了包含两个事件的Bloc，点击第一个按钮触发<MqttConnectEvent>初始化MqttServerClient类，但触发<PublishEvent>时尝试使用该类对象却抛出空指针错误。相关代码如下：

class MyBloc extends Bloc<MqttEvents, MqttState> {
  MqttServerClient? _client;
  MyBloc() : super(MqttInitialState()) {

    on<MqttConnectEvent> ((event, emit) async {
      
      _client = MqttServerClient.withPort('', '',);
      _client!.logging(on: true);
    
    } on Exception catch (e) {
      print('EXAMPLE::client exception - $e');
      _client!.disconnect();
      exit(-1);
    }

    });

    on<PublishEvent>((event, emit) async {
      
      final MqttClientPayloadBuilder builder = MqttClientPayloadBuilder();
      builder.addString(event.message.toString());
      _client!.publishMessage("flutter/test", MqttQos.exactlyOnce, builder.payload!);
      // 该行抛出空指针错误
    });
  }
}

解决方案 #

1. 确保先触发连接事件再执行发布操作

空指针的核心原因之一是PublishEvent触发时，_client还未被初始化（用户没先点击连接按钮）。可以在UI层做限制：

• 未连接时禁用发布按钮
• 点击发布按钮前先检查Bloc的当前状态，若未连接则提示用户

2. 在PublishEvent中安全处理空值

不要直接用!强制解包_client，而是通过条件判断规避空指针：

on<PublishEvent>((event, emit) async {
  if (_client == null) {
    emit(MqttErrorState('请先连接MQTT服务器'));
    print('错误：未连接MQTT服务器');
    return;
  }

  final MqttClientPayloadBuilder builder = MqttClientPayloadBuilder();
  builder.addString(event.message.toString());
  _client!.publishMessage("flutter/test", MqttQos.exactlyOnce, builder.payload!);
});

3. 完善连接事件的错误处理逻辑

原代码的异常捕获逻辑存在问题，需要将初始化和连接逻辑包裹在try块中，确保初始化失败时重置_client并通知UI：

on<MqttConnectEvent> ((event, emit) async {
  try {
    // 补充正确的服务器地址和端口
    _client = MqttServerClient.withPort('your-mqtt-server', 1883);
    _client!.logging(on: true);
    
    // 补充MQTT连接逻辑
    await _client!.connect();
    emit(MqttConnectedState()); // 连接成功后更新状态
  } on Exception catch (e) {
    print('EXAMPLE::client exception - $e');
    _client?.disconnect();
    _client = null; // 重置client避免后续错误使用
    emit(MqttErrorState('连接失败：$e'));
    // 避免直接调用exit(-1)，改用状态通知UI处理
  }
});

4. 通过状态管理同步连接状态

定义完整的状态类，让Bloc通过状态通知UI当前连接状态，从根源上避免非法操作：

abstract class MqttState {}
class MqttInitialState extends MqttState {}
class MqttConnectedState extends MqttState {}
class MqttDisconnectedState extends MqttState {}
class MqttErrorState extends MqttState {
  final String message;
  MqttErrorState(this.message);
}

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