xinyin025/RuoYi-Vue-Plus
1
0
Fork 0
mirror of https://github.com/dromara/RuoYi-Vue-Plus.git synced 2026-01-23 15:45:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

update 优化 增加mqtt模块配置开关

Browse Source
This commit is contained in:
疯狂的狮子Li
2026-01-22 09:33:40 +08:00
parent 161b52d8d7
commit 4072b080fe
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ruoyi-common/ruoyi-common-mqtt/src/main/java/org/dromara/common/mqtt/config/MqttAutoConfiguration.java
View File

@@ -4,6 +4,7 @@ import org.dromara.common.mqtt.listener.MqttClientConnectListener;
import org.dromara.common.mqtt.listener.MqttClientGlobalMessageListener;
import org.dromara.mica.mqtt.core.client.MqttClientCreator;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
/**
@@ -17,6 +18,7 @@ import org.springframework.context.annotation.Bean;
* @author Lion Li
*/
@AutoConfiguration
@ConditionalOnProperty(value = "mqtt.client.enabled", havingValue = "true")
public class MqttAutoConfiguration {
@Bean

6
ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/MqttController.java
View File

@@ -8,6 +8,8 @@ import org.dromara.mica.mqtt.codec.message.MqttPublishMessage;
import org.dromara.mica.mqtt.core.annotation.MqttClientSubscribe;
import org.dromara.mica.mqtt.core.deserialize.MqttJsonDeserializer;
import org.dromara.mica.mqtt.spring.client.MqttClientTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@@ -30,7 +32,9 @@ import java.nio.charset.StandardCharsets;
@Slf4j
public class MqttController {
private final MqttClientTemplate client;
@Lazy
@Autowired
private MqttClientTemplate client;
@GetMapping("/send")
public boolean send() {