|
...
|
...
|
@@ -6,6 +6,7 @@ import com.zhonglai.luhui.device.analysis.comm.util.ByteUtil; |
|
|
|
import com.zhonglai.luhui.device.analysis.util.TopicUtil;
|
|
|
|
import com.zhonglai.luhui.device.protocol.factory.comm.DataLogType;
|
|
|
|
import com.zhonglai.luhui.device.protocol.factory.comm.DeviceDataLog;
|
|
|
|
import com.zhonglai.luhui.device.protocol.factory.plugins.FileChangeListener;
|
|
|
|
import com.zhonglai.luhui.device.protocol.factory.service.impl.DefaultDbService;
|
|
|
|
import org.eclipse.paho.client.mqttv3.MqttClient;
|
|
|
|
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
|
|
...
|
...
|
@@ -20,6 +21,7 @@ import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
import javax.annotation.PostConstruct;
|
|
|
|
import javax.annotation.PreDestroy;
|
|
|
|
import java.io.IOException;
|
|
|
|
import java.util.ArrayList;
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.concurrent.ExecutorService;
|
|
...
|
...
|
@@ -37,10 +39,10 @@ public class TerminalService { |
|
|
|
private MqttCallback mqttCallback;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
private DefaultDbService dbService;
|
|
|
|
private SysParameter sysParameter;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
private SysParameter sysParameter;
|
|
|
|
private FileChangeListener fileChangeListener;
|
|
|
|
|
|
|
|
@Value("${mqtt.broker}")
|
|
|
|
private String broker;
|
|
...
|
...
|
@@ -97,7 +99,8 @@ public class TerminalService { |
|
|
|
}
|
|
|
|
|
|
|
|
@PostConstruct
|
|
|
|
public void startMqttListenerService() throws MqttException {
|
|
|
|
public void startMqttListenerService() throws MqttException, IOException {
|
|
|
|
fileChangeListener.onApplicationEvent();
|
|
|
|
log.info("-----------开始启动mqtt监听服务--------------------");
|
|
|
|
init();
|
|
|
|
log.info("-----------启动参数{}--------------------",options);
|
...
|
...
|
|