MQTT
Implementazione di MQTT
Ricerca…
Esempio di pubblicazione / sottoscrizione in java
crea un progetto web dinamico in sts / eclipse scarica il vaso pakey eclipse da clicca qui per scaricare e incollare il file jar in webcontent-> webinf-> cartella-> lib
Pubblica esempio
String broker = "tcp://localhost:1883";
String topicName = "test/topic";
int qos = 1;
MqttClient mqttClient = new MqttClient(broker,String.valueOf(System.nanoTime()));
//Mqtt ConnectOptions is used to set the additional features to mqtt message
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setCleanSession(true); //no persistent session
connOpts.setKeepAliveInterval(1000);
MqttMessage message = new MqttMessage("Ed Sheeran".getBytes());
// qui ed sheeran è un messaggio
message.setQos(qos); //sets qos level 1
message.setRetained(true); //sets retained message
MqttTopic topic2 = mqttClient.getTopic(topicName);
mqttClient.connect(connOpts); //connects the broker with connect options
topic2.publish(message); // publishes the message to the topic(test/topic)
Iscriviti Esempio
//We're using eclipse paho library so we've to go with MqttCallback
MqttClient client = new MqttClient("tcp://localhost:1883","clientid");
client.setCallback(this);
MqttConnectOptions mqOptions=new MqttConnectOptions();
mqOptions.setCleanSession(true);
client.connect(mqOptions); //connecting to broker
client.subscribe("test/topic"); //subscribing to the topic name test/topic
//Override methods from MqttCallback interface
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
System.out.println("message is : "+message);
}
.
.//other override methods
.
Modified text is an extract of the original Stack Overflow Documentation
Autorizzato sotto CC BY-SA 3.0
Non affiliato con Stack Overflow