MQTT传输 接收者

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>

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);
     }
 
+
+
+
 }

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();
+        }
+    }
+
+}

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 {
+}