70 lines
2.0 KiB
Plaintext
70 lines
2.0 KiB
Plaintext
|
package com.example.administrator.ximengjianyu.mqtt.publisher;
|
||
|
|
|
||
|
|
import org.eclipse.paho.client.mqttv3.MqttClient;
|
||
|
|
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
|
||
|
|
import org.eclipse.paho.client.mqttv3.MqttException;
|
||
|
|
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
||
|
|
import org.eclipse.paho.client.mqttv3.MqttTopic;
|
||
|
|
//import org.eclipse.paho.client.mqttv3.internal.MemoryPersistence;
|
||
|
|
|
||
|
|
import java.util.Random;
|
||
|
|
|
||
|
|
public class Thermometer {
|
||
|
|
|
||
|
|
//通知地址
|
||
|
|
public static final String BROKER_URL = "tcp://192.168.133.150:1883";
|
||
|
|
|
||
|
|
public static final String TOPIC = "de/eclipsemagazin/blackice/warnings";
|
||
|
|
|
||
|
|
private MqttClient client;
|
||
|
|
|
||
|
|
|
||
|
|
public Thermometer() {
|
||
|
|
// try {
|
||
|
|
// client = new MqttClient(BROKER_URL, MqttClient.generateClientId(), new MemoryPersistence());
|
||
|
|
// } catch (MqttException e) {
|
||
|
|
// e.printStackTrace();
|
||
|
|
// System.exit(1);
|
||
|
|
// }
|
||
|
|
}
|
||
|
|
|
||
|
|
private void start() {
|
||
|
|
|
||
|
|
try {
|
||
|
|
MqttConnectOptions ss = new MqttConnectOptions();
|
||
|
|
ss.setUserName("cmkj");
|
||
|
|
ss.setPassword("cmkj".toCharArray());
|
||
|
|
client.connect(ss);
|
||
|
|
|
||
|
|
publishTemperature();
|
||
|
|
|
||
|
|
client.disconnect();
|
||
|
|
|
||
|
|
} catch (MqttException e) {
|
||
|
|
e.printStackTrace();
|
||
|
|
System.exit(1);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private void publishTemperature() throws MqttException {
|
||
|
|
final MqttTopic temperatureTopic = client.getTopic(TOPIC);
|
||
|
|
|
||
|
|
final int temperature = createRandomNumberBetween(-20, 4);
|
||
|
|
|
||
|
|
final MqttMessage message = new MqttMessage(String.valueOf(temperature).getBytes());
|
||
|
|
temperatureTopic.publish(message);
|
||
|
|
|
||
|
|
System.out.println("Published data. Topic: " + temperatureTopic.getName() + " Message: " + temperature);
|
||
|
|
}
|
||
|
|
|
||
|
|
public static int createRandomNumberBetween(int min, int max) {
|
||
|
|
|
||
|
|
return new Random().nextInt(max - min + 1) + min;
|
||
|
|
}
|
||
|
|
|
||
|
|
public static void main(String... args) {
|
||
|
|
final Thermometer thermometer = new Thermometer();
|
||
|
|
thermometer.start();
|
||
|
|
}
|
||
|
|
}
|