diff --git a/src/main/java/com/campus/water/config/MqttConfig.java b/src/main/java/com/campus/water/config/MqttConfig.java index c096b2d..e86e4ab 100644 --- a/src/main/java/com/campus/water/config/MqttConfig.java +++ b/src/main/java/com/campus/water/config/MqttConfig.java @@ -12,7 +12,7 @@ import org.springframework.messaging.MessageChannel; @Configuration public class MqttConfig { // MQTT 基础配置(可迁移到 application.yml 中,用 @ConfigurationProperties 绑定) - public static final String BROKER = "b17be106.ala.cn-hangzhou.emqxsl.cn:8883"; + public static final String BROKER = "ssl://b17be106.ala.cn-hangzhou.emqxsl.cn:8883"; public static final String USERNAME = "test1"; public static final String PASSWORD = "123456"; public static final int QOS = 1; // 消息质量等级(1=确保送达,不重复)