小编典典

最好的方法是构造连接逻辑,使其独立存在于一个方法中,以便可以从实例的connectionLost回调中再次调用它MqttCallback。

该connectionLost方法通过Throwable传递,该异常将触发断开连接,因此您可以决定根本原因以及重新连接的时间/方式的影响。

连接方法应连接并订阅您所需的主题。

像这样:

public class PubSub {

MqttClient client;

String topics[] = ["foo/#", "bar"];

MqttCallback callback = new MqttCallback() {

public void connectionLost(Throwable t) {

this.connect();

}

public void messageArrived(String topic, MqttMessage message) throws Exception {

System.out.println("topic - " + topic + ": " + new String(message.getPayload()));

}

public void deliveryComplete(IMqttDeliveryToken token) {

}

};

public static void main(String args[]) {

PubSub foo = new PubSub();

}

public PubSub(){

this.connect();

}

public void connect(){

client = new MqttClient("mqtt://localhost", "pubsub-1");

client.setCallback(callback);

client.connect();

client.subscribe(topics);

}

}

2020-11-16

java paho_Java Eclipse Paho实现-自动重新连接相关推荐

  1. eclipse paho java_Eclipse paho学习笔记

    Eclipse Paho java 支持java和android 两个客户端异步和同步, MqttAsyncClient,MqttClient 其中 后者是前者的包装同步器,特效除了5.0都支持 有两 ...

  2. java mqtt paho_使用eclipse paho在java端实现MQTT消息的收发(客户端与服务端实例)...

    一.MQTT(消息队列)简介 MQTT(MQ Telemetry Transport)是IBM开发的一种网络应用层的协议,提供轻量级的,支持可发布/可订阅的的消息推送模式,使设备对设备之间的短消息通信 ...

  3. eclipse paho java_如何使用Eclipse Paho在Java MQTT客户端上接收时发布消息

    我正在尝试使用 Eclipse Paho在Java中的MQTT客户端上实现某些功能.目标是订阅主题,并且当收到消息时,客户端发送关于另一主题的另一消息. 这看起来很容易,但我有一个奇怪的问题,我无法解 ...

  4. java设置代码自动提示_eclipse代码自动提示设置、如何配置eclipse的代码自动提示功能?...

    对于编程人员来说,要记住大量的类名或类方法的名字,着实不是一件容易的事情.如果要IDE能够自动补全代码,那将为我们编程人员带来很大帮助. EcliPSe代码里面的代码提示功能默认是关闭的,只有输入&q ...

  5. MQTT基本应用(Mosquitto+Eclipse Paho)

    本文主要介绍,MQTT 基本概念和实现方式: 1.概述 1.1MQTT协议 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输协议),由IBM在1999 ...

  6. Eclipse Paho MQTT Python Client 使用手册

    Eclipse Paho MQTT Python Client 使用手册 原文地址:https://www.cooooder.com/archives/20210303 目录 介绍 环境 准备 快速开 ...

  7. API for org.eclipse.paho.client.mqttv3

    org.eclipse.paho.client.mqttv3的包结构如下: org.eclipse.paho.client.mqttv3 InterfacesIMqttActionListenerIM ...

  8. java基础-Eclipse开发工具介绍

    java基础-Eclipse开发工具介绍 作者:尹正杰 版权声明:原创作品,谢绝转载!否则将追究法律责任. 所谓工欲善其事必先利其器,即将身为一名Java开发工程师怎么能没有一款好使的IDE呢?今天就 ...

  9. android reboot 定时重启可靠吗,请教一下有人做过安卓系统 reboot 重启之后,appium 能自动重新连接吗...

    就是我用 adb 的命令重启手机,然后 usb 是一直连着的,重启之后,我想做尝试能让 appium 自动重新连接 尝试过先让 driver.quit(); //driver 先退出 Thread.s ...

最新文章

  1. [译]Reduce(软件编写)(第五部分)
  2. No architectures to compile for (ONLY_ACTIVE_ARCH=YES, active arch=armv7s, VALID_ARCHS=armv7 armv6)
  3. 中国古代历朝首都一览
  4. 19款探岳刷隐藏教程_三星S10系列如何隐藏导航栏 官微“手把手”教你设置
  5. Linux终端下翻页操作
  6. ASP.NET站点性能提升-缩短首页生成时间
  7. EthBox以太坊开发套件,一键安装部署以太坊开发环境
  8. 【Android开发】之Android环境搭建及HelloWorld
  9. 判断 失效_复合材料渐进失效Hashin模型及参数详解
  10. 录计算机,电脑屏幕上的操作怎么录制下来?
  11. python人脸识别代码实现
  12. 机器视觉需要掌握的知识
  13. 【项目管理】Java OCR实现图片文字识别
  14. JavaScript学习(三)
  15. ResNet(残差网络)之残差模块
  16. 【帝国CMS】灵动标签调用标题图片没有图片时显示默认图片
  17. Kali Linux实战:如何一下看出Windows计算机是否开启445危险端口?是否存在永恒之蓝漏洞?
  18. C#利用控件拖拽技术制作拼图游戏
  19. 文本纠错--CRASpell模型
  20. egpu+mac+bootcamp

热门文章

  1. 微服务07-负载均衡
  2. 汉字 计算机 坟墓,墓字的意思4、墓的繁体字、墓的笔顺笔画、墓字部首和繁体字墓的意思...
  3. 动态规划:回文串系列
  4. 腾讯8分钟产品课—用户
  5. 微信小程序学习之路——表单组件(一)
  6. POJ 2142 The Balance(扩展欧几里德)
  7. 仁兄,可曾听闻支持向量机?
  8. 工作族必备的备忘录时间管理APP软件
  9. Python 列表的使用
  10. python因子分析论文_Python——因子分析(KMO检验和Bartlett's球形检验)