package com.tuoheng.admin.mqtt; | package com.tuoheng.admin.mqtt; | ||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; | |||||
import com.tuoheng.admin.mqtt.consumer.MqttConsumerCallBack; | import com.tuoheng.admin.mqtt.consumer.MqttConsumerCallBack; | ||||
import com.tuoheng.common.core.utils.IpUtils; | import com.tuoheng.common.core.utils.IpUtils; | ||||
import lombok.extern.slf4j.Slf4j; | import lombok.extern.slf4j.Slf4j; | ||||
client.setCallback(new MqttConsumerCallBack()); | client.setCallback(new MqttConsumerCallBack()); | ||||
client.connect(options); | client.connect(options); | ||||
client.subscribe("$share/g1/v1/298dd766/environment/message", 0); | |||||
String topic = "/v1/298dd766/environment/message"; | |||||
log.info("拓恒大气监测系统,订阅:topic={}", topic); | |||||
client.subscribe(topic, 0); | |||||
} catch (MqttException e) { | } catch (MqttException e) { | ||||
e.printStackTrace(); | e.printStackTrace(); | ||||
} | } |
password: public | password: public | ||||
#客户端id(不能重复) | #客户端id(不能重复) | ||||
client: | client: | ||||
id: tuoheng-airmonitor-consumer-id | |||||
id: tuoheng-airmonitor-id | |||||
#MQTT默认的消息推送主题,实际可在调用接口是指定 | #MQTT默认的消息推送主题,实际可在调用接口是指定 | ||||
default: | default: | ||||
topic: topic | topic: topic |
password: | password: | ||||
#客户端id(不能重复) | #客户端id(不能重复) | ||||
client: | client: | ||||
id: tuoheng-airmonitor-consumer-id | |||||
id: tuoheng-airmonitor-id | |||||
#MQTT默认的消息推送主题,实际可在调用接口是指定 | #MQTT默认的消息推送主题,实际可在调用接口是指定 | ||||
default: | default: | ||||
topic: topic | topic: topic |
password: admin##123 | password: admin##123 | ||||
#客户端id(不能重复) | #客户端id(不能重复) | ||||
client: | client: | ||||
id: tuoheng-airmonitor-consumer-id | |||||
id: tuoheng-airmonitor-id | |||||
#MQTT默认的消息推送主题,实际可在调用接口是指定 | #MQTT默认的消息推送主题,实际可在调用接口是指定 | ||||
default: | default: | ||||
topic: topic | topic: topic |
password: admin##123 | password: admin##123 | ||||
#客户端id(不能重复) | #客户端id(不能重复) | ||||
client: | client: | ||||
id: tuoheng-airmonitor-consumer-id | |||||
id: tuoheng-airmonitor-id | |||||
#MQTT默认的消息推送主题,实际可在调用接口是指定 | #MQTT默认的消息推送主题,实际可在调用接口是指定 | ||||
default: | default: | ||||
topic: topic | topic: topic |