物联网实战：Spring Boot MQTT和Paho客户端SDK，如何入门？

你想玩玩IoT嘛？ 别急，先把思路梳理清楚。 我这就来给你讲讲怎么用Spring Boot搞MQTT。 别kan名字大佬多，实际上一套代码跑起来也没那么难。 下面咱们就从Zui基础的依赖说起。

在你的pom.xml里加个Paho的MQTT客户端：

    org.eclipse.paho
    org.eclipse.paho.mqttv5.client
    

我们先写一个小工具类，用来存放clientId、topic和broker地址。 这里演示的是免费公共Broker，你Ke以随便换成自己的。

package com.jysemel.iot;
public class ClientId {
    public static String clientId_1 = "jysemel-test-";
    public static String clientId_2 = "jysemel-test-";
    public static String topic = "demo-test-hello";
    // 免费的公共broker服务
    public static String brokerUrl = "tcp://broker.example.com:";
}

下面这段代码演示了怎样发布消息到MQTT Broker。 我一开始写的时候就有点乱，后来才改成现在这样。

package com.jysemel.iot;
import lombok.SneakyThrows;
import org.eclipse.paho.mqttv5.client.MqttClient;
import org.eclipse.paho.mqttv5.client.MqttConnectionOptions;
import org.eclipse.paho.mqttv5.common.MqttMessage;
/** 
 * MQTT 消息发布示例类 
 * 用于演示如何连接到 MQTT Broker 并发布消息 
 */
public class MqttPublishDemo {
    @SneakyThrows
    public static void main {
        // 获取固定的客户端ID
        String clientId = ClientId.clientId_1;
        MqttClient client = null;
        try {
            // 创建 MQTT 客户端实例
            client = new MqttClient;
            // 配置 MQTT 连接选项
            MqttConnectionOptions options = new MqttConnectionOptions;
            // 设置为全新会话，不保留历史数据
            options.setCleanStart;
            // 启用自动重连功Neng
            options.setAutomaticReconnect;
            // 连接超时时间设置为10秒
            options.setConnectionTimeout;
            // 心跳间隔设置为20秒
            options.setKeepAliveInterval;
            // 连接到 Broker
            client.connect;
            System.out.println;
            // 循环发布5条消息
            for  {
                String payload = "消息 " + i + " 时间: " + System.currentTimeMillis;
                MqttMessage msg = new MqttMessage);
                msg.setQos;   // 至少送达一次
                client.publish;
                System.out.println;
                Thread.sleep;   // 暂停1秒后发布下一条
            }
            // 断开与 Broker 的连接
            client.disconnect;
            System.out.println;
        } finally {
            if  {
                client.close;
            }
        }
    }
}

订阅可比发布geng复杂一点，因为你需要实现回调接口来处理消息。 下面这段代码给你一个完整的实现框架。

package com.jysemel.iot;
import org.eclipse.paho.mqttv5.client.*;
import org.eclipse.paho.mqttv5.common.MqttException;
import org.eclipse.paho.mqttv5.common.MqttMessage;
import java.nio.charset.StandardCharsets;
/** 
 * MQTT 消息订阅示例类 
 * 实现了 MqttCallback 接口，用于接收和处理 MQTT 消息 
 */
public class MqttSubscribeDemo implements MqttCallback {
    private final MqttClient client;
    public MqttSubscribeDemo throws MqttException {
        this.client = new MqttClient;
        this.client.setCallback;   // 注册回调处理器
    }
    public void start throws Exception {
        MqttConnectionOptions options = new MqttConnectionOptions;
        options.setCleanStart;
        options.setAutomaticReconnect;
        System.out.println;
        client.connect;
        System.out.println);
        client.subscribe;   // QoS=1订阅主题
        System.out.println;
    }
    public void stop {
        try {
            if ) {   // Ru果仍连着，就先断开
                client.disconnect;
                System.out.println;
            }
            client.close;               // 关闭客户端释放资源
        } catch  { 
           e.printStackTrace; 
       }
   }
   /* ======== 回调方法实现 ======== */
   @Override public void messageArrived {
       String payload = new String, StandardCharsets.UTF_8);
       System.out.printf%n", topic,payload,message.getQos);
   }
   @Override public void disconnected{}
   @Override public void mqttErrorOccurred{
       System.err.println);
   }
   @Override public void deliveryComplete{}
   @Override public void connectComplete{
       System.out.println;
   }
   /* ===== 主程序入口 ===== */
   public static void main throws Exception{
       String broker=ClientId.brokerUrl;
       String cid=ClientId.clientId_2;
       MqtSubscribeDemo demo=new);
       demo.start;
       System.out.println;
       System.in.read;         
       demo.stop;
     }
}

topic和clientID规范

- 别把topic随便拼成大写字母或者含特殊字符，否则Broker会拒绝。

- 每台设备dou得有唯一clientID；否则会互相覆盖。

网络抖动怎么办？

- 自动重连开启后大多数情况下就Neng自动恢复。

- 若频繁掉线，Ke以考虑降低keepAlive时间或改用QoS=2。

Maven配置错误常见症状

- 编译报“找不到Moqt…”，那是因为版本号漏填了。

- 不要直接把JDK版本锁死在9以下否则Spring Boot可Neng不兼容。

- 内容被判定为“低质量”或重复度过高，搜索引擎算法会降权；

- 缺少站外链接或社交媒体分享量不足，导致权重不足；

- 对于技术博客来说Ru果没有足够的外链或者未提交站点地图，也会被忽略。

只要你掌握了下面几个步骤，就Neng快速跑通一个基于Spring Boot+Paho的MQTT Demo： ① 把依赖加进去；② 写好配置类；③ 编写发布/订阅逻辑；④ 测试连通性；⑤ 调试出现的问题。 别怕犯错，那就是学习的一部分。不懂就问，同学们一起搞！哈哈～咱就是说只要你保持好奇心，IoT世界真的hen酷炫。 再说一句，我知道你一定会搞定这些，只是偶尔需要点小技巧而Yi。祝编码愉快！🙌💡 — 咱们下次再聊新技术啦！ 结束语：Ru果还有什么疑问或者想深入讨论，请随时留言，我这边也乐意帮忙~ 🚀 END.