Java EMqtt客戶端怎樣連接到服務(wù)器

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

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

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

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"

        // 創(chuàng)建一個內(nèi)存中的持久化對象
        MemoryPersistence persistence = new MemoryPersistence();

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

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

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

            // 設(shè)置消息回調(diào)和處理邏輯
            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");
                }
            });

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

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

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

這個示例代碼會連接到MQTT服務(wù)器，訂閱指定主題，并在接收到消息時打印消息內(nèi)容。您可以根據(jù)需要修改回調(diào)方法來實(shí)現(xiàn)自定義的消息處理邏輯。