Flutter 集成Mqtt协议并接收服务端主动推送的消息 （无证书）

MQTT 是一种基于发布/订阅模式的轻量级物联网消息传输协议 ，可在严重受限的硬件设备和低带宽、高延迟的网络上实现稳定传输。它凭借简单易实现、支持 QoS、报文小等特点，占据了物联网协议的半壁江山。

本文主要介绍如何在 Flutter 项目中使用 MQTT，实现客户端与 MQTT 服务器的连接、订阅、取消订阅、收发消息等功能。

第一步，pub插件市场找到mqtt_client,并在yaml中引入，我此时的版本是9.0.0（坑爹的是我4.8号早上引入的是9.0.0，下午他9.1.0就更新了）

dependencies:
  flutter:
    sdk: flutter
  mqtt_client: ^9.0.0

第二步，拿到server、port、身份识别、用户名、密码等参数（向服务端要），通过withPort获取mqtt对象：

注意这个身份标识很重要，如果你要订阅多个主题，身份标识一致的话会覆盖之前的订阅，所以尽可能要保证身份标识是不一样的

 //自定义端口可以调用 MqttClient.withPort(服务器地址, 身份标识, 端口号);
  final client = MqttServerClient.withPort('server', 'client', port);

第三步，初始化mqtt连接配置

  ///初始化mqtt链接配置
  Future<void> initClient() async {
    client.logging(on: true); //是否开启日志
    client.keepAlivePeriod = 20; //设置超时时间
    // client.port=30083;
    try {
      await client.connect(username, password); //开始连接
      print('EXAMPLE::Mosquitto client connected');
    } on Exception catch (e) {
      client.disconnect();
    }
    if (client.connectionStatus.state == MqttConnectionState.connected) {
      //检查连接结果
      print('EXAMPLE::Mosquitto client connected');
    } else {
      client.disconnect();
      //exit(-1);
    }

    client.subscribe(topic1, MqttQos.atMostOnce);
    client.subscribe(topic2, MqttQos.atMostOnce);
    //监听服务器发来的信息
    client.updates.listen((List<MqttReceivedMessage<MqttMessage>> c) {
      final MqttPublishMessage recMess = c[0].payload as MqttPublishMessage;
      //服务器返回的数据信息
      final String pt =
          MqttPublishPayload.bytesToStringAsString(recMess.payload.message);
      log('订阅的主题-------------${c[0].topic}');
      log('服务器返回的数据信息-------------$pt');
      final payloadModel =
          PayLoadModel.fromJson(jsonDecode(pt) as Map<String, dynamic>);
      final topicArr = c[0].topic.split('/');
      final id = topicArr[2];
      getDeviceDetail(id, payloadModel);
    });
  }

如果在日志输出台看到如下显示，则代表连接成功，此时等待服务端推送消息即可，：

EXAMPLE::Mosquitto client connected

我这边收到服务端推送消息打印如下：

我这边服务端返回如下，拿到数据后就可以自行处理数据了。

tips:

订阅主题的理解：我理解主题就是跟后台商量的一个规则，你把对应的规则订阅后，后台根据你订阅的规则，主动推送给你符合规则要求的数据，并且此处可以订阅多次，比如我这里的需求是订阅消息上线与下线，我就写了两个主题，并suscribe了两次，对于主题的更深入理解，可以点击这里。对Mqtt协议的更多了解，可以点击这里