问题标签 [paho]

我正在尝试使用 Paho 的 MQTT javascript 客户端。我看到了 HiveMQ 的一个例子，你可以在这里查看 - - http://www.hivemq.com/demos/websocket-client/

它似乎正在工作，但是当我将主机设置为：test.mosquitto.org:1883时，它是 mosquitto 的 mqtt 代理服务，它失败了。

当我尝试连接到这个 mosquitto 服务时，它给了我一个连接错误 -connect failed: AMQJS0007E, Socket error: undefined.

我想对mosquitto进行压力测试，所以我创建了一些代码如下

但是，我EOFException在运行期间遇到了一些错误，并且某些客户端断开了连接。我想知道一台mosquitto服务器可以同时发布多少个客户端，如何进行压力测试。谢谢！

详细例外是：

我从 mosquitto 服务器上找到了一些日志：

请帮助我，谢谢！

我正在使用 MQTT Paho Javascript ( mqttws31.js) 制作一个 Web 应用程序。

在我的onMessageArrived函数中，我现在定义以下代码到达的消息：

有没有更好的方法来检查主题？

messageArrived是否可以为每个订阅定义一个函数？我知道定义的唯一方法messageArrived是在client.connect函数之前。我知道订阅的唯一方法是在连接后做client.subscribe。

定义例如：client.subscribe("registertopic", registerhandlerfunction);

我能做些什么？

我在 android 4.3 上使用 paho，与位于m2m.eclipse.org. 我将客户端包裹在服务中，并使用该服务AlarmManager向服务器发送保持活动消息。我有一个单独的客户端（仅使用 mqtt httbridge，或使用 paho 的另一个 android 设备）将消息发送到我的服务正在收听的主题。

一切都很顺利......直到它没有。在某些时候，我的 android 服务停止接收消息。keep-alives 继续发送，everyhting 似乎很好，但消息没有通过。我无法在 mosquitto 的本地实例上复制此行为，这让我认为这是 eclipse 端的某种配置，但会提供任何指针。

服务质量为 0。

我正在使用 paho 发送和接收 mqtt 消息。到目前为止，发送消息没有问题。我收到它们时遇到问题。我的代码是：

这发送和接收消息。

输出：

我想发送消息，然后接收它们。有什么帮助吗？预期输出：

我在 ubuntu 上使用 eclipse paho 客户端，并尝试将纬度、经度和时间戳信息作为 JSON 格式发送到 MQTT 代理。我怎么做？

我找到了这篇文章，但它并不完整。

我正在尝试使用建立 MQTT 连接的 Flask 来纠正 Python 中的 Google Cloud Platform 应用程序。我已经包含了 paho python 库pip install paho-mqtt -t libs/。但是，当我尝试运行该应用程序时，即使我没有尝试连接到 MQTT。我收到一个关于 IP 地址检查的奇怪错误： RuntimeError: error('illegal IP address string passed to inet_pton',)

似乎remote_socket库中的某些东西导致了问题。这是一个安全问题吗？有什么办法可以禁用它吗？

相关代码：

以及完整的堆栈跟踪：

谢谢！

我在我的 ubuntu 中使用 eclipse paho 'C' 客户端，并尝试将纬度、经度和时间戳信息作为 JSON 格式发送到 MQTT 代理。我怎么做 ？

参考： http: //www.eclipse.org/paho/clients/c/

我正在运行 Paho Java 客户端附带的示例：http: //git.eclipse.org/c/paho/org.eclipse.paho.mqtt.java.git/

无论是他们自己的示例，还是来自其他来源的独立 hello world Paho 演示，甚至与 Spring Integration 结合使用，如果其有效负载超过 200MB，客户端会以某种方式碰巧多次收到消息（这不是确切的图，因为我通过逐条消息逐渐增加有效负载 5MB 进行测试）。

我的经纪人是蚊子。我尝试了所有的 QOS 配置，还是一样。

值得注意的是，使用相同的设置使用 Paho Python 库时不会发生这种情况。所以我的环境（网络、代理、发布客户端等）应该没问题。

我想在 Spring Integration 中使用异步 Paho 客户端：

我必须自己写一个吗？我只能找到同步客户端工厂的示例。