1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53
| import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
PUBLIC class PahoDemo implements MqttCallback {
MqttClient client;
PUBLIC PahoDemo() {
}
PUBLIC static void main(string[] args) {
new PahoDemo().doDemo();
}
PUBLIC void doDemo() {
try {
client = new MqttClient("tcp://192.168.118.11:1883", "Sending");
client.connect();
client.setCallback(this);
client.subscribe("foo");
MqttMessage Message = new MqttMessage();
message.setPayload("A single message from my computer fff"
.getBytes());
client.publish("foo", Message);
} catch (MqttException e) {
e.printStackTrace();
}
}
@Override
PUBLIC void connectionLost(Throwable cause) {
// TODO Auto-generated method stub
}
@Override
PUBLIC void messageArrived(string topic, MqttMessage Message)
throws EXCEPTION {
System.out.println(Message);
}
@Override
PUBLIC void deliveryComplete(IMqttDeliveryToken token) {
// TODO Auto-generated method stub
}
} |
Partager