Flutter如何使用mqtt_client插件

我在Flutter项目中使用mqtt_client插件时遇到了一些问题。具体是在连接MQTT服务器时总是失败，错误提示是"Connection failed"。我的代码基本按照官方文档写的，但不知道哪里出了问题。想请教一下：

  1. 连接MQTT服务器最基本的正确代码示例是怎样的？
  2. 常见的连接失败原因有哪些？该如何排查？
  3. 是否需要额外配置Android/iOS的权限或网络设置？
    希望有经验的朋友能分享一下具体实现步骤和注意事项。
2 回复

在Flutter中使用mqtt_client插件，首先在pubspec.yaml中添加依赖：

dependencies:
  mqtt_client: ^9.0.0

然后运行flutter pub get。

基本使用步骤：

  1. 创建客户端：MqttClient client = MqttClient('broker-url', '')
  2. 连接：await client.connect()
  3. 订阅主题：client.subscribe('topic', MqttQos.atMostOnce)
  4. 监听消息：client.updates!.listen((List<MqttReceivedMessage> c) {...})
  5. 发布消息：client.publishMessage('topic', MqttQos.atMostOnce, message)

记得处理连接状态和异常。

更多关于Flutter如何使用mqtt_client插件的实战系列教程也可以访问 https://www.itying.com/category-92-b0.html


Flutter 使用 mqtt_client 插件的步骤如下：

  1. 添加依赖
    在 pubspec.yaml 中添加：

    dependencies:
  mqtt_client: ^9.6.3

    运行 flutter pub get 安装。

  2. 基本连接配置

    import 'package:mqtt_client/mqtt_client.dart';

final client = MqttClient('tcp://broker.hivemq.com', 'flutter_client');
client.port = 1883; // 默认端口（无SSL）

  3. 建立连接

    try {
  await client.connect();
  print('连接成功');
} catch (e) {
  print('连接失败: $e');
}

  4. 订阅主题

    const topic = 'test/topic';
client.subscribe(topic, MqttQos.atMostOnce);

  5. 接收消息

    client.updates!.listen((List<MqttReceivedMessage<MqttMessage>> messages) {
  final msg = messages[0].payload as MqttPublishMessage;
  final payload = MqttPublishPayload.bytesToStringAsString(msg.payload.message);
  print('收到消息: $payload');
});

  6. 发布消息

    final builder = MqttClientPayloadBuilder();
builder.addString('Hello MQTT');
client.publishMessage(topic, MqttQos.atMostOnce, builder.payload!);

  7. 断开连接

    client.disconnect();

注意事项：

  • 使用 MqttQos 控制消息质量（0/1/2）。
  • 生产环境建议启用SSL（端口8883）。
  • 处理连接状态变化可通过 client.connectionStatus 监听。

完整示例可参考 mqtt_client文档。

回到顶部