mqtt.dart 1.42 KB
import 'package:appframe/config/locator.dart';

/// 此处暂时测试
/// 正常需要在登录状态下,查询host和jwt
Future<void> registerMqtt() async {
  // String mqttHost = '58.87.99.45';
  // int mqttPort = 1883;
  // // 获取 mac 地址
  // String mqttMac = '';
  // String mqttClientId = 'tanghuan_phone';
  // int keepAlive = 60;
  // String mqttUsername = 'user';
  // String mqttPassword =
  //     'eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjE3NjI2NTgzOTEsInJzIjoib2sifQ.AoU0MfSKflC1VB0abi7BVr3g4MDah1uLlg01ZTFQgTxfolu28IfZ4BaGhRF9qy7yAQH2Efmdf2cs2iwKrdcHRSHzJhwTC44beX6viRhCCiCxe51AB8NVv72l2TmsNxIvACfXOhDLjKH6QE38EaKC486aS_L-QpakvDOQP_IPjq5ZvH68JwwhOwhLTgaCgOR3xde2H-NgRDK2BQ-FyDTXi1RX8hDGvKMw8pi6WiVBjR1ENTO5A7yvMioJS9qwdjs_7_5c6n5GXSjCHTtdQ7746hlId2uwP_41G5Ug3DYWiZ5aWIuvGRH6ZxKmbC32wN62ys_XkLGzhBw8wsQ-KhETvQ	';
  //
  // /// 初始化MQTT客户端
  // var mqttService = MqttService(mqttHost, mqttPort, mqttClientId, keepAlive, mqttUsername, mqttPassword);
  // await mqttService.initConn();
  //
  // /// 设置到getIt,用于获取使用
  // getIt.registerSingleton(mqttService);

  // MqttIsolateManager mqttIsolateManager = MqttIsolateManager();
  // mqttIsolateManager.start();
  // await mqttIsolateManager.connect('server', 'clientId');
  // // 暂停3秒
  // // await Future.delayed(Duration(seconds: 2));
  // mqttIsolateManager.subscribe('bxe/abc');
  //
  // getIt.registerSingleton(mqttIsolateManager);
}