在Java中，您可以使用 Eclipse Paho MQTT 客戶端庫來連接到 MQTT 服務器。以下是一個簡單的示例代碼，展示如何使用 Eclipse Paho MQTT 客戶端庫來連接到 MQTT 服務器：

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;

public class MQTTClient {

    public static void main(String[] args) {
        String broker = "tcp://broker.hivemq.com:1883";
        String clientId = "JavaClient";
        
        try {
            MqttClient client = new MqttClient(broker, clientId);
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);
            
            client.connect(connOpts);
            
            System.out.println("Connected to MQTT broker: " + broker);
            
            // Do something with the MQTT client
            
            client.disconnect();
            System.out.println("Disconnected from MQTT broker");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在這個示例中，我們創建了一個 MqttClient 對象，并指定了要連接到的 MQTT 服務器的地址和客戶端ID。然后，我們創建了一個 MqttConnectOptions 對象，設置了 cleanSession 選項，并調用 connect() 方法來連接到 MQTT 服務器。最后，我們做一些操作，然后調用 disconnect() 方法來斷開與 MQTT 服務器的連接。

您可以根據需要修改以上代碼，以滿足您的具體需求。請注意，您需要在項目中添加 Eclipse Paho MQTT 客戶端庫的依賴，以便能夠使用該庫。