在Java中實現MQTT連接，可以使用MQTT客戶端庫，如Eclipse Paho。以下是一個簡單的示例，展示了如何使用Eclipse Paho MQTT客戶端庫連接到MQTT代理：

1. 首先，確保已將Eclipse Paho MQTT客戶端庫添加到項目的依賴項中。如果使用Maven，可以在pom.xml文件中添加以下依賴：

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

2. 創建一個名為MQTTClientExample.java的Java類，并編寫以下代碼：

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://mqtt.example.com:1883"; // 替換為你的MQTT代理地址
        String clientId = "JavaSampleClient"; // 替換為你的客戶端ID
        String topic = "test/topic"; // 替換為你感興趣的主題

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

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

            // 設置連接回調
            client.setCallback(new MqttCallback() {
                @Override
                public void connectionLost(Throwable cause) {
                    System.out.println("連接丟失: " + cause.getMessage());
                }

                @Override
                public void messageArrived(String topic, MqttMessage message) {
                    System.out.println("收到消息: " + new String(message.getPayload()));
                }

                @Override
                public void deliveryComplete(IMqttDeliveryToken token) {
                    System.out.println("消息傳遞完成");
                }
            });

            // 連接到MQTT代理
            client.connect();

            // 訂閱感興趣的主題
            client.subscribe(topic);

            System.out.println("已連接到MQTT代理并訂閱了主題: " + topic);

            // 為了演示，這里讓主線程睡眠一段時間，以便觀察連接和消息接收
            Thread.sleep(60000);

            // 斷開連接
            client.disconnect();
            System.out.println("已斷開與MQTT代理的連接");

        } catch (Exception e) {
            System.out.println("發生異常: " + e.getMessage());
            e.printStackTrace();
        }
    }
}

3. 修改brokerUrl、clientId和topic變量，使其與你的MQTT代理設置相匹配。

4. 運行MQTTClientExample.java類，它將連接到MQTT代理，訂閱指定主題，并在接收到消息時打印消息內容。

注意：在實際應用中，你可能需要處理網絡中斷、重新連接等異常情況。這個示例僅用于演示基本的連接和訂閱功能。