问题标签 [paho]

我正在尝试测试我的使用 MQTT 接收消息的 android 应用程序。我收到 JSON 格式的消息，其中还包含一个 base64 编码的图像。当图像为几千字节时，这工作得非常好，但是当我尝试发送大约 400KB 的任何内容时，消息不会被发送。

我使用了两个公共经纪人两次都得到了相同的响应。(test.mosquitto.org & iot.eclipse.org)

这是正在发送的 JSON 对象：

这是用于发布的代码，使用 Paho android 服务客户端：

尝试使用 eclipse paho (1.0.2) java 库使用表单的 url 连接到 MQTT 代理tls:// ...会抛出IllegalArgumentException. 毫不奇怪，它在代码中被明确禁止（尽管 ssl 可用）。连接在 MqttConnectOptions 中调用此方法

有没有办法绕过这个限制？或者，是否有某些原因被阻止？人们如何通过这些 url 使用这个客户端？任何帮助表示赞赏。

我正在使用 paho android 服务客户端从使用 Mqtt 的服务器接收消息。该应用程序在活动运行时可以正常发送和接收，但是在应用程序未运行时发布的任何消息都不会被接收，并且我的回调类将不会运行。

我相信这可能是上下文的问题，并且我的回调与我的活动上下文相关联，或者我需要以某种方式唤醒我的应用程序，以便它将消息写入数据库然后再次休眠。

这是我的 MqttCallback 实现：

这是我的客户实例：

发送给两者的上下文是我的 MainActivity (this)

任何指导将不胜感激。

哟，伙计们。所以我对 Python 比较陌生，并且是 MQTT 的新手。所以，我试图通过 MQTT 简单地连接两个程序。其中一个程序是发布者：

所以，基本上发布者读取一个密钥输入并将其发送给代理。并且客户端程序应该读取击键并做出相应的反应：

这是一个简单的测试程序，但我在尝试“读取”MQTT 有效负载时遇到了很多麻烦。

我已经设置了一个 Moquette MQTT 代理并将其与 eclipse Paho 客户端连接（我将调用它paho1）。订阅in/#主题。

我创建了另一个 Paho 客户端（我将调用它paho2），当然具有不同的客户端 ID，并将其发布到带有in/device主题的代理。

起初，数据包已成功交付。但是，当我断开连接paho2并重新连接到代理并发送相同的数据包时，它不会传递到paho1.

我想知道为什么会这样。我对 Paho 客户端的设置是qos = 0（我也尝试了 1 和 2）。

我正在查看经纪人的日志，它如下所示。成功后，我的协议版本将打印到日志中。

我正在尝试在 android 中编写一个应用程序来发布 mqtt 消息。我正在使用 AsyncTask 发布到我的代理，但有时我有很大的延迟，我猜是因为我每次发布前都必须连接到代理

我的问题是，有没有更好的方法来做到这一点，也许在服务中保持连接活跃？

最好的问候，
保罗。

我正在编写一个 Java 应用程序来使用 Eclipse Paho Lib (org.eclipse.paho.client.mqtt3-1.0.2.jar) 在设备和应用程序端发布/订阅物联网 MQTT 服务器。

Connect 适用于两种凭证类型，并且似乎是发布...给我的错误是订阅：

通过 mosquitto_sub 命令行尝试，它循环如下：

等等。

当使用 MqttAsyncClient 从 java 中尝试时，subcribe() 方法返回，但随后 waitForCompletion() 方法立即出现：

这是我正在运行的代码：

接着：

此外，此错误使库无法通过 AsyncClient 释放持久性路径用户，使其在每次重试时抛出“持久性已在使用”异常，直到我停止 JVM 并手动清除该路径，但我想这是是某种库错误。

不幸的是，我无法（或不知道如何）访问 IoT 端 mqtt 服务器以了解其中发生了什么。

有任何想法吗？谢谢

With Spring's integration libraries, I am trying to connect to mosquitto and read/send messages... But there are some things I couldn't figure out.

1 - When initilazing app, app connects to mosquitto, but mosquitto receives hundreds of connection requests again from same app with same id in seconds. This is the example of log :

2 - I can't get any messages from mosquitto using this configuration :

Spring XML :

Custom Adapter :

I'm not using service-activator because I need to know which topic that arrived message sent from, so I've wrapped the MqttPahoMessageDrivenChannelAdapter as its mentioned within the Spring Integration Docs

So is there any suggestions ?

在Android中取消绑定外部服务（位于另一个jar中）文件的正确方法是什么？

org.eclipse.paho.android.service-1.0.2.jar我在清单文件中将服务（位于 中）声明为：

服务源在这里

并且服务运行正常。但是，在退出应用程序时出现ServiceConnectionLeaked错误，在进行了一些搜索后，我发现我需要调用活动unbindService(...);的onDestroy()方法。

日志：

但是，我没有ServiceConnection要传递的信息，unbindService()因为我没有手动启动服务。有没有办法获得该ServiceConnection服务并解除绑定？

我正在使用 Mqtt (Paho)​​ 实现一个 Android 应用程序。我有一些组件，我必须将包含通配符的订阅主题与客户发布到的实际主题进行比较。

我只是不明白它，我的“基本”正则表达式技能也无济于事......

Paho/Java MQTT 中是否有实用程序类来查看是否

“SENSOR/TEMPERATURE/+/DEGREE/#/ID”（订阅主题）

适用于

“SENOR/TEMPERATURE/GARDEN/DEGREE/CELSIUS/ABOVEZERO/ID”（实际主题）？

有人知道最好的方法是什么吗？

谢谢！

编辑：您好-我认为这应该是正确的