SpringBoot整合MQTT实现消息发送

SpringBoot整合MQTT实现消息发送

MQTT作为一种轻量级的消息传输协议，在物联网领域应用广泛。本文将介绍如何在SpringBoot项目中整合MQTT，并实现消息发送功能。

1. 添加MQTT依赖

首先，我们需要在项目的 pom.xml 文件中添加Eclipse Paho MQTT客户端库的依赖：

<dependencies>
    <!-- Spring Boot Starter Web -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <!-- Eclipse Paho MQTT Client -->
    <dependency>
        <groupId>org.eclipse.paho</groupId>
        <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
        <version>1.2.5</version>
    </dependency>
</dependencies>

2. 创建MQTT消息发送类

接下来，我们创建一个名为 MqttSender 的类，用于处理MQTT消息发送：

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.stereotype.Component;

@Component
public class MqttSender {

    private static final String BROKER = 'tcp://mqtt.eclipse.org:1883';
    private static final String TOPIC = 'topic/test';
    private static final String CLIENT_ID = 'mqtt-sender';

    public void sendMessage(String message) {
        try {
            MqttClient mqttClient = new MqttClient(BROKER, CLIENT_ID, new MemoryPersistence());

            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);

            mqttClient.connect(connOpts);

            MqttMessage mqttMessage = new MqttMessage(message.getBytes());
            mqttMessage.setQos(0);

            mqttClient.publish(TOPIC, mqttMessage);

            mqttClient.disconnect();
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

在上述代码中，我们定义了MQTT代理地址、主题和客户端ID，并实现了 sendMessage 方法用于发送消息。

3. 创建控制器类发送消息

最后，我们创建一个控制器类，用于接收HTTP请求并调用 MqttSender 发送消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    @Autowired
    private MqttSender mqttSender;

    @GetMapping('/send/{message}')
    public String sendMqttMessage(@PathVariable String message) {
        mqttSender.sendMessage(message);
        return 'Message sent: ' + message;
    }
}

访问 /send/{message} 接口即可发送MQTT消息，其中 {message} 为要发送的消息内容。

总结

本文介绍了如何在SpringBoot项目中整合MQTT并实现消息发送功能。你可以根据实际需求修改MQTT代理地址、主题和消息内容。需要注意的是，在运行代码之前，请确保你已经正确配置了MQTT代理，并启动了代理服务。