Flutter框架高阶——使用MQTT协议进行信息传输

import 'package:mqtt_client/mqtt_client.dart';
 
Future<void> connectToMqttBroker(String host, int port, String clientIdentifier) async {
  final client = MqttServerClient.withPort(host, clientIdentifier, port);
  client.logging(on: true);
  client.onConnected = () {
    print('Connected');
  };
  client.onDisconnected = () {
    print('Disconnected');
  };
  try {
    await client.connect();
    print('Connected to MQTT Broker');
  } catch (e) {
    print('Exception: $e');
    client.disconnect();
  }
}
 
// 使用示例
void main() {
  const host = 'test.mosquitto.org'; // MQTT 代理服务器地址
  const port = 1883; // MQTT 代理服务器端口
  const clientIdentifier = 'your_client_id'; // 客户端标识符
  connectToMqttBroker(host, port, clientIdentifier);
}

这段代码展示了如何在Flutter中使用mqtt\_client库连接到MQTT代理服务器。首先创建了一个MqttServerClient实例，并设置了连接和断开连接时的回调函数。然后尝试连接到服务器，并在连接成功或失败时进行处理。这是一个简单的实例，展示了如何在实际应用程序中使用MQTT协议。