mq创建连接

aijinhui

2023-11-15 6a24755c21e5ae90ddf30025680a0098479aad21

 ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttOnce.java

@@ -87,6 +87,7 @@
    public String publishCar(String carId,String topic,String message,String type) throws MqttException {
        MqttClient client = getMqttClient(carId);
        MqttConnectOptions options = getMqttConnectOptions();
        client.connect(options);
        MqttMessage msg = new MqttMessage(message.getBytes());
        msg.setQos(2);
        client.publish(topic,msg);