mqtt，java实现连接，并监听指定topic的消息，往指定topic发布命令，实现数据交互

MQTT (Message Queuing Telemetry Transport) 是一种轻量级的、基于发布/订阅模式的通信协议，常用于物联网(IoT)设备间的数据传输。在 Java 中实现 MQTT 连接并监听主题消息，通常会利用第三方库如 Eclipse Paho 或者 Atmosphere 进行简化。

以下是基本步骤：

1. **添加依赖**：如果你选择 Eclipse Paho，可以在项目中添加 Maven 或 Gradle 的依赖。例如 Maven 里添加到 `pom.xml` 文件中：

   <dependency>
       <groupId>org.eclipse.paho</groupId>
       <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
       <version>1.2.5</version>
   </dependency>

2. **创建连接**：

   MqttClient client = new MqttClient("tcp://your-broker-url:1883", "your-client-id");
   client.connect();

3. **订阅主题**：

   client.subscribe(new MqttTopic("your-topic"));
   client.setCallback(new MqttCallback() {
       // 实现回调处理接收到的主题消息
       @Override
       public void messageArrived(String topic, MqttMessage message) throws Exception {
           System.out.println("Received message on topic " + topic);
       }
   });

4. **发布消息**：

   MqttMessage message = new MqttMessage("your-message".getBytes());
   client.publish("your-topic", message, QoS.AT_MOST_ONCE);

5. **断开连接**：

   client.disconnect();