paho

    0热度

    1回答

    目前这在paho java库中不受支持,但我在我们的应用程序中需要此功能。例如,在应用程序启动时,我们没有网络连接,但在30秒左右后,我们建立了连接,因此我希望我的客户端能够自动连接。 我的问题是 - 什么是最好的方法来实现这一目标?我到目前为止尝试的是在连接方法出现问题时尝试重新连接。而且由于我们使用RxJava,我已经计划执行负责客户端连接的相同方法。如果我粘贴代码会更容易。 private

    0热度

    1回答

    我想运行我的paho mqtt客户端指定的时间段,而不是永远。什么是正确的实施方式? P.S.我想阻塞呼叫,而不是事件驱动loop_start()/ stop()设施 谢谢!

    0热度

    1回答

    有人可以请我建议我如何在AWS服务器上创建主题?我知道,当我通过提供主题名称发布消息时,它会自动创建主题,但有什么方法可以在服务器上添加所有可能的主题? 在上图中,我能够在一个主题(test_topic)发送消息,并在服务器上自动创建。有什么方法可以一次在服务器上创建所有主题?

    1热度

    1回答

    我正在致力于HiveMQ Websocket Client,我正面临与message delivery有关的一些问题。 所以,我碰到过这个词PUBACK 让我解释你对我的理解,然后我会问我的问题。 无论何时我们发送消息QOS1,hivemq服务器都会通过回调PUBACK来确认发件人。 现在,我打算在我的websockets中对onPubackReceived事件进行子类化,但事件在发送消息后未触发

    2热度

    2回答

    我只是看着Eclipse PAHO和Mosquitto客户端库(MQTT C++库)的细节。看起来PAHO使用mosquitto MQTT代理,但提供了自己的MQTT客户端库。 此外,Mosquitto库提供了一种为Mosquitto MQTT代理实现客户端库的方法。 我想了解这两个客户端库的主要区别是什么。 Here它被讨论但不能回答我的问题。哪一个比另一个更受欢迎,为什么?为什么eclipse

    1热度

    1回答

    我正在用Paho在C++中编写一个mqtt应用程序。我正在使用Paho.mqtt C库,可以找到here。 当我在回调函数中收到消息时,它会调用另一个函数来打印消息。我希望能够循环该功能,直到有新消息到达。 bool start = false; void loopMessage(std::string message){ start = true; while(start)

    0热度

    2回答

    我使用mqtt协议将传感器数据的消息发送给蚊子代理。我想要做的是每隔t秒发送一次传感器数据,但是如果我收到消息并行处理它。是使用time.sleep(),但我认为这会延迟“on_message”函数。我使用paho-mqtt和python 2.7。关于如何完成这样的事情的任何想法? 客户端1号(发送传感器数据) from mysignals import mysignals import pah

    -1热度

    1回答

    我有一个应用程序,其中连接到一个mqtt服务器i followed this link并作了一些修改,并与用户名和密码连接,如何从该服务器断开连接 import { Injectable } from '@angular/core'; import { Http } from '@angular/http'; import 'rxjs/add/operator/map'; imp

    0热度

    1回答

    尝试在付费 GAE应用程序上运行简单的MQTT客户端(不是代理)。然而一个on_connect回调从来没有发生在以下: worker.py import webapp2 import paho.mqtt.client as paho class WorkerHandler(webapp2.RequestHandler): def on_subscribe(client, user

    0热度

    2回答

    我正在用eclipse paho java库使用mosquitto MQ。我希望在订阅主题并获取消息之前检查主题是否存在。我怎么做 ?