要使用Java MQTT客戶端連接到服務器，您需要首先添加MQTT客戶端庫依賴。如果您使用的是Maven項目，可以在pom.xml文件中添加以下依賴：

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

接下來，您可以使用以下代碼示例來創建一個簡單的Java MQTT客戶端，連接到服務器并訂閱主題：

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

public class MqttClientExample {

    public static void main(String[] args) {
        String brokerUrl = "tcp://your_mqtt_server_address:port"; // 例如: "tcp://broker.hivemq.com:1883"
        String clientId = "your_client_id"; // 例如: "JavaSampleClient"
        String topic = "your_topic"; // 例如: "test/topic"

        // 創建一個內存中的持久化對象
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            // 創建一個MQTT客戶端實例
            MqttClient client = new MqttClient(brokerUrl, clientId, persistence);

            // 連接到MQTT服務器
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);
            client.connect(connOpts);

            // 訂閱指定主題
            client.subscribe(topic);

            // 設置消息回調和處理邏輯
            client.setCallback(new MqttCallback() {
                @Override
                public void messageArrived(String topic, MqttMessage message) {
                    System.out.println("Message arrived: " + new String(message.getPayload()));
                }

                @Override
                public void connectionLost(Throwable cause) {
                    System.out.println("Connection lost: " + cause.getMessage());
                }

                @Override
                public void deliveryComplete(IMqttDeliveryToken token) {
                    System.out.println("Delivery complete");
                }
            });

            // 保持客戶端運行，以便持續接收消息
            Thread.sleep(60000);

        } catch (Exception e) {
            System.out.println("Error: " + e.getMessage());
            e.printStackTrace();
        }
    }
}

請確保將your_mqtt_server_address、port、your_client_id和your_topic替換為您的實際MQTT服務器地址、端口、客戶端ID和訂閱的主題。

這個示例代碼會連接到MQTT服務器，訂閱指定主題，并在接收到消息時打印消息內容。您可以根據需要修改回調方法來實現自定義的消息處理邏輯。