问题标签 [paho]

我按照一些教程来了解如何从 Android 设备publish发送消息。broker下面是我的尝试，此时，我没有找到教程中提供的方法，就像MqttDeliveryTokenAndroid它不在库中一样。

请让我知道如何publish正确发送消息，并请提供最近更新的 Paho Android API 的链接，我现在正在使用的 API 是从Paho网站下载的，并且一些类和方法以及我上面提到的那个丢失了。

代码

有没有人有一个合乎逻辑的解释，为什么尽管我clear session flage = false没有收到我订阅的更新的发布消息，而我没有连接到经纪人？

将 aore提到的标志设置为 false 我运行了我的应用程序，并且我不断向主题发布一些值（从 PC 到代理而不是从 Android 设备到代理）。然后我从电脑上拔下安卓设备的usb，并再次发布一些值。当我再次将 USB 插入电脑时，我希望看到我最近发布到该主题的值，但我没有收到任何值。

我发布的主题正是我订阅的主题，带有QoS = 1.

在下面的代码片段中，我为订阅声明了一个usernameand passqord。

我从应用程序开始连接，clean session = false无论client ID = 1是否提供密码和用户名，我一直发布（从 PC 到代理）我订阅的主题的值（从应用程序到代理。

稍后在subscribe消息中，我在连接选项中设置了密码和用户名，并没有指定publish消息的用户名和密码，然后重新运行 p。发生的事情是，我收到了我订阅的主题的更新发布值。

之后，publish我指定了错误的用户名和密码并订阅了相同的主题，当我运行应用程序时，我会正常收到值。

我用错了密码和用户名？

注意：我已经尝试了不同的相同程序，clientID即使指定了错误的密码，我也会收到发布的值。

当我尝试通过这个 JS 连接到 Mosquitto 服务器时，我收到这个错误：

我从控制台尝试过，它工作正常。我尝试使用 Java 客户端作为提供者和消费者，它工作正常。所以我不明白我应该怎么做才能让它工作。

这是 JS：

这是Java（工作）：

我正在使用Paho Android Service API，我连接onResume和断开连接onPause。在运行时，我可以subscribe从设备published上通过mosquitto Broker. 当我按下他时BackButton，应用程序崩溃并显示以下logcat错误。

请让我知道如何解决这个问题。

注意：

1_因为我正在使用Paho Android Service API我将所需的库导入到项目中。
在我的项目清单文件的元素application中，我添加了这一行

2_我没有在我的框架中注册任何接收器，接收器包含在我导入以使用 Paho API 的库中

日志猫：

此类IMqttClient()允许您创建一个client对象，该对象具有对所有可能发生的事件的回调，例如

但是这个类不允许你ID为每个客户端指定一个。这怎么可能？特别是如果你想联系clean session = false？

MqttConnectOptions此外，当您实例化一个对象时，我已经检查了类，您可以将其设置server URI为选项，稍后您可以执行类似的操作client.connect(opts)，但无法指定ID.

Since specifying the clienID is only a feature in the class MqttAndroidClient, and can not be specified when using classes IMqttClient and IMqttAsynchClient.

what is the real purpose of connecting a client with a unique ID?

我创建了一个client类型MqttClient，如下面的代码所示，我创建了一个客户端并设置了它的Asynchronous callback. 问题是，

1-当我运行程序时，System.out.println("Client is Connected");出现了，但我没有收到onSuccess来自 o 或 o的响应onFailure，为什么？我在代码中做错了什么。

2-我实现了static IMqttAsyncClient asynchClientCB = new IMqttAsyncClient()接口，但由于我有一个类型的客户端MqttClient，我不能使用这个IMqttAsyncClient接口。我尝试使用mqttAsynchClien，但因为我为 java 编程而不是因为Android我不能使用它。如何使用IMqttAsyncClient界面。？

更新_1

在下面的代码“Updated_code_1”中，我稍微修改了代码，但我希望每次成功连接到同步回调中broker​​的消息时都会打印出来，并且在连接终止的情况下打印同步回调中​​的消息，例如当我故意断开网络时。但是在我连接到的时候，既不也不显示任何东西。那么，它们的设计目的是什么？onSuccessonFailurebrokeronSuccessonFailur

*Update_2_17_Dec_2014

我有一个询问可能会引导我们找到解决方案，也就是说，我通过有线/无线网络连接到代理是否重要？这会改变同步和异步监听器的行为吗？

更新_1_code：

新客户：

异步回调：

当我运行 Eclipse 并编译我的程序时，它只工作一次，在第一次程序执行后，如果我再次尝试运行它，我会收到：

Exception in thread "main" Persistence is already in use

为了解决这个问题，我必须关闭 Eclipse 并重新打开它，每次都会发生同样的事情，我可以运行我的程序一次，否则我会收到发布的消息。

该错误是什么意思，我该如何解决？

更新

代码：

控制台输出：

以下是我在我的 java 程序中使用的导入。我想要做的是，创建一个client类型MqttCient，然后使用connectWithResuls如下方法

问题是eclipse用红色曲线强调了上面提到的谎言，我不知道为什么，我也提到了Paho java docs here。

请让我知道为什么无法识别上述方法。

进口