Java EMqtt客户端怎样连接到服务器

要使用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服务器，订阅指定主题，并在接收到消息时打印消息内容。您可以根据需要修改回调方法来实现自定义的消息处理逻辑。