使用java语言写一段接收mqtt消息的代码，并集成mytbatis_plus插件，放到mysql数据中，并带上详细的代码注释

好的，以下是代码和注释：

import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@MapperScan("com.example.demo.mapper") // MyBatis Plus扫描Mapper接口的注解
public class MqttApplication {

    public static void main(String[] args) {
        SpringApplication.run(MqttApplication.class, args);

        String topic = "test"; // 订阅的主题
        int qos = 2; // 消息的服务质量
        String broker = "tcp://localhost:1883"; // MQTT Broker的地址
        String clientId = "JavaSample"; // 客户端ID
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);
            System.out.println("Connecting to broker: " + broker);
            sampleClient.connect(connOpts);
            System.out.println("Connected");

            sampleClient.setCallback(new MqttCallback() {
                public void connectionLost(Throwable throwable) {
                    System.out.println("Connection lost");
                }

                public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
                    String message = new String(mqttMessage.getPayload());
                    System.out.println("Message received: " + message);

                    // 将消息存储到MySQL数据库中
                    MyMessage myMessage = new MyMessage();
                    myMessage.setContent(message);
                    myMessage.setTimestamp(System.currentTimeMillis());
                    myMessageMapper.insert(myMessage);
                }

                public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
                    System.out.println("Delivery complete");
                }
            });

            sampleClient.subscribe(topic, qos);
            System.out.println("Subscribed to topic: " + topic);

        } catch (MqttException me) {
            System.out.println("reason " + me.getReasonCode());
            System.out.println("msg " + me.getMessage());
            System.out.println("loc " + me.getLocalizedMessage());
            System.out.println("cause " + me.getCause());
            System.out.println("excep " + me);
            me.printStackTrace();
        }
    }
}

注释：

- `@MapperScan("com.example.demo.mapper")`：使用MyBatis Plus插件需要扫描Mapper接口的包路径。
- `String topic = "test";`：订阅的主题。
- `int qos = 2;`：消息的服务质量，这里设置为2，表示消息至少被传递一次，确保消息的可靠性。
- `String broker = "tcp://localhost:1883";`：MQTT Broker的地址，这里使用本地的Broker。
- `String clientId = "JavaSample";`：客户端ID，可以自定义。
- `MemoryPersistence persistence = new MemoryPersistence();`：使用内存持久化方式。
- `MqttClient sampleClient = new MqttClient(broker, clientId, persistence);`：创建MQTT客户端。
- `MqttConnectOptions connOpts = new MqttConnectOptions();`：MQTT连接选项。
- `connOpts.setCleanSession(true);`：设置为true，表示客户端断开连接时，Broker会删除客户端的所有订阅和消息。
- `sampleClient.setCallback(new MqttCallback() {...});`：设置回调函数，当有消息到达时，会调用`messageArrived`方法。
- `MyMessage myMessage = new MyMessage();`：创建一个MyMessage对象，用于存储消息。
- `myMessage.setContent(message);`：设置消息内容。
- `myMessage.setTimestamp(System.currentTimeMillis());`：设置消息的时间戳。
- `myMessageMapper.insert(myMessage);`：将消息存储到MySQL数据库中。这里需要自己定义MyMessageMapper接口和对应的XML文件。
- `sampleClient.subscribe(topic, qos);`：订阅主题。

希望这个代码能够帮到你！