springboot mqtt进行断开自动重连
final CallbackConnection callbackConnection = mqtt.callbackConnection();
callbackConnection.listener(new Listener() {
@Override
public void onConnected() {
log.info("mqtt callback onConnected");
}
@Override
public void onDisconnected() {
log.info("mqtt callback onDisconnected");
}
@Override
public void onPublish(UTF8Buffer utf8Buffer, Buffer buffer, Runnable ack) {
//当有设备向服务已订阅的主题发送消息时,该方法会消费
String topic = utf8Buffer.utf8().toString();
String payload = buffer.utf8().toString();
log.info("mq监听接收到的消息{},{}", topic, payload);
ack.run();
}
@Override
public void onFailure(Throwable throwable) {
}
});
callbackConnection.connect(new Callback<Void>() {
@Override
public void onSuccess(Void aVoid) {
//连接成功后会默认订阅主题($client/mengsu)
log.info("连接成功");
}
@Override
public void onFailure(Throwable throwable) {
}
});
// 创建相关的MQTT 的主题列表
Topic[] topics = {new Topic(topic, QoS.EXACTLY_ONCE)};
callbackConnection.subscribe(topics, new Callback<byte[]>() {
@Override
public void onSuccess(byte[] qoses) {
//主题订阅成功
log.info("mqtt subscribe " + topic + " success");
}
@Override
public void onFailure(Throwable value) {
//状态主题订阅失败
}
});
MQTT 发布订阅
最后编辑于 :
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
- 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...