From acf352921487e857810a943b008121e33404e9ae Mon Sep 17 00:00:00 2001
From: kongdeqiang <kongdeqiang960204@163.com>
Date: 星期二, 15 四月 2025 16:56:50 +0800
Subject: [PATCH] fix:白名单新增bug
---
src/main/java/com/boying/controller/car/ServerMQTT.java | 186 +++++++++++++++++++++++-----------------------
1 files changed, 93 insertions(+), 93 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..582264d 100644
--- a/src/main/java/com/boying/controller/car/ServerMQTT.java
+++ b/src/main/java/com/boying/controller/car/ServerMQTT.java
@@ -1,93 +1,93 @@
-package com.boying.controller.car;
-
-import org.eclipse.paho.client.mqttv3.*;
-import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
-
-/**
- * @author kdq
- * @version 1.0.0
- * @ClassName ServerMQTT.java
- * @Description TODO
- * @createTime 2024骞�03鏈�20鏃� 15:43:00
- */
-public class ServerMQTT {
-
- public static void main(String[] args) throws MqttException {
- ServerMQTT server = new ServerMQTT();
-
- server.message = new MqttMessage();
- server.message.setQos(2);
- server.message.setRetained(true);
- server.message.setPayload("ServerMQTT".getBytes());
- server.publish(server.topic , server.message);
- System.out.println(server.message.isRetained() + "------ratained鐘舵��");
- }
-
- //MQTT瀹夎鐨勬湇鍔″櫒鍦板潃鍜岀鍙ｅ彿
- public static final String HOST = "tcp://39.96.92.240:9092";
- //瀹氫箟涓�涓富棰�
- public static final String TOPIC = "/device/message/up/ivs_result";
- //瀹氫箟MQTT鐨処D锛屽彲浠ュ湪MQTT鏈嶅姟閰嶇疆涓寚瀹�
- private static final String clientid = "client-1";
-
- private MqttClient client;
- private MqttTopic topic;
- private String userName = "mqtt";
- private String passWord = "mqtt";
- private MqttMessage message;
-
- /**
- * g鏋勯�犲嚱鏁�
- */
- public ServerMQTT() throws MqttException {
- // MemoryPersistence璁剧疆clientid鐨勪繚瀛樺舰寮忥紝榛樿涓轰互鍐呭瓨淇濆瓨
- client = new MqttClient(HOST, clientid, new MemoryPersistence());
- connect();
- }
-
- /**
- * l杩炴帴鏈嶅姟鍣�
- */
- private void connect() {
- MqttConnectOptions options = new MqttConnectOptions();
- options.setCleanSession(false);
- options.setUserName(userName);
- options.setPassword(passWord.toCharArray());
- // 璁剧疆瓒呮椂鏃堕棿
- options.setConnectionTimeout(10);
- // 璁剧疆浼氳瘽蹇冭烦鏃堕棿
- options.setKeepAliveInterval(20);
- try {
- client.setCallback(new MqttCallback() {
- @Override
- public void connectionLost(Throwable cause) {
- // 杩炴帴涓㈠け鍚庯紝涓�鑸湪杩欓噷闈㈣繘琛岄噸杩�
- System.out.println("杩炴帴鏂紑鈥︹�︼紙鍙互鍋氶噸杩烇級");
- }
- @Override
- public void deliveryComplete(IMqttDeliveryToken token) {
- System.out.println("deliveryComplete---------" + token.isComplete());
- }
- @Override
- public void messageArrived(String topic, MqttMessage message) throws Exception {
- // subscribe鍚庡緱鍒扮殑娑堟伅浼氭墽琛屽埌杩欓噷闈�
- System.out.println("鎺ユ敹娑堟伅涓婚:" + topic + " 鎺ユ敹娑堟伅Qos:" + message.getQos() + "鎺ユ敹娑堟伅鍐呭:" + new String(message.getPayload()));
- }
- });
- client.connect(options);
-
- topic = client.getTopic(TOPIC);
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
- /**
- * t鎺ㄩ�佹秷鎭�
- */
- public void publish(MqttTopic topic , MqttMessage message) throws MqttPersistenceException, MqttException {
- MqttDeliveryToken token = topic.publish(message);
- token.waitForCompletion();
- System.out.println("message is published completely! " + token.isComplete());
- }
-}
+//package com.boying.controller.car;
+//
+//import org.eclipse.paho.client.mqttv3.*;
+//import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
+//
+///**
+// * @author kdq
+// * @version 1.0.0
+// * @ClassName ServerMQTT.java
+// * @Description TODO
+// * @createTime 2024骞�03鏈�20鏃� 15:43:00
+// */
+//public class ServerMQTT {
+//
+// public static void main(String[] args) throws MqttException {
+// ServerMQTT server = new ServerMQTT();
+//
+// server.message = new MqttMessage();
+// server.message.setQos(2);
+// server.message.setRetained(true);
+// server.message.setPayload("ServerMQTT".getBytes());
+// server.publish(server.topic , server.message);
+// System.out.println(server.message.isRetained() + "------ratained鐘舵��");
+// }
+//
+// //MQTT瀹夎鐨勬湇鍔″櫒鍦板潃鍜岀鍙ｅ彿
+// public static final String HOST = "tcp://39.96.92.240:9092";
+// //瀹氫箟涓�涓富棰�
+// public static final String TOPIC = "/device/message/up/ivs_result";
+// //瀹氫箟MQTT鐨処D锛屽彲浠ュ湪MQTT鏈嶅姟閰嶇疆涓寚瀹�
+// private static final String clientid = "client-1";
+//
+// private MqttClient client;
+// private MqttTopic topic;
+// private String userName = "mqtt";
+// private String passWord = "mqtt";
+// private MqttMessage message;
+//
+// /**
+// * g鏋勯�犲嚱鏁�
+// */
+// public ServerMQTT() throws MqttException {
+// // MemoryPersistence璁剧疆clientid鐨勪繚瀛樺舰寮忥紝榛樿涓轰互鍐呭瓨淇濆瓨
+// client = new MqttClient(HOST, clientid, new MemoryPersistence());
+// connect();
+// }
+//
+// /**
+// * l杩炴帴鏈嶅姟鍣�
+// */
+// private void connect() {
+// MqttConnectOptions options = new MqttConnectOptions();
+// options.setCleanSession(false);
+// options.setUserName(userName);
+// options.setPassword(passWord.toCharArray());
+// // 璁剧疆瓒呮椂鏃堕棿
+// options.setConnectionTimeout(10);
+// // 璁剧疆浼氳瘽蹇冭烦鏃堕棿
+// options.setKeepAliveInterval(20);
+// try {
+// client.setCallback(new MqttCallback() {
+// @Override
+// public void connectionLost(Throwable cause) {
+// // 杩炴帴涓㈠け鍚庯紝涓�鑸湪杩欓噷闈㈣繘琛岄噸杩�
+// System.out.println("杩炴帴鏂紑鈥︹�︼紙鍙互鍋氶噸杩烇級");
+// }
+// @Override
+// public void deliveryComplete(IMqttDeliveryToken token) {
+// System.out.println("deliveryComplete---------" + token.isComplete());
+// }
+// @Override
+// public void messageArrived(String topic, MqttMessage message) throws Exception {
+// // subscribe鍚庡緱鍒扮殑娑堟伅浼氭墽琛屽埌杩欓噷闈�
+// System.out.println("鎺ユ敹娑堟伅涓婚:" + topic + " 鎺ユ敹娑堟伅Qos:" + message.getQos() + "鎺ユ敹娑堟伅鍐呭:" + new String(message.getPayload()));
+// }
+// });
+// client.connect(options);
+//
+// topic = client.getTopic(TOPIC);
+// } catch (Exception e) {
+// e.printStackTrace();
+// }
+// }
+//
+// /**
+// * t鎺ㄩ�佹秷鎭�
+// */
+// public void publish(MqttTopic topic , MqttMessage message) throws MqttPersistenceException, MqttException {
+// MqttDeliveryToken token = topic.publish(message);
+// token.waitForCompletion();
+// System.out.println("message is published completely! " + token.isComplete());
+// }
+//}
--
Gitblit v1.9.1