Java代码实现发送抬杆的mqtt消息示例

好的，以下是Java代码实现发送抬杆的mqtt消息的示例：

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

public class MqttPublisher {
    public static void main(String[] args) {
        String topic = "抬杆";
        String content = "1";
        int qos = 2;
        String broker = "tcp://localhost:1883";
        String clientId = "JavaSample";
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            MqttClient client = new MqttClient(broker, clientId, persistence);
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);
            System.out.println("Connecting to broker: " + broker);
            client.connect(connOpts);
            System.out.println("Connected");
            System.out.println("Publishing message: " + content);
            MqttMessage message = new MqttMessage(content.getBytes());
            message.setQos(qos);
            client.publish(topic, message);
            System.out.println("Message published");
            client.disconnect();
            System.out.println("Disconnected");
            System.exit(0);
        } catch (MqttException me) {
            System.out.println("Reason: " + me.getReasonCode());
            System.out.println("Message: " + me.getMessage());
            System.out.println("Localized Message: " + me.getLocalizedMessage());
            System.out.println("Cause: " + me.getCause());
            System.out.println("Exception: " + me);
            me.printStackTrace();
        }
    }
}

代码说明：

- 通过 `MqttClient` 类创建一个 MQTT 客户端对象。客户端 ID 必须在连接时唯一，因此我们将其设置为 JavaSample。
- `MqttConnectOptions` 类使我们可以配置连接。这里我们只设置了一个，即清除会话（`setCleanSession(true)`）。
- `client.connect` 连接到 MQTT 经纪人（在此处为本地主机）。
- `client.publish` 发布主题为 "抬杆"，内容为 "1" 的消息。在这里，我们设置了服务质量（`setQos(qos)`）为 2，这意味着至少一次交付，并且我们的消息将被保存，直到我们收到经纪人的确认。
- 最后，我们关闭客户端，关闭连接并退出程序。

希望以上代码示例对您有所帮助！