Flutter MQTT通信插件zyg_mqtt_plugin的使用

zyg_mqtt_plugin

这是中裕冠的MQTT插件。

使用步骤

安装

在项目的pubspec.yaml文件中添加以下依赖：

dependencies:
  zyg_mqtt_plugin: ^0.0.2

引入

在需要使用该插件的地方引入：

import 'package:zyg_mqtt_plugin/zyg_mqtt_plugin.dart';

1. 挂载 ZygMqttWidget()

示例代码如下：

Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: const Text('Plugin example app'),
        ),
        body: Center(
          child: Stack(
            children: [
              ZygMqttWidget(),
            ],
          ),
        ),
      ),
    );
}

2. 配置（必须先配置，再去连接）

// 先配置，再去连接
const productKey = 'a1WPnByrqko'; // 产品密钥
const deviceName = '1224708605@qq.com'; // 设备名称
const deviceSecret = '3a694c1543fa8582ffc6d8ff1d7af6ca'; // 设备密钥
// 当前产品和设备所属地域的ID
// const region = 'us-west-1';
const region = 'cn-shanghai';

// 接收消息时使用的订阅URL
String subscribeUrl = '/${productKey}/${deviceName}/user/get';
// 发送消息时使用的发布URL
String publishUrl = '/${productKey}/${deviceName}/user/update';

// 配置MQTT插件
ZygMqttPlugin().setConfigure(productKey, deviceName, deviceSecret, region, subscribeUrl, publishUrl);

3. 设置连接状态回调

// 连接状态回调
ZygMqttPlugin().myConnectStateCallback = (state) {
  if (ZygConnectState.connected == state) {
    print('已连接');
    setState(() {
      connectState = '已连接';
    });
  } else if (ZygConnectState.disconnect == state) {
    print('已断开');
    connectState = '已断开';
  }
};

4. 设置接收消息回调

// 接收消息回调，rawData是接收到的原始数据，jsonData是JSON格式的数据
ZygMqttPlugin().myReceiveCallback = (rawData, jsonData) {
  setState(() {
    receiveDataList.add(rawData.toString());
  });
};

5. 去连接MQTT

// 连接到MQTT服务器
ZygMqttPlugin().goToConnetMqtt();

6. 去发送MQTT消息

// 获取电量的指令
Map map = {
  "target_device": "89860124801080169975", // 目标设备ID
  "cmd": "detect_battery" // 命令
};

String msg = jsonEncode(map);

// 发送数据
ZygMqttPlugin().sendData(msg);

完整示例代码

以下是完整的示例代码：

import 'dart:convert';

import 'package:flutter/material.dart';
import 'package:zyg_mqtt_plugin/zyg_mqtt_plugin.dart';

void main() {
  runApp(const MyApp());
}

class MyApp extends StatefulWidget {
  const MyApp({super.key});

  [@override](/user/override)
  State<MyApp> createState() => _MyAppState();
}

class _MyAppState extends State<MyApp> {
  String _platformVersion = 'Unknown';
  final _zygMqttPlugin = ZygMqttPlugin();
  List<String> receiveDataList = [];
  String connectState = '未连接';

  [@override](/user/override)
  void initState() {
    super.initState();
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: const Text('Plugin example app'),
        ),
        body: Center(
          child: Stack(
            children: [
              ZygMqttWidget(),
              ListView(
                children: [
                  Text(
                    '连接状态：$connectState',
                    style: TextStyle(color: Colors.red),
                  ),
                  SizedBox(height: 20),
                  FilledButton(
                    onPressed: () {
                      // 配置MQTT参数
                      const productKey = 'a1WPnByrqko';
                      const deviceName = '1224708605@qq.com';
                      const deviceSecret = '3a694c1543fa8582ffc6d8ff1d7af6ca';
                      const region = 'cn-shanghai';

                      String subscribeUrl = '/${productKey}/${deviceName}/user/get';
                      String publishUrl = '/${productKey}/${deviceName}/user/update';

                      // 设置MQTT配置
                      ZygMqttPlugin().setConfigure(productKey, deviceName, deviceSecret, region, subscribeUrl, publishUrl);

                      // 设置连接状态回调
                      ZygMqttPlugin().myConnectStateCallback = (state) {
                        if (ZygConnectState.connected == state) {
                          print('已连接');
                          setState(() {
                            connectState = '已连接';
                          });
                        } else if (ZygConnectState.disconnect == state) {
                          print('已断开');
                          setState(() {
                            connectState = '已断开';
                          });
                        }
                      };

                      // 设置接收消息回调
                      ZygMqttPlugin().myReceiveCallback = (rawData, jsonData) {
                        setState(() {
                          receiveDataList.add(rawData.toString());
                        });
                      };

                      // 连接到MQTT服务器
                      ZygMqttPlugin().goToConnetMqtt();
                    },
                    child: Text('连接MQTT'),
                  ),
                  SizedBox(height: 20),
                  FilledButton(
                    onPressed: () {
                      // 发送电量检测命令
                      Map map = {
                        "target_device": "89860124801080169975",
                        "cmd": "detect_battery"
                      };
                      String msg = jsonEncode(map);
                      ZygMqttPlugin().sendData(msg);
                    },
                    child: Text('发送数据'),
                  ),
                  ...receiveDataList.map((data) => Text(data)).toList(),
                ],
              ),
            ],
          ),
        ),
      ),
    );
  }
}