硬件数据推送

xuhy

2 天以前 ba2e6c5fa2e21f535da27f29e54da2d6c7eb9aaa

 ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/mqtt/callback/PushCallback.java

@@ -35,11 +35,8 @@
    public void connectionLost(Throwable throwable) {
        if (client == null || !client.isConnected()) {
            System.out.println("连接断开，正在重连....");
            int[] Qos  = {0};
            String[] topic1 = {TopicConstants.CHARGE_PILE_CODE};
            try {
                client.connect(options);
                client.subscribe(topic1, Qos);
                log.info("连接失败重连成功");
            } catch (MqttException e) {
                log.info("连接失败重连失败");