dart_mqtt 1.0.1+3

a mqtt library to easy connect via tcp/ssl,dependence xtransport,developing,not stable.

example/README.md

Quickstart Guide

tcp

import 'package:dart_mqtt/dart_mqtt.dart';

void main() async {
  var cli = MqttClient("broker.emqx.io", 1883, log: true, allowReconnect: true)
    ..withKeepalive(20)
    ..withClientID("mqtt_test");
  cli.onMqttConack((msg) {
    if (msg.returnCode != MqttConnectReturnCode.connectionAccepted) {
      // cli.
      cli.close();
      return;
    }
    cli.subscribe("test111", onMessage: (msg) {});
  });
  cli.onBeforeReconnect(() async {
    print("reconnecting...");
  });

  cli.start();
}

tls

import 'dart:io';

import 'package:dart_mqtt/dart_mqtt.dart';

void main() async {
  var cli = MqttClient(
    "127.0.0.1",
    8883,
    credentials: XtransportCredentials.secure(
      authority: "fake.apple.com",
      certificates: File('cert/ca.pem').readAsBytesSync(),
      clientCertificateBytes: File('cert/client.pem').readAsBytesSync(),
      clientPrivateKeyBytes: File('cert/client.key').readAsBytesSync(),
      onBadCertificate: (_x509, _host) => true,
    ),
    log: true,
  )
    ..withKeepalive(0)
    ..withClientID("mqttx_test");
  cli.onMqttConack((msg) {
    if (msg.returnCode != MqttConnectReturnCode.connectionAccepted) {
      cli.close();
      return;
    }
    cli.reSub();
  });

  cli.onBeforeReconnect(() async {
    print("reconnecting...");
  });
  cli.start();
  cli.subscribe("test/topic", onMessage: (msg) {
    print(msg);
  }).then((_) {
    print("subed1");
  });
  cli.subscribe("test/t2", onMessage: (msg) {
    print(msg);
    print("xx");
  }).then((_) {
    print("subed2");
  });
}