mqtt_client_service

Description:

mqtt client service

mqtt_client_service #
Custom MQTT Client Service with MQTT Client
Features #

Easily send and receive messages

Getting started #
To use this package, add mqtt_client_service as a dependency in your pubspec.yaml file.
Usage #
For example:
late MQTTClientService mqttClientService;
final String broker = 'broker.emqx.io';
final String clientId = 'mqttx_3ced2008';
final TextEditingController topicController = TextEditingController();
final TextEditingController messageController = TextEditingController();
List<String> receivedMessages = []; // Store received messages
Set<String> subscribedTopics = {}; // Track subscribed topics

@override
void initState() {
super.initState();
mqttClientService = MQTTClientService(broker, clientId);
mqttClientService.onMessageReceived = onMessageReceived;
mqttClientService.initializeMQTTClient();
}

@override
void dispose() {
mqttClientService.onDisconnected();
super.dispose();
}

ElevatedButton(
onPressed: () {
mqttClientService.publishMessage(
topicController.text,
messageController.text,
);
},
child: const Text('Publish'),
),

ListView.builder(
itemCount: receivedMessages.length,
itemBuilder: (context, index) {
final messageData = receivedMessages[index];
print("Received Message : $messageData");
// Parse the received message
final parts = messageData.split(', ');
final topic = parts[0].substring('Topic: '.length);
final message = parts[1].substring('Message: '.length);
return ListTile(
title: Row(
children: [
Expanded(
child: Text(topic),
),
Expanded(
child: Text(message),
),
],
),
);
},
)
copied to clipboard