java idea mqtt 示例代码

Java IDEA中使用MQTT的示例代码可以参考如下步骤：

1. 首先需要在项目中引入MQTT的相关依赖，比如paho-mqtt-client。

2. 在Java代码中创建一个MQTT客户端对象，并设置连接参数，比如连接的地址、客户端ID、用户名和密码等。

3. 设置客户端的回调函数，可以处理接收到的消息。

4. 连接MQTT服务器。

5. 发布消息或者订阅某个主题。

以下是一个简单的示例代码：

import org.eclipse.paho.client.mqttv3.*;

public class MqttTest {
    public static void main(String[] args) throws MqttException {
        // 创建MQTT客户端
        MqttClient mqttClient = new MqttClient("tcp://localhost:1883", "JavaClient");
        // 设置连接参数
        MqttConnectOptions connOpts = new MqttConnectOptions();
        connOpts.setUserName("username");
        connOpts.setPassword("password".toCharArray());
        // 设置回调函数
        mqttClient.setCallback(new MqttCallback() {
            @Override
            public void connectionLost(Throwable throwable) {
                System.out.println("Connection lost");
            }

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

            @Override
            public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
                System.out.println("Delivery complete");
            }
        });
        // 连接服务器
        mqttClient.connect(connOpts);
        // 发布消息
        MqttMessage message = new MqttMessage("Hello World".getBytes());
        mqttClient.publish("test", message);
        // 订阅主题
        mqttClient.subscribe("test");
    }
}

以上代码演示了一个简单的MQTT客户端的创建、连接、发布消息和订阅主题的过程。你可以根据自己的需求修改代码，实现更复杂的MQTT应用。