java mqtt 连接

要连接到 MQTT 服务器，你需要使用 MQTT 客户端库。以下是在 Java 中使用 Eclipse Paho 客户端库连接到 MQTT 服务器的示例代码：

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

public class MqttClientExample implements MqttCallback {
    private MqttClient client;

    public void connect(String brokerUrl, String clientId, String topic) throws MqttException {
        client = new MqttClient(brokerUrl, clientId);
        client.setCallback(this);
        MqttConnectOptions options = new MqttConnectOptions();
        options.setCleanSession(true);
        client.connect(options);
        client.subscribe(topic);
    }

    // Implement callback methods
    public void connectionLost(Throwable cause) {
        // Handle connection lost
    }

    public void messageArrived(String topic, MqttMessage message) throws Exception {
        // Handle incoming messages
    }

    public void deliveryComplete(IMqttDeliveryToken token) {
        // Handle message delivery complete
    }
}

在上面的代码示例中，我们创建了一个名为 `MqttClientExample` 的类，它实现了 `MqttCallback` 接口。这个类包含了连接到 MQTT 服务器的方法 `connect()`，并且订阅了一个主题。当收到消息时，`messageArrived()` 方法将被调用。在此示例中，我们只是简单地打印了收到的消息，你可以根据需要来处理消息。