写一个MQTT的Java client

当然，我可以为您提供一个基本的MQTT Java客户端示例代码。请注意，您需要确保已经安装了Eclipse Paho MQTT库。

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

public class MqttClientExample {
    public static void main(String[] args) {
        String broker = "tcp://mqtt.eclipse.org:1883";
        String clientId = "JavaClient";
        String topic = "test/topic";

        try {
            MqttClient mqttClient = new MqttClient(broker, clientId);
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);

            mqttClient.connect(connOpts);
            System.out.println("Connected to MQTT broker");

            mqttClient.subscribe(topic);
            System.out.println("Subscribed to topic: " + topic);

            mqttClient.setCallback(new MqttCallback() {
                public void connectionLost(Throwable cause) {
                    System.out.println("Connection lost: " + cause.getMessage());
                }

                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("Received message: " + new String(message.getPayload()));
                }

                public void deliveryComplete(IMqttDeliveryToken token) {
                    // Not used in this example
                }
            });
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

上述示例代码创建了一个MQTT客户端，连接到指定的MQTT代理服务器（`broker`）。然后，它订阅了一个特定的主题（`topic`），并设置了一个回调函数来处理接收到的消息。当您运行此代码时，它将连接到MQTT代理并开始接收消息。

请注意，这只是一个简单的示例，你可以根据自己的需求进行扩展和修改。另外，确保在使用此代码之前替换有效的MQTT代理地址、客户端ID和主题。

希望对您有所帮助！如果您有任何其他问题，请随时提问。