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=确保送达，不重复）