java接收mqtt协议的代码

当使用Java接收MQTT协议时，可以使用Eclipse Paho客户端库来实现。以下是一个简单的示例代码，用于接收MQTT消息：

首先，确保已经添加了Eclipse Paho MQTT客户端库的依赖。可以在Maven项目中添加以下依赖项：

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

然后，可以使用以下代码来接收MQTT消息：

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

public class MqttSubscriber {

    public static void main(String[] args) {
        String broker = "tcp://mqtt.example.com:1883"; // MQTT broker的地址
        String clientId = "JavaMqttSubscriber"; // 客户端ID
        String topic = "myTopic"; // 订阅的主题

        try {
            MqttClient mqttClient = new MqttClient(broker, clientId, new MemoryPersistence());
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);

            mqttClient.setCallback(new MqttCallback() {
                public void connectionLost(Throwable cause) {
                    System.out.println("连接丢失");
                }

                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("接收到消息：" + new String(message.getPayload()));
                }

                public void deliveryComplete(IMqttDeliveryToken token) {
                    // 消息发送完成
                }
            });

            mqttClient.connect(connOpts);
            mqttClient.subscribe(topic);

        } catch (MqttException me) {
            me.printStackTrace();
        }
    }
}

在上述代码中，需要替换`broker`变量为实际的MQTT broker地址，`clientId`为客户端ID，`topic`为要订阅的主题。在`messageArrived`方法中，可以处理接收到的消息。