demo获取报文

zhilian-common/zhilian-common-resolver/src/main/java/com/zhilian/common/resolver/domain/VehicleData.java

@@ -0,0 +1,172 @@
+package com.zhilian.common.resolver.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class VehicleData {
+    /**
+     *  车辆编码
+     */
+    private String vin;
+
+    /**
+     *  行驶路线
+     */
+    private String drivingRoute;
+
+    /**
+     *  经度
+     */
+    private String latitude;
+
+    /**
+     * 速度
+     */
+    private String speed;
+
+    /**
+     *  里程
+     */
+    private BigDecimal mileage;
+
+    /**
+     * 总电压
+     */
+    private String voltage;
+
+    /**
+     * 总电流
+     */
+    private String current;
+
+    /**
+     *  绝缘电阻
+     */
+    private String resistance;
+
+    /**
+     *  档位
+     */
+    private String gear;
+
+    /**
+     *  加速踏板行程值
+     */
+    private String accelerationPedal;
+
+    /**
+     *  制动踏板行程值
+     */
+    private String brakePedal;
+
+    /**
+     * 燃料消耗率
+     */
+    private String fuelConsumptionRate;
+
+    /**
+     * 电机控制器温度
+     */
+    private String motorControllerTemperature;
+
+    /**
+     *  电机转速
+     */
+    private String motorSpeed;
+
+    /**
+     *  电机转矩
+     */
+    private String motorTorque;
+
+    /**
+     * 电机温度
+     */
+    private String motorTemperature;
+
+    /**
+     *  电机电压
+     */
+    private String motorVoltage;
+
+    /**
+     *  电机电流
+     */
+    private String motorCurrent;
+
+    /**
+     * 动力电池剩余电量SOC
+     */
+    private BigDecimal remainingBattery;
+
+    /**
+     *  电池总容量
+     */
+    private BigDecimal batteryLevel;
+
+    /**
+     *  当前状态允许的最大反馈功率
+     */
+    private String maximumFeedbackPower;
+
+    /**
+     *  当前状态允许最大放电功率
+     */
+    private String maximumDischargePower;
+
+    /**
+     * BMS自检计数器
+     */
+    private String selfCheckCounter;
+
+    /**
+     * 动力电池充放电电流
+     */
+    private String totalBatteryCurrent;
+
+    /**
+     * 动力电池负载端总电压V3
+     */
+    private String totalBatteryVoltage;
+
+    /**
+     * 单次最大电压
+     */
+    private String singleBatteryMaxVoltage;
+
+    /**
+     * 单体电池最低电压
+     */
+    private String singleBatteryMinVoltage;
+
+    /**
+     * 单体电池最高温度
+     */
+    private String singleBatteryMaxTemperature;
+
+    /**
+     * 单体电池最低温度
+     */
+    private String singleBatteryMinTemperature;
+
+    /**
+     * 动力电池可用容量
+     */
+    private String availableBatteryCapacity;
+
+    /**
+     * 车辆状态
+     */
+    private int vehicleStatus;
+
+
+
+}

zhilian-modules/zhilian-online/pom.xml

@@ -9,6 +9,8 @@
         <version>3.6.3</version>
     </parent>
 
+    <packaging>jar</packaging>
+
     <artifactId>zhilian-online</artifactId>
 
     <properties>

zhilian-modules/zhilian-online/src/main/java/com/zhilian/ZhiLianOnLineApplication.java

@@ -0,0 +1,11 @@
+package com.zhilian;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ZhiLianOnLineApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(ZhiLianOnLineApplication.class);
+    }
+}

zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/aa.java

@@ -0,0 +1,4 @@
+package com.zhilian.online;
+
+public class aa {
+}

zhilian-modules/zhilian-resolver/pom.xml

@@ -110,6 +110,13 @@
             <artifactId>elasticsearch-rest-high-level-client</artifactId>
         </dependency>
 
+        <!-- Mqtt -->
+        <dependency>
+            <groupId>org.eclipse.paho</groupId>
+            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
+            <version>1.2.5</version>
+        </dependency>
+
     </dependencies>
 
     <build>

zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/controller/ResolverReportInfoController.java

@@ -34,7 +34,7 @@ public class ResolverReportInfoController extends BaseController {
     /**
      *  @Description 查询报文列表
      *  @Param [report]
-     *  @Return com.zhilian.common.core.web.controller.Result<com.zhilian.common.core.web.page.TableDataInfo<com.zhilian.resolver.domain.Report>>
+     *  @Return Result<TableDataInfo<ResolverReportInfo>>
      */
     @Log(title = "报文信息", businessType = BusinessType.OTHER)
 ////    @RequiresPermissions("resolver:report:list")
@@ -44,5 +44,4 @@ public class ResolverReportInfoController extends BaseController {
         List<ResolverReportInfo> list = reportService.pageQuery(report);
         return getDataTable(list);
     }
-
 }

zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/resolverReport/ResolverMqttMsg.java

@@ -0,0 +1,49 @@
+package com.zhilian.resolver.resolverReport;
+
+
+import lombok.extern.slf4j.Slf4j;
+import org.eclipse.paho.client.mqttv3.*;
+
+@Slf4j
+public class ResolverMqttMsg {
+    private static final String BROKER_URL = "tcp://111.229.33.194:1883";
+    private static final String CLIENT_ID = "mqttx_e9f5976f";
+
+    public static void main(String[] args) {
+        try {
+            MqttClient mqttClient = new MqttClient(BROKER_URL, CLIENT_ID);
+
+            MqttConnectOptions options = new MqttConnectOptions();
+
+            options.setCleanSession(true);
+            mqttClient.connect(options);
+
+            mqttClient.setCallback(new MqttCallback() {
+                @Override
+                public void connectionLost(Throwable throwable) {
+                    log.info("连接断开");
+                }
+
+                @Override
+                public void messageArrived(String topic, MqttMessage message) throws Exception {
+                    log.info("Message received from topic '{}': {}", topic, new String(message.getPayload()));
+                }
+
+                @Override
+                public void deliveryComplete(IMqttDeliveryToken token) {
+                    log.info("消息已成功投递：{}",token);
+                }
+            });
+
+            mqttClient.subscribe("cartest",1);
+
+            Thread.sleep(1000*60*10);
+
+            mqttClient.disconnect();
+        } catch (MqttException e) {
+            e.printStackTrace();
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}