mqtt相关内容

MQTT知道客户端是否已订阅

问题已经发布,如何查找已连接的MQTT客户端详细信息 在我的情况下,如果客户端X已在频道A中订阅,则客户端Y不能订阅频道A,直到X取消订阅为止.我只能在该频道中订阅一个客户端 我还可以使用保留消息和LWT的想法吗? 如果是,我不知道应该从哪里开始.最好从一个简单的示例开始,以查看保留的消息和LWT的工作方式.到目前为止,我仅具有发布和订阅方面的经验,但仅此而已. 能否请您告 ..
发布时间:2020-05-12 20:19:41 Java开发

PHP MQTT订阅不一致

我试图在基于PHP的页面上使用MQTT显示一些值. PHP代码包含订户.我正在为MQTT经纪人使用Bluemix IoT服务.而且,消息是通过Python代码在本地计算机上发布的. 当我尝试使用页面刷新在页面上显示值时,页面有时无法显示值.由于Bluemix IoT服务已成功显示值,因此在发布者端没有问题. 我的代码如下: ..
发布时间:2020-05-12 20:19:35 其他开发

两个paho.mqtt客户端订阅相同的客户端区域

我正在尝试确定是否可以有两个paho.mqtt客户端( https://eclipse.org/paho/clients/python/docs/)订阅同一台服务器.客户端和服务器都在同一主机上运行.我的目的是让两个客户端使用不同的凭据订阅同一台服务器(在我的情况下是带有mqtt插件的rabbitmq),以便我可以按虚拟主机(而不是按主题对我的有效负载进行排序),因为我无法控制主题. /p> 目 ..
发布时间:2020-05-12 20:19:33 Python

带有NodeMCU的ESP8266上的MQTT-发布问题

我正在基于NodeMCU构建基于ESP8266的电池供电的IoT设备. 我使用mqtt定期执行测量并发布结果. 我知道,要允许网络堆栈运行,我应该避免紧密的循环并依靠回调函数.因此,在我看来,我的测量代码的正确组织应该是: interval=60000000 function sleep_till_next_sample() node.dsleep(interval) end func ..
发布时间:2020-05-12 20:19:31 其他开发

正确的MQTT订阅代码,可保持持久性

我正在寻找用于订阅给定主题的MQTT客户端的Java代码,在该主题上发布的每条消息应仅到达客户端一次.我编写了许多代码,并且在所有情况下,消息均已正确地传递给客户端当它连接到代理,但是如果订阅的客户端与代理断开连接一段时间,然后再次连接回去时,它没有收到未连接期间发送的消息,并且我设置了干净会话标志同样是错误的,但仍然无法正常工作,下面给出了我使用的代码 import org.fusesou ..
发布时间:2020-05-12 20:19:28 Java开发

如何在WebSocket服务器中获取MQTT客户端的主题

我正在尝试获取mqtt客户端的主题,我在Google中进行了搜索,找不到合适的主题. 例如,从mqtt客户端发布一条消息,考虑服务器主题为"topicOfServer",而客户端主题为"topicOfClient". client.publish('topicOfServer','hi服务器'); 服务器将收到"hi服务器"消息.但是服务器如何知道该消息来自哪个客户端,例如:'t ..
发布时间:2020-05-12 20:19:25 前端开发

Paho Rabitmqq连接失败

这是我的paho客户代码 // Create a client instance client = new Paho.MQTT.Client('127.0.0.1', 1883, "clientId"); // set callback handlers client.onConnectionLost = onConnectionLost; client.onMessageArrived ..
发布时间:2020-05-12 20:19:23 其他开发

带有MqttAsyncClient订阅丢失消息的QoS = 1

我有充当MQTT客户端的前台服务.我为此使用MqttAsyncClient mqttClient. 我在订阅主题上使用QoS=1 mqttClient.subscribe("sensors/s1/", 1); 但是如果我的手机离线一段时间后会错过当前时间段的消息.整个代码如下. 我是我正在使用MqttAndroidClient mqttAndroidClient的另一个应用程序, ..
发布时间:2020-05-12 20:19:20 移动开发

Android中的Websockets上的MQTT

我正在通过Web套接字使用Paho Android Service for MQTT. https://www.hivemq.com /blog/mqtt-client-library-enyclopedia-paho-android-service 我的问题是如何设置其中具有查询参数的Broker WSS URI. 例如: wss://test.amazon.com:80/mq ..
发布时间:2020-05-12 20:19:13 移动开发

使用BG96和MQTT协议将数据发布到AWS IoT时出错

我正在尝试使用BG96(使用AT命令的NB-IoT设备)将数据发布到Amazon Web服务 我正在关注官方文档(Quectel) 所以我配置SSL参数(使用命令:at + qsslcfg = ...)并成功启动MQTT SSL连接(AT + QMTOPEN = ...),但是当我尝试连接到MQTT服务器时(AT + QMTCONN = ...) ,连接立即关闭 请帮忙,如何解决此问题并将数据发布 ..
发布时间:2020-05-12 20:19:11 其他开发

如何为Paho mqtt用python发送PINGREQ?

我通过以下方式连接到我的蚊子经纪人 client.connect("192.168.1.1",1883,60) 建立连接,服务器每60秒就会收到一次流量. Paho文档引用了PINGREQ/PINGACK消息,我想使用该消息来保持连接的活动状态. 找不到任何示例-如何在python(2.7)中做到这一点? 解决方案 简短的答案是你不 ping是由MQTT客户端网络环路 ..
发布时间:2020-05-12 20:19:08 Python

Azure IoTHub DeviceMessage和路由筛选器

我使用 python 和 paho.mqtt 将消息发送到云 我设置了端点和路由.当我将查询字符串设置为 true 时,一切正常 messageDict = {} systemPropertiesDict = {"contentType": "application/json", "contentEncoding": "utf-8", "iothub-message-source": "de ..
发布时间:2020-05-12 20:19:05 Python

带有MQTT的Python Flask应用

我正尝试将Flask应用程序用作订户,但在收到消息时它不会调用on_message回调.相反,我将得到如下所示的信息: Connected with result code 0 Closing data file... Connected with result code 0 Closing data file... 这是我运行Flask应用程序的方式: main.py: fro ..
发布时间:2020-05-12 20:19:03 其他开发

在Rabbit MQ中禁用保留的MQTT消息

出于遗留原因,我需要在运行RabbitMQ的MQTT节点上禁用保留的消息. 在研究了该问题之后,似乎Rabbit MQ团队确实添加了这样一个功能在名为 rabbit_mqtt_retained_msg_store_noop.erl . 否则,我对代码库不熟悉,并且在文档的任何地方都找不到提及noop固定器的信息. 如何启用rabbit_mqtt_retained_msg_stor ..
发布时间:2020-05-12 20:19:00 其他开发

MQTT代理可以处理多少个客户?

MQTT是一种发布/订阅协议.每当发布者发布到主题时,所有订阅该主题的订阅者都将通过MQTT代理获取消息.我想知道MQTT经纪人可以处理的最大客户数量.有上限吗? 解决方案 一个MQTT代理可以服务多少个客户端,取决于您使用的MQTT代理软件.大多数MQTT代理可能仅受可用内存量的限制(每个套接字使用一块内存),因此,这成为一个问题,即哪个代理软件以最有效的方式利用内存(和其他资源).当然 ..
发布时间:2020-05-12 20:18:58 其他开发