问题标签 [paho]

我有一个运行 mosquitto 的远程服务器。我可以使用 mosquitto_pub 和 mosquitto_sub 连接到该服务器并交换消息。如果我尝试使用一些带有 paho.mqtt.client 的 python 进行相同操作，我将无法连接。我的脚本一直在运行，但永远不会调用 on_connection 钩子。但是，相同的脚本可以在我的本地 mosquitto 服务器上完美运行。

连接问题的可能原因是什么？我怎样才能获得更多关于正在发生的事情的反馈？有什么建议么？

编辑：我添加了一个最小的代码示例

编辑2：在玩耍时，我注意到用“test.mosquitto.org”替换“localhost”导致OSError: [Errno 101] Network is unreachable虽然我通过mosquitto_sub连接它没有问题

我是 Android Open Accessor 的新手AOA，我想下载paho专为 Android 服务设计的库。

我在这里阅读了这个文档，但它在部分中Building from source说我必须应用这个命令

git clone http://git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.java.git

我真的不知道在哪里运行这个命令？是cmd命令还是什么？我真的不知道。

我是MQTT新手paho Libs for Android。今天我尝试创建一个简单的连接示例，如下所示，但是发生的情况是，logcat尽管代码中没有错误，但在运行时，我从下面发布的错误消息中得到了 eclipse 说can not run the projects due to errors "which are not exist"或应用程序崩溃，我得到了下面发布的错误日志。

此外，我在我的项目中的库图片下方发布了一张图片，这些库是从paho website.

请让我知道我错过了什么以及我做错了什么。

代码：

}

日志猫：

图片

几天来，我一直在努力paho android service工作。我从这里下载了它，并按照网站上提供的步骤解压缩了GIT内容。关于Paho Java Client我从这里下载的压缩文件和压缩文件的内容，我将它们复制到libs我在文件夹中创建的org.eclipse.paho.android.service文件夹中。

现在，当我将paho android service包含org.eclipse.paho.android.service,org.eclipse.paho.android.service.sample和org.eclipse.paho.android.service.test文件夹的文件导入 Eclipse 时，项目既没有标有感叹号也没有红色 X 标记，但是当我运行应用程序时，我收到以下logcat输出。为了解决它，我检查了一些与java.lang.VerifyError错误相关的问题，但问题仍然存在。

日志猫：

我一直在阅读本教程以了解 的基础知识Paho android Service API，以及我阅读的文本中的一些地方，client.connect(context, callback其中有两种方法onSuccess()和onFailure()

如前所述，此示例中使用了同步客户端（MqttClient 与 MqttAsyncClient 相对）。这意味着请求，如连接，将阻塞并返回或抛出异常。没有轮询或读取方法从服务器获取消息，来自服务器的消息可以随时到达。该库提供回调机制来处理此行为，向客户端注册的 MqttCallback 对象中的方法将被适当地调用。MqttCallback 是一个必须由另一个类实现的接口...要启用回调功能，向客户端注册一个回调对象，这在逻辑上最符合逻辑的是在连接到服务器之前完成

在阅读了我提到的最后两行之后，我感到困惑。因为据我了解，让客户端注册到具有的回调的本质connectionLost,deliveryComplete,messageArrived是“异步”处理服务器状态并从服务器读取。

现在，我的问题是，关于我引用的最后两行，我应该如何注册客户端以在连接到服务器本身之前从服务器读取状态？或者换句话说，“为什么“client.callback”应该在“client.connect()”之前调用？

任何人都可以澄清和解释这一点。

在下面的代码中，我试图为持久数据创建一个文件夹。如您所见，我创建private final String folder = "//temp";了对象persistence。但问题是当我运行应用程序时，我说Connection Failed，这条消息来自client connection synchronous listener，当我在没有对象的情况下连接时persistence，一切正常。

我是错误地初始化folder变量还是使用 MqttClientPersistence persistence不正确？

代码：

如果服务器在上述时间内没有收到来自客户端的任何消息(1.5) * KeepAlivetime并且客户端没有PINGREQ在上述时间内发送任何消息，那么服务器是否应该DISCONNECT？

如果是，为什么我收到LWT不应该收到的DISCONNECT消息？

为了测试，我创建了一个客户端clean sessin = false并setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, true);运行了该应用程序。后来，我设置setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, false);当我运行该应用程序时，我会收到以前的LWT消息。如何停止接收它们？

在下面，当我运行它并故意关闭 WiFi 时，回调clientCallBack.connectionLost会显示Log.d(TAG, "@connectionLost: MQTT Server connection lost");两次消息。当我重新连接时，回调中的消息Log.i(TAG, "@onSuccess: Connection Successful.");只client_1.connect显示一次。

任何人都可以解释为什么我两次收到来自回调的消息？

代码

我让他LWT topic跟着WT message

当我发布消息时，我订阅了一个topic名称sensor_0，但当我关闭 WiFi 并再次打开它时，我希望看到LWT messahe我在连接选项中设置的，但发生的情况是我没有收到它.

为什么我重新连接时没有收到LWT消息？

代码：