Connectez Java à un broker MQTT avec le client Java Eclipse Paho. Commencez sur le broker public gratuit, puis pointez le même code vers un broker privé et sécurisé sur ConnectMQ.
mqtt-code-samples/javaClonez les exemples complets et prêts à l’emploi. Étoiles et pull requests bienvenues. Voir sur GitHub Aucun compte requis : connectez-vous à broker.connectmq.com sur le port 1883 et publiez vos premiers messages en quelques secondes.
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
public class Example {
public static void main(String[] args) throws Exception {
String topic = "your-project/sensors/temperature"; // Utilisez un préfixe de topic unique : tout le monde peut lire le broker public
// Connexion au broker public gratuit (aucun compte requis)
MqttClient client = new MqttClient("tcp://broker.connectmq.com:1883",
MqttClient.generateClientId(), new MemoryPersistence());
MqttConnectOptions options = new MqttConnectOptions();
// Reconnexion automatique en cas de coupure
options.setAutomaticReconnect(true);
client.connect(options);
// Abonnement au topic de température
client.subscribe(topic, 1, (t, message) ->
System.out.println(t + ": " + new String(message.getPayload())));
// Publication d’une mesure en JSON
client.publish(topic, "{\"temperature\":21.5}".getBytes(), 1, false);
}
}
Le broker public est partagé : n’importe qui peut s’abonner à vos topics. N’y faites jamais transiter de mots de passe, de données personnelles ou d’informations confidentielles.
À propos du broker MQTT public gratuitPour de vrais appareils, utilisez un broker MQTT serverless privé sur ConnectMQ plutôt que le broker public : chiffrement TLS, un nom d’utilisateur et un mot de passe par appareil et un contrôle d’accès par topic, entièrement managé. Commencez avec l’offre Free, sans carte bancaire.
Remplacez YOUR_BROKER_HOST, YOUR_USERNAME et YOUR_PASSWORD par les valeurs de votre tableau de bord ConnectMQ.
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
public class Example {
public static void main(String[] args) throws Exception {
String topic = "your-project/sensors/temperature";
// Connexion à votre broker ConnectMQ privé sur le port 8883 (TLS : le magasin CA du système vérifie le certificat du broker)
MqttClient client = new MqttClient("ssl://YOUR_BROKER_HOST:8883",
MqttClient.generateClientId(), new MemoryPersistence());
MqttConnectOptions options = new MqttConnectOptions();
// Nom d’utilisateur et mot de passe issus du tableau de bord ConnectMQ
options.setUserName("YOUR_USERNAME");
options.setPassword("YOUR_PASSWORD".toCharArray());
// Reconnexion automatique en cas de coupure
options.setAutomaticReconnect(true);
client.connect(options);
// Abonnement au topic de température
client.subscribe(topic, 1, (t, message) ->
System.out.println(t + ": " + new String(message.getPayload())));
// Publication d’une mesure en JSON
client.publish(topic, "{\"temperature\":21.5}".getBytes(), 1, false);
}
}
Installez Eclipse Paho Java Client, connectez-vous à l’hôte du broker sur le port 1883 (ou 8883 avec TLS), puis abonnez-vous à un topic et publiez-y des messages. Les exemples de cette page se connectent au broker public gratuit broker.connectmq.com et à un broker ConnectMQ privé.
Oui. broker.connectmq.com est un broker MQTT public gratuit qui ne nécessite aucun compte. Tout le monde peut lire ses topics : utilisez-le uniquement pour vos tests, avec un préfixe de topic unique.
Connectez-vous via TLS sur le port 8883 avec un nom d’utilisateur et un mot de passe issus de votre tableau de bord ConnectMQ, et attribuez à chaque appareil ses propres identifiants et permissions de topic au lieu d’utiliser le broker public.
Connectez Python à un broker MQTT avec paho-mqtt.
Voir l’exempleConnectez Node.js à un broker MQTT avec MQTT.js.
Voir l’exempleConnectez un ESP32 à un broker MQTT via Wi-Fi avec la bibliothèque Arduino PubSubClient.
Voir l’exempleConnectez Go à un broker MQTT avec le client Go Eclipse Paho.
Voir l’exemplePubliez et abonnez-vous en ligne de commande avec mosquitto_pub et mosquitto_sub.
Voir l’exempleConnectez C# et .NET à un broker MQTT avec MQTTnet.
Voir l’exempleConnectez Rust à un broker MQTT avec la crate rumqttc.
Voir l’exempleConnectez vos applications Dart et Flutter à un broker MQTT avec le package mqtt_client.
Voir l’exempleConnectez vos applications natives iOS (Swift) et Android (Kotlin) à un broker MQTT.
Voir l’exempleConnectez Home Assistant à un broker MQTT et transformez les messages MQTT en capteurs.
Voir l’exempleConnectez Node-RED à un broker MQTT avec un flow importable.
Voir l’exempleTestez n’importe quel exemple sur broker.connectmq.com : sans inscription, MQTT 3.1.1 et 5, TCP, TLS et WebSocket.
À propos du broker MQTT public gratuitLe moment venu de connecter de vrais appareils, exécutez le même code sur un broker ConnectMQ privé et entièrement managé, avec TLS et des identifiants par appareil.
Commencer gratuitementCréez un compte, récupérez les identifiants de votre broker et connectez votre premier appareil — aucun serveur à installer, mettre à jour ou dimensionner.
