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();
|
}
|
}
|
}
|
