完善代码

liurunyu

2025-08-14 04dc21b07c4e8b78d16cceb9a078ecd3a5c4470a

 pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttMsgSender.java

New file
@@ -0,0 +1,27 @@
package com.dy.pipIrrApp.workOrder.mqtt;

import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * @author ZhuBaoMin
 * @date 2024-11-16 11:28
 * @LastEditTime 2024-11-16 11:28
 * @Description 消息发送方法
 */

@Slf4j
public class MqttMsgSender {
    public void sendMessage(MqttClient client, String topic, String content, int qos){
        MqttMessage message = new MqttMessage(content.getBytes());
        message.setQos(qos);
        try{
            client.publish(topic,message);
        } catch (MqttException e){
            log.error("MqttClient publish text info Error:{}!", e.getMessage());
            e.printStackTrace();
        }
    }
}