使用Spring boot 框架实现MQTT数据存储到ｍｙｓｑｌ

使用Spring Boot框架结合MQTT（Message Queuing Telemetry Transport）和MySQL数据库来实现消息存储，可以按照以下步骤操作：

1. **添加依赖**：
- 首先，在你的`pom.xml`文件中添加Spring Boot MQTT和JPA（Java Persistence API）的依赖，例如：

   <dependencies>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-messaging</artifactId>
       </dependency>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-data-jpa</artifactId>
       </dependency>
       <!-- 如果需要连接MySQL -->
       <dependency>
           <groupId>mysql</groupId>
           <artifactId>mysql-connector-java</artifactId>
       </dependency>
   </dependencies>

2. **配置MQTT**：
- 创建`application.properties`或`application.yml`文件，设置MQTT服务器的相关信息，如主机名、端口、用户名和密码等。例如：

   spring.cloud.stream.bindings.input.destination=mqtt-topic
   spring.messagining.broker-url=tcp://localhost:1883

3. **创建实体类（Message Entity）**：
- 定义一个表示MQTT消息的Java实体类，通常包含一个String字段来保存消息内容，并可能包含时间戳属性。

4. **定义Repository接口**：
- 实现JpaRepository接口来处理数据库操作，如保存、查询和删除消息记录。

5. **MQTT Message Handler**：
- 创建一个监听MQTT消息的处理器类，实现MessageHandler接口，当接收到MQTT消息时，解析消息并将其保存到数据库。

@Component
public class MqttMessageHandler implements MessageHandler {
    private final MyDatabaseRepository repository;

    public MqttMessageHandler(MyDatabaseRepository repository) {
        this.repository = repository;
    }

    @Override
    public void handleMessage(Message<?> message) {
        String payload = message.getBody().toString();
        MyMessage myMessage = new MyMessage(payload);
        repository.save(myMessage);
    }
}

6. **启动应用程序**：
- 启动Spring Boot应用，MQTT消费者会自动运行，每当接收到MQTT消息，它就会将消息转换成Entity对象并保存到MySQL数据库中。