package sendMQTT;
|
|
|
|
import java.io.UnsupportedEncodingException;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import sendMQTT.HTTPUtils.PropertiesFileUploader;
|
import set.Setsys;
|
import user.Usrdell;
|
|
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;
|
|
|
public class Server {
|
static String host="tcp://39.99.43.227:1883";
|
static String clientId="1231@qq.com";
|
|
/**
|
* 获取当前系统时间
|
* @return 格式化的时间字符串，格式为 "yyyy-MM-dd HH:mm:ss"
|
*/
|
public static String getCurrentSystemTime() {
|
LocalDateTime now = LocalDateTime.now();
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
return now.format(formatter);
|
}
|
|
/**
|
* 获取当前系统时间（自定义格式）
|
* @param pattern 时间格式模式，例如 "yyyy-MM-dd HH:mm:ss"、"yyyy/MM/dd HH:mm:ss" 等
|
* @return 格式化的时间字符串
|
*/
|
public static String getCurrentSystemTime(String pattern) {
|
LocalDateTime now = LocalDateTime.now();
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
|
return now.format(formatter);
|
}
|
|
|
|
private static void testCode() {
|
String mes_id="hxzkcontrol_20151104";//消息ID
|
String userId=Usrdell.getUserEmail();//用户ID
|
String deviceID=Setsys.getMowerIdValue();//设备ID
|
String protiesFilePath="./dikuai.properties";//地块信息配置文件
|
String json = PropertiesFileUploader.movePathSend(mes_id,userId, deviceID, protiesFilePath);//生成给设备下发的JSON
|
sendMQTT(json, host, clientId,deviceID);
|
}
|
|
private static void sendMQTT(String messageJson, String host, String clientId,String deviceID) {
|
try {
|
String topic="app/p/mower/"+deviceID+"/path";
|
MqttConnectOptions options = new MqttConnectOptions();
|
options.setCleanSession(true);
|
MqttClient client = new MqttClient(host, clientId);
|
client.connect(options);
|
// 添加关闭钩子，程序退出时关闭连接
|
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
|
try {
|
if (client.isConnected()) {
|
client.disconnect();
|
client.close();
|
}
|
} catch (Exception e) {
|
}
|
}));
|
MqttMessage message = new MqttMessage();
|
message.setPayload(messageJson.getBytes("UTF-8"));
|
client.publish(topic, message);
|
System.out.println("发送数据到主题: " + topic);
|
} catch (MqttException e) {
|
throw new RuntimeException(e);
|
} catch (UnsupportedEncodingException e) {
|
throw new RuntimeException(e);
|
}
|
}
|
|
}
|
