package com.ruoyi.dataInterchange.util.mqtt;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.messaging.Message;
|
import org.springframework.messaging.MessageHandler;
|
import org.springframework.messaging.MessageHeaders;
|
import org.springframework.messaging.MessagingException;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* @author zhibing.pu
|
* @Date 2025/5/23 17:30
|
*/
|
@Slf4j
|
@Component
|
public class MqttReceiverMessageHandler implements MessageHandler {
|
|
@Override
|
public void handleMessage(Message<?> message) throws MessagingException {
|
MessageHeaders headers = message.getHeaders();
|
log.info("线程名称：{}，收到消息，主题：{}，消息：{}", Thread.currentThread().getName(), headers.get("mqtt_receivedTopic").toString(), message.getPayload());
|
// log.info("收到消息主题：{}", headers.get("mqtt_receivedTopic").toString());
|
// log.info("收到消息：{}", message.getPayload());
|
// 消息保存到内存队列里面，定时批量入库，也可以在这里直接入库
|
}
|
}
|
