如何在一段代码中设置多个MQTT回调并订阅多个主题？

文章/答案/技术大牛

发布

1回答

callback、mqtt、subscribe

我是MQTT的新手。我正在做一个涉及Pycom板(Sipy)的项目。在电路板上，我有一个温度和一个重量传感器，我正在读取值。为此，我编写了两个回调函数(名为sub_weight和sub_temp)。然而，在我看来，只有第二个回调被考虑在内，就好像第一个回调是被按下的一样。当我尝试订阅这两个主题时，我也遇到了同样的问题。我当时的问题是:是否可以订阅多个主题，并<em

浏览 162提问于2019-01-29得票数 1

1回答

多个订阅的Paho mqtt回调

python、callback、mqtt、paho

我已经使用paho.mqtt订阅了多个(大约4个)主题。对于每个主题，数据库中都有相应的表。我应该use on_message()回调还是message_callback_add()回<

浏览 0提问于2017-12-08得票数 0

回答已采纳

2回答

在python脚本中订阅两个主题MQTT

python-3.x、mqtt

我有一个python脚本，它在MQTT中调优到一个主题，它工作得很好。import paho.mqtt.client as mqtt #import the client1import json broker_address="127.0

浏览 87提问于2019-02-12得票数 3

回答已采纳

1回答

泛美卫生组织C++异步客户端回调与action_listener与connected_handler的比较

c++、mqtt、paho、pahocpp

在使用C++时，我试图了解Paho MQTT async_client库中各种回调机制的使用和行为，特别是： mqtt::callbackmqtt::iaction listenermqtt::connection_handler我想要达到的目标是:一种阻止初始化方法，它等待成功的连接并成功地订阅一个主题列表(首先是一个主题)，如果连接退出，再加上这些主题的自动重新连接和重新订阅。“async_subscribe”示

浏览 1提问于2020-03-30得票数 0

回答已采纳

2回答

如何使用paho mqtt* java实现请求-响应模式？*

java、mqtt、paho

我想使用并实现一些“请求-响应”模式。我的意思是，在某些情况下，客户端必须与服务器对话，并期待对特定请求的特定应答。感觉这个库拥有匹配请求和响应所需的一切，但我不能把它们放在一起。

浏览 80提问于2020-06-08得票数 0

2回答

Paho Javascript MQTT订阅多个主题

javascript、mqtt、paho

当客户机订阅多个主题时，是否可以使用类似的概念(在javascript中)和paho python中使用的message_callback_add来使用多个回调？我已经看到了if条件在onMessageArrived()中的使用，但我想知道是否存在一种更高效、更干净的方法？var mqtt; // MQTT variable/objec

浏览 9提问于2021-06-07得票数 1

回答已采纳

1回答

MQTT.js subscribe()函数的回调未捕获错误消息

javascript、mqtt

我正在使用MQTT.js订阅实时遥测数据。console.log(err.toString()); ); =>client connected =>Uncaught TypeError: err is null 有时订阅不成功，所以我使用docs中指定的回调函数来检索错误。我故意给了一个错误的订阅令牌，所以即使它连接了，它也不能订阅。问题是它说没有错误(err is null)。那么，我如何知道错误是什么呢？这里有一个类

浏览 240提问于2020-09-17得票数 0

回答已采纳

1回答

Paho-mqtt.client可以连接到数字海洋mqtt服务器，但无法订阅

debian、mqtt、digital-ocean、paho、hivemq

我使用的是Paho-Mqtt python客户端示例。我的digitalocean debian服务器上也有HiveMq mqtt服务器。如果我在我的笔记本电脑或linux Debian机器上运行，用python编写的客户端示例代码可以连接并订阅digitalocean服务器。但。这就是但是。当我在digitalocean服务器( hivemq mqtt服务器)上运行客户端时，它只能连接而不能订阅！我同时使用了本地主机和服务器IP，但仍然没有成功。但是，在digital

浏览 5提问于2015-07-27得票数 0

1回答

用户登录后，在nodejs中运行一个连续函数

javascript、node.js

这是我的问题--我在mongo上有一个用户数据库，其中也有一个用户订阅的topicsList。我需要通过Mqtt不断地听topicsList中的主题。一旦用户登录&通过身份验证，就可以从数据库中获取主题列表。如何在app.js函数的主app.listen文件中的回调函数中传递主题列表。app.listen(3000, function(){ console.log(

浏览 6提问于2022-07-27得票数 0

1回答

如何处理需要在node.js中触发函数的多个mqtt客户端的消息？

javascript、node.js、parallel-processing、mqtt

我正在编写一个node.js脚本，它使用mqtt接收发布到单个主题的消息。我希望执行一个函数，该函数从消息中获取数据，并创建客户端订阅的主题列表。我有如下所示的工作代码。问题是，我将有成千上万的设备将发送消息到主题-“主题/信息”，可能有数百条同时消息。虽然可以在MQTT中使用QoS设置接收消息，但串行执行效率不高，因为函数中有一个for循环运行以及一个数据库插入(不是在代码</e

浏览 5提问于2022-01-04得票数 0

2回答

如何从mosca向mqtt.js客户端发送消息

javascript、mqtt、iot

我们设置了一个由驱动的MQTT客户机(无论是在桌面PC上还是在实际的板上，都是相同的)和一个由驱动的MQTT代理，这个代理运行在桌面PC上。我们能够成功地从客户端发送带有特定主题的消息到代理，但现在我们遇到了相反的情况:将消息从代理发送到客户端。bro

浏览 4提问于2015-05-04得票数 3

1回答

聊天应用程序如何知道用户何时发送消息以重新呈现？

javascript、mysql、node.js、reactjs、express

我可以让它在我正在使用的浏览器中重新呈现，但如果我打开另一个选项卡并键入一条消息，我的应用程序将不会重新呈现。有没有什么简单的方法可以解决这个问题，或者我应该使用websockets？这是我的代码。

浏览 1提问于2021-03-31得票数 2

6回答

Android - Paho Mqtt客户端在网络连接改变后不会接收消息(移动数据已禁用并再次启用)

java、android、mqtt、mosquitto、paho

3)订阅某一主题。结果： Mqtt客户端接收发布到主题的所有消息。现在6)向主题发布一些信息。由于KeepAliveInterval的价值很高(30分钟)，它应该在重新连接到internet后接收所有消息。相同的用例(相同的代码)适用于简单的java项目(非android)，在该项目中，我在笔记本电脑上

浏览 0提问于2014-08-07得票数 5

1回答

如何用多个流包装单个回调

kotlin-coroutines

我有一个第三方库，在那里你可以订阅一些主题来接收关于这个主题的更新(通过回调)。但是问题是，当您再次使用相同的主题调用订阅方法时，以前的订阅将被新的订阅默默地替换。val flow: Flow<Message> = callbackFlow { lib.subscribe(topic) { message -> of

浏览 1提问于2019-10-25得票数 2

2回答

用值返回Map但获得空值

javascript、node.js

我试图返回一个有价值的地图，但返回0const mapResultTemp = new Map();/scripts/findTopic.js"); //***var client = mqtt.connect('***', options); client.on

浏览 0提问于2021-06-08得票数 0

回答已采纳

1回答

python paho-mqtt* -未接收mqtt消息*

python、mqtt、paho

我正在开发一个python应用程序，应该可以接收mqtt消息。我使用的是paho-mqtt库。import paho.mqtt.client as mqtt BROKER_ENDPOINT =

浏览 69提问于2019-08-19得票数 0

2回答

相同订阅服务器的Azure服务总线多个实例

asp.net-core、azureservicebus、azure-servicebus-topics

我遇到的情况是，我有一个asp.net核心应用程序，它将订阅客户端注册到启动时的主题(IHostedService)，这个订阅客户端本质上有一个回调字典，每当它检测到带有id的主题中的新消息时，就需要触发该字典本词典存在于应用程序的整个生命周期中，并保存在内存中。在蔚蓝上的asp.net核心应用服务的单个实例上，一切都很好，当我扩展到2时，我注意到订阅中的回调有时不会触发。这是有

浏览 1提问于2018-10-16得票数 2

回答已采纳

1回答

是否订阅配置文件中的多级主题？

mqtt

我试图在配置文件中订阅多个主题级别，目标是每当我启动MQTT时，代理都会有这些主题，之后当我输入通配符时，它会比较并检查主题是否在代理上，如果是，它就提取数据，如果不在，它就跳到下一个分支级别下面显示了主题树的代码片段，

浏览 0提问于2019-07-26得票数 0

3回答

RxJS是如何创建或模拟异步的？

javascript、asynchronous、rxjs

我很难理解RxJS观测数据和主题的执行模型/顺序。我读了很多文献和博客文章，说RxJS可观察是更好的承诺，因为它们的订阅可以被取消，它们可以通过next()发出多个结果/值。RxJS可观察性是否环绕承诺并创建一系列承诺，以使代码执行异步？还是由于已实现的可观察模式，更改被异步传播到订阅服务器，但代码执行仍然是同步的？在我看来，javascript代码在事件循环处理的任何JavaScript回调队列

浏览 8提问于2020-02-07得票数 4

1回答

使用Storm的可伸缩信号处理体系结构所需的建议

mqtt、apache-storm

该平台旨在同时处理多个信号(从一个MQTT主题中收集)，向它们应用一系列的信号处理算法。到目前为止，我们的解决方案包括，如描述的 MQTT喷口，它订阅其名称的所有主题。通过建立对喷管的并行性提示，我们能够注意到Storm是如何在多台机器上分配负载的，从而提高了整个系统的吞吐量。我们知

浏览 1提问于2018-04-04得票数 0

点击加载更多