From 199202813dd8ca536ed2334f5eeb6aba3ad25b21 Mon Sep 17 00:00:00 2001
From: kongdeqiang <123456>
Date: 星期一, 22 十二月 2025 08:49:51 +0800
Subject: [PATCH] fix ： 新分支
---
src/main/java/com/boying/controller/car/ServerMQTT.java | 34 +++++++++++++++++++++++++---------
1 files changed, 25 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/boying/controller/car/ServerMQTT.java b/src/main/java/com/boying/controller/car/ServerMQTT.java
index e2254a9..1c14370 100644
--- a/src/main/java/com/boying/controller/car/ServerMQTT.java
+++ b/src/main/java/com/boying/controller/car/ServerMQTT.java
@@ -1,7 +1,12 @@
package com.boying.controller.car;
+import com.google.gson.Gson;
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
/**
* @author kdq
@@ -15,25 +20,35 @@
public static void main(String[] args) throws MqttException {
ServerMQTT server = new ServerMQTT();
+ Map<String, Object> map2 = new HashMap<>();
+
+
+ Map<String, Object> map = new HashMap<>();
+ map.put("t",System.currentTimeMillis());
+ map.put("f","control");
+ map.put("d","JYGL-MTXX");
+ map.put("s","0001");
+ Gson gson =new Gson();
+ String str = gson.toJson(map);
server.message = new MqttMessage();
server.message.setQos(2);
server.message.setRetained(true);
- server.message.setPayload("ServerMQTT".getBytes());
+ server.message.setPayload(str.getBytes());
server.publish(server.topic , server.message);
- System.out.println(server.message.isRetained() + "------ratained鐘舵��");
+ System.out.println("message鐨勪繚鐣欑姸鎬佷负锛�"+server.message.isRetained() + "------ratained鐘舵��");
}
//MQTT瀹夎鐨勬湇鍔″櫒鍦板潃鍜岀鍙ｅ彿
- public static final String HOST = "tcp://39.96.92.240:9092";
+ public static final String HOST = "tcp://47.92.115.108:1883";
//瀹氫箟涓�涓富棰�
- public static final String TOPIC = "/device/message/up/ivs_result";
+ public static final String TOPIC = "/MXXT";
//瀹氫箟MQTT鐨処D锛屽彲浠ュ湪MQTT鏈嶅姟閰嶇疆涓寚瀹�
- private static final String clientid = "client-1";
+ private static final String clientid = "jzadmin"+System.currentTimeMillis();
private MqttClient client;
private MqttTopic topic;
- private String userName = "mqtt";
- private String passWord = "mqtt";
+ private String userName = "jzadmin";
+ private String passWord = "Sys123456";
private MqttMessage message;
/**
@@ -66,7 +81,7 @@
}
@Override
public void deliveryComplete(IMqttDeliveryToken token) {
- System.out.println("deliveryComplete---------" + token.isComplete());
+ System.out.println("mqtt鐨刣eliveryComplete鍥炶皟鐘舵�佷负---------" + token.isComplete());
}
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
@@ -86,8 +101,9 @@
* t鎺ㄩ�佹秷鎭�
*/
public void publish(MqttTopic topic , MqttMessage message) throws MqttPersistenceException, MqttException {
+ topic = client.getTopic(TOPIC);
MqttDeliveryToken token = topic.publish(message);
token.waitForCompletion();
- System.out.println("message is published completely! " + token.isComplete());
+ System.out.println("message 鎴愬姛鍙戦��! token.isComplete鐘舵�佷负锛�" + token.isComplete());
}
}
--
Gitblit v1.9.1