From 3bff2fa630c6e4a8d370d44f45f10983061d23e6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B0=A2=E6=AC=A3=E6=82=A6?= <2289014031@qq.com>
Date: Sun, 29 Sep 2024 10:19:43 +0800
Subject: [PATCH] =?UTF-8?q?MQTT=E4=BC=A0=E8=BE=93=20=E6=8E=A5=E6=94=B6?=
 =?UTF-8?q?=E8=80=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cloud-modules/cloud-modules-car/pom.xml       |  6 ++-
 .../java/com/muyu/car/CarApplication.java     |  3 ++
 .../src/main/java/com/muyu/car/Demo.java      | 51 +++++++++++++++++++
 .../main/java/com/muyu/car/config/kafka.java  |  4 ++
 4 files changed, 63 insertions(+), 1 deletion(-)
 create mode 100644 cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Demo.java
 create mode 100644 cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/config/kafka.java

diff --git a/cloud-modules/cloud-modules-car/pom.xml b/cloud-modules/cloud-modules-car/pom.xml
index 42b3dd2..1b56b76 100644
--- a/cloud-modules/cloud-modules-car/pom.xml
+++ b/cloud-modules/cloud-modules-car/pom.xml
@@ -72,7 +72,11 @@
             <artifactId>kafka-clients</artifactId>
         </dependency>
 
-
+        <dependency>
+            <groupId>org.eclipse.paho</groupId>
+            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
+            <version>1.2.2</version>
+        </dependency>
 
         <!-- MuYu Common System-->
         <dependency>
diff --git a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/CarApplication.java b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/CarApplication.java
index 472285c..226489e 100644
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/CarApplication.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/CarApplication.java
@@ -20,4 +20,7 @@ public class CarApplication {
         SpringApplication.run(CarApplication.class,args);
     }
 
+
+
+
 }
diff --git a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Demo.java b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Demo.java
new file mode 100644
index 0000000..92a6092
--- /dev/null
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Demo.java
@@ -0,0 +1,51 @@
+package com.muyu.car;
+
+import org.eclipse.paho.client.mqttv3.*;
+import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
+
+public class Demo {
+
+    public static void main(String[] args) {
+
+        String topic        = "vehicle";
+        String content      = "Message from MqttPublishSample";
+        int qos             = 2;
+        String broker       = "tcp://127.0.0.1:1883";
+        String clientId     = "JavaSample";
+
+        try {
+            // 第三个参数为空，默认持久化策略
+            MqttClient sampleClient = new MqttClient(broker, clientId);
+            MqttConnectOptions connOpts = new MqttConnectOptions();
+            connOpts.setCleanSession(true);
+            System.out.println("Connecting to broker: "+broker);
+            sampleClient.connect(connOpts);
+            sampleClient.subscribe(topic,0);
+            sampleClient.setCallback(new MqttCallback() {
+                // 连接丢失
+                @Override
+                public void connectionLost(Throwable throwable) {
+
+                }
+                // 连接成功
+                @Override
+                public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
+                    System.out.println(new String(mqttMessage.getPayload()));
+                }
+                // 接收信息
+                @Override
+                public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
+
+                }
+            });
+        } catch(MqttException me) {
+            System.out.println("reason "+me.getReasonCode());
+            System.out.println("msg "+me.getMessage());
+            System.out.println("loc "+me.getLocalizedMessage());
+            System.out.println("cause "+me.getCause());
+            System.out.println("excep "+me);
+            me.printStackTrace();
+        }
+    }
+
+}
diff --git a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/config/kafka.java b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/config/kafka.java
new file mode 100644
index 0000000..a66a297
--- /dev/null
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/config/kafka.java
@@ -0,0 +1,4 @@
+package com.muyu.car.config;
+
+public class kafka {
+}