From 1d42efe4cbd6b1028a28ff7f3ef2b3d721051c2f Mon Sep 17 00:00:00 2001
From: kongdeqiang <123456>
Date: 星期四, 26 九月 2024 13:58:24 +0800
Subject: [PATCH] fix ： 新增修改车数日志
---
src/main/java/com/boying/controller/car/ServerMQTT.java | 93 ++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 93 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/boying/controller/car/ServerMQTT.java b/src/main/java/com/boying/controller/car/ServerMQTT.java
new file mode 100644
index 0000000..e2254a9
--- /dev/null
+++ b/src/main/java/com/boying/controller/car/ServerMQTT.java
@@ -0,0 +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());
+ }
+}
--
Gitblit v1.9.1