mqtt调整：实现订阅多个mqtt服务

zouyu

昨天 69310a7de3d963c2bf46250b0965a2c7e8532f1e

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
package com.ruoyi.web;
 
import com.ruoyi.device.mqtt.DeviceMqttConfig;
import com.ruoyi.device.mqtt.MQClient;
import com.ruoyi.device.mqtt.MQConfig;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;
 
import java.util.Objects;
 
@Component
@Slf4j
public class MqttApplicationRunner implements ApplicationRunner {
 
    @Autowired
    private MQConfig mqConfig;
 
//    @Value("${mqtt.client}")
//    private Boolean client;
 
    @Override
    public void run(ApplicationArguments args) throws MqttException {
        if(Objects.nonNull(mqConfig)){
            for (DeviceMqttConfig deviceMqttConfig : mqConfig.getMqtt()) {
                if (deviceMqttConfig.getClient()) {
                    MQClient mqttPushClient = new MQClient();
                    mqttPushClient.connect(deviceMqttConfig);
                }
            }
        }
    }
}