将MQTT消息与发布者的clienID连接
MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，常用于物联网领域的设备间通信。它基于发布/订阅模式，通过中间代理（Broker）实现消息的传递。
MQTT的消息与发布者的clientID连接是指在MQTT协议中，发布者（Publisher）发送消息时，需要通过clientID与Broker建立连接。clientID是一个唯一标识符，用于区分不同的客户端。通过clientID连接，Broker可以将消息正确地路由给订阅者（Subscriber）。
MQTT的优势在于其轻量级和低功耗的特性，适用于资源受限的设备。它具有以下特点：
- 简单易用：MQTT协议设计简洁，易于实现和使用。
- 轻量级：MQTT的消息头部较小，协议开销低，适用于带宽有限的网络环境。
- 异步通信：MQTT支持异步通信模式，发布者和订阅者之间解耦，提高系统的可伸缩性和灵活性。
- 可靠性：MQTT支持消息的持久化和QoS（Quality of Service）等级控制，确保消息的可靠传输。
- 安全性：MQTT支持TLS/SSL加密传输，保障通信的安全性。
MQTT在物联网领域有广泛的应用场景，例如：
- 物联网设备通信：MQTT作为物联网设备间的通信协议，可用于传输传感器数据、控制指令等。
- 实时数据传输：MQTT可以用于实时监控系统、智能家居等场景，将数据快速传输到订阅者端。
- 远程监控和控制：通过MQTT，可以实现对远程设备的监控和控制，如远程开关、远程升级等。
- 消息推送：MQTT可以用于实现消息推送服务，如即时通讯、新闻推送等。
腾讯云提供了MQTT相关的产品和服务，例如：
- 物联网通信（IoT Hub）：腾讯云物联网通信平台，提供了MQTT协议支持，可实现设备与云端的可靠通信。详情请参考：物联网通信产品介绍
- 物联网套件（IoT Suite）：腾讯云物联网套件提供了一站式的物联网解决方案，包括设备接入、数据存储、消息通信等功能。详情请参考：物联网套件产品介绍
以上是关于将MQTT消息与发布者的clientID连接的完善且全面的答案。
相关·内容
我有一个发布者，它在"/ex/topicA/“下发送消息，另一个发布者在"/ex/topicB/”下发送消息给蚊子代理。
订阅者在"/ex/#“下不断地从broker订阅。
现在，由于网络连接不良，一个主题为"/ex/topicA“的出版商没有将数据发送给蚊子经纪人。
现在，paho mqtt订阅者如何知道哪个发布者没有将数据发送给mqtt？
浏览 17提问于2019-08-07得票数 0
回答已采纳
1回答
我已经成功地将MQTT连接到我的代理发布者和订阅者都工作得很好，但存在一个问题，我的订阅者没有主动接收消息，当我重新启动订阅者应用程序时，函数mqtt_publishedRecieved仅触发一次，并且一次只接收一条消息。为了获得另一条消息，我必须再次重启我的应用程序。据我所知，这是因为我在启动时调用了我的类的config方法。因此，它只在启动时检查订阅的主题。但我真的希望我的subscriber类中的功能在接收方发布消息后立即接收消息，这意味着两者应该并行工作。我的要求是，如果订阅者已连接，则为=>，在发布者触发时立即接收消息。=>如果订阅者断开连接，则消息应排队，稍后当订阅者
浏览 56提问于2021-11-07得票数 1
回答已采纳
3回答
我运行一个简单的mqtt publisher c代码来订阅"Hello World“。
mqtt subscriber1：
mosquitto_sub -h xx.xx.xx.xx -t "mq_test"
我连续地在另一个位置运行相同的mqtt发布程序代码，并向相同的主机订阅不同的主题。
mqtt subscriber2：
mosquitto_sub -h xx.xx.xx.xx -t "mq_t"
当我启动第二个publisher程序时，第一个mqtt订阅停止。为什么会出现这个问题，我认为订阅多个主题是可能的。
mqtt publisher c代码
浏览 0提问于2017-08-28得票数 1
我的要求是创建node red应用程序来读取来自n个设备和m个网关的消息，并使用MQTT节点作为MQTT发布到IBM，并将其处理并存储在cloudant DB中。如果有任何更新，那么设备应该订阅这些命令。我从IBM门户阅读，并能够使用MQTT节点向IOT节点发送和接收网关的消息。
需要澄清以下几点
可以使用节点红色模拟器同时从设备/网关发送消息(因为网关将直接发送消息给simulator，但是设备总是会向网关发送消息)
如何识别或区分沃森物联网节点中从设备/Gateway接收的消息
消息的顺序是如何发布的？是先进先出顺序吗？
是时候为这条信息活下去了？如果MQTT代理断开连接，
浏览 3提问于2017-02-03得票数 0
我正在运行Mosquitto，并且在同一个raspberry中使用node，我成功地将消息发送到我的MQTT服务器，并且还创建了一个成功连接的输入节点。我现在正在尝试从收到的消息中获取clientId信息。有没有办法弄到它？谢谢
浏览 0提问于2018-04-12得票数 1
我从一个python脚本同时从多个客户端发送多个消息，并尝试在另一个脚本上接收这些消息。我得到的问题是，消息被接收，但只从第一个连接的客户端收到，并且它一直在它上面循环。我需要的是以发布消息的方式从每个客户端获取消息。 import paho.mqtt.client as mqtt
import time
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("Connected to broker")
global Connected
浏览 114提问于2019-08-27得票数 0
回答已采纳
根据我在MQTT协议中读到的内容，它似乎不支持告知已发布消息的发布者是谁。但是，MQTT订阅者有可能知道消息来自哪个发布者吗？
也许是“msg.publisher”的变通方法？
#!/usr/bin/env python
import mosquitto
def on_message(mosq, obj, msg):
print "Publisher: %s, Topic: %s, "Msg: %s" % (msg.publisher, msg.topic, msg.payload)
cli = mosquitto.Mosquitto()
cli.on_me
浏览 22提问于2015-09-16得票数 4
最近我读了一篇物联网的文章，他说，通过协议，客户端可以通过一对多和多对一的方式进行通信。在mqtt规范本身中提到了一对多，但我在多对一中几乎没有混淆。我所理解的是，许多客户端在同一主题上发布，并且这些不同的publishers.Then只有一个订阅者，订阅者(用户)应该如何识别消息属于哪个发布者？另一个疑问是，如果两个发布者使用相同的主题发布他们的数据而不知道对方，因为每个客户端都连接到互联网，订阅者将获得这两个数据。但这并不是订阅者expected.He想要的仅来自一个发布者的数据。在mqtt通信中有没有可能发生同样的情况？
浏览 1提问于2015-09-12得票数 8
1回答
订阅客户端未收到消息MQTT
、、、、
我正在研究MQTT协议，我尝试发布和订阅两个不同的Java应用程序。
我的第一个应用程序是“发布”。我在MQTT服务器上发布了一条消息。
我的第二个应用程序是“订阅”。我订阅了一个主题，并尝试接收消息。但是我从来没有收到过这条消息。
当我运行这两个应用程序时，我从“订阅”应用程序开始，然后运行“发布”应用程序。当“发布”应用程序开始时，我失去了与“订阅”应用程序的连接，并且我无法接收我的消息。
在"Subscribe“应用程序中，client.setCallback(this)从不调用我的方法messageArrived()。(请参阅下面的代码)。
下面是我的两个代码应用程序：
发布应
浏览 3提问于2016-05-26得票数 0
我正在尝试在我的React web应用程序和一个在docker上运行的蚊子经纪人之间建立联系。为此，我使用了MQTT.js库。 到目前为止，我的代码如下： const mqtt = require('mqtt')
const client = mqtt.connect('tcp://172.19.0.4:1883')
console.log('mounted');
client.on('connect', function () {
console.log('connected')
client.s
浏览 33提问于2020-09-24得票数 0
我们有mqtt生产者和消费者。MQTT生成器位于客户端级。当我们向producer推送消息时，如果设备打开了，那么它就会收到消息。如果设备被关闭，那么它在打开之前不会收到消息。
我们需要知道，当消息发送到服务器中的MQTT时，如果服务器关闭了，那么我们需要知道它的状态是，它是否正在排队或未被服务器接收。
在此基础上，我们将向用户as发送消息，请打开设备进行具体操作。
有没有更好的方法来了解MQTT中的状态，以查找消息是否已发送、失败或排队以了解服务器是否处于活动状态。
浏览 0提问于2020-06-04得票数 0
关于这个话题，我有几个问题，所以我会把它们放在这里，否则我必须对不同的问题单独发表文章。场景是我有NodeMCU板，我将使用它通过MQTT (MQTT)接收来自多个发布者的多条消息。以下是我需要澄清的问题，我还没有实现，我只是在形成逻辑。假设我将通过MQTT代理不断地接收来自4 NodeMCU板的消息，然后将其发送到服务器进行存储，问题是
在我将其存储到服务器之前，1 publisher的消息会覆盖另一个发布者的消息吗？
来自MQTT代理的消息，它们是存储在NodeMCU板的ROM或RAM中吗？
MQTT代理能否同时将来自2个发布者的数据发送到同一个NodeMCU板？
这帖
浏览 0提问于2018-05-02得票数 0
回答已采纳
我正在使用mqtt来实现一种电子邮件通知系统。我还计划在webapp中使用它来触发通知。当我们以JSON格式抛出带有publisher id的MQTT url时，MQTT是否将数据存储在服务器端？我之所以问这个问题，是因为在我的例子中，MQTT只存储最后抛出的数据，如果我发送另一个数据，那么前一个数据就会消失。我想知道它是否从一开始就存在于MQTT端( MQ代表消息队列)&我还没有使用或需要在服务器/消费者端实现？
浏览 3提问于2015-05-15得票数 4
somenoe能告诉我如何以node-red格式获取mqtt消息的发布时间吗？
我的代理上有一个保留的消息，它通过mqtt提供给node-red。这条信息来自于一个家庭墙上的按钮，它通过homegear连接到我的经纪人。
现在的问题是，homegear保留了所有信息，这显然对传感器等有好处。但按钮的“真”信息--如果按下了--也会保留在它的主题中。在部署或重新启动node-red时，它将接收保留的消息，并在消息刚到达时执行操作。
直到homegear在按下按钮后在主题中放了一个"false“，我必须检查主题中的消息是否不是旧的。有可能吗？
node-red的mqtt help告诉我mq
浏览 9提问于2016-08-12得票数 2
回答已采纳
1回答
我是MQTT的初学者，我想我误解了这个概念。我使用带有QOS1& 2的节点red发布了一条消息(例如:M1001)，代理收到了该消息。此时，订户或接收器由于电源或互联网故障而断开。 当我现在重新连接到代理时，我在订阅者中没有收到消息(例如:m1001)，如果我设置了retain=true，该消息将存储在代理中，并重复执行该消息，直到我手动清除它。 我要求每条消息从pub传递到sub时没有故障。我如何才能做到这一点？
浏览 28提问于2019-04-10得票数 0
在web应用程序中，我使用Aedes作为代理，使用MQTT.js作为客户端。
在启动时，我连接到代理并订阅一些频道。
我想知道是否有办法以MQTT的方式获取之前的最后消息。
浏览 10提问于2020-10-28得票数 0
回答已采纳
我正在开发一个通信模块，其中服务器向mqtt发送数据，另一个客户端模块接收来自mqtt的消息。在这里，我需要在收到消息后来自mqtt nodejs客户端的确认，以便从服务器队列中删除该消息。 我正在使用nodejs mqtt客户端包(https://www.npmjs.com/package/mqtt#publish)。mqtt包有默认的确认功能吗？ client.handleMessage = (packet: any, callback) => {
console.log(packet);
}; 在上面的代码中，handle message中有一个回调函数，用于向服务器
浏览 68提问于2019-09-25得票数 0
回答已采纳
1回答
移动与ESP8266的连接
、、、、
我正在从事一个家庭自动化项目，我想将移动应用程序连接到ESP8266。
我可以发布从Mobile到AWS服务器的消息，AWS服务器是作为代理设置的。(工作)
我可以发布一条从AWS到Raspberry PI的消息。(工作)
我还可以发布从Raspberry到NodeMCU / ESP8266的Mqtt消息。(工作)
但是，当我试图把所有这些都整合在一起时，问题就会发生。当发布来自AWS的消息时，Raspberry会接收它，但它不会反映在NodeMCU / ESP8266上。
这是。
这就是我在我的ESP8266中使用的东西。当我发布从Raspberry PI，它是很好的工作
浏览 1提问于2016-08-22得票数 11
我一直在尝试使用paho mqtt客户端作为代理发布和接收消息，并且工作得很好。虽然我的用例涉及发送者向代理发布消息并断开连接，但此时，接收者(无论是连接的还是断开的)都应该使用该消息并立即删除它。我尝试了所有的属性，例如QOS，保留的消息，干净的会话等，但都没有产生我想要的结果。请帮帮忙。
浏览 48提问于2018-08-13得票数 0
1回答
我正在尝试将paho.mqtt用于python ()，而且一切都很好。我唯一的问题是我会发现找出是谁发的信息非常有用。我查找了源代码，但如果在client中传递的on_message变量是我用来连接到的客户机或发布消息的客户端的详细信息(我猜这是第一个选项)，我就不太明白了。
所以问题是-能不能找出谁(用户名)发送了这条消息？
浏览 1提问于2016-11-10得票数 0
回答已采纳
1回答
目前，我正在尝试使用MQTT、Python和OpenHab创建一个简单的应用程序。因此，我只想连接到MQTT服务器，订阅主题并读取放在那里的数据/消息。每件事都很好，但有“局限性”。Python客户端能够连接到MQTT，订阅和.轰隆隆！没什么!我可以从订阅的主题中读取消息，但是我需要在客户端连接之后更新主题。如果没有在客户端连接后重新更新主题数据，我将无法看到任何东西，即使有真正的数据。所以，简单来说
Python客户端(paho MQTT 1.3v)连接到MQTT (蚊子)服务器
订阅指定的主题(希望在此处查看当前主题数据)
除非有人重新更新话题，否则什么都不会发生。
如
浏览 3提问于2017-07-03得票数 0
1回答
我的问题是：
我有一个树莓派，我已经在它上面安装了Mosquitto代理。我的目标是使两个MQTT客户端通过Mosquitto代理进行通信，因此我在两个ESP8266 (WeMos D1 mini)上安装了以下代码，并创建了这个MQTT命令：mosquitto_pub -h 192.168.1.20 -t /wassim/led -m "on"。
因此，当我只连接一个ESP客户端时，我在串行监视器中看到消息"on“。但是当我连接第二个ESP客户端时，我在串行监视器上看不到任何消息...(但如果在树莓的终端上，那么我可以看到所有的东西。在客户端上，我看不到任何东西)。代码
浏览 2提问于2017-07-03得票数 0
我用python创建了一个Mqtt订阅，它将HA作为代理…。当我建立第一个连接时，我启动了一系列关于我连接的所有mqtt按钮的消息，即使我没有激活它们，因为我的订阅是"house/click/ #“。一旦列表完成，…如果你按下一个按钮，我就会开始收到信息I need…有没有办法删除它给我的第一个列表。 这是我使用的代码： import paho.mqtt.client as paho
import pandas as pd
import pyautogui
import os
import platform
def on_subscribe(client, userdata, m
浏览 55提问于2020-08-17得票数 0
我有四个mqtt客户端，其中两个将连接在一起，另外两个连接在一起。例如，客户端A在主题/AtoB上向客户端B发布数据，而客户端X在主题/XtoY上向客户端Y发布数据。现在，我将在我的PC上的mqtt代理上路由这两个主题。我应该如何设置我的经纪人？我还找到了mqtt客户端的mqtt库，但没有找到(可能吗？)库来编写mqtt代理。谢谢
浏览 2提问于2018-08-18得票数 0
2回答
根据我的研究，MQTT代理只保存最新的消息，但facebook在其messenger应用程序中使用MQTT。那么，他们是否使用自定义代理来保留消息呢？
https://www.facebook.com/notes/facebook-engineering/building-facebook-messenger/10150259350998920
我的问题是，mqtt代理是否可以保留所有发送的消息，以便我可以创建自己的聊天消息移动应用程序？我知道像HiveMQ这样的付费服务提供了这种功能，但我正在寻找一个免费的替代方案。
浏览 1提问于2016-12-26得票数 0
我有许多设备使用MQTT通过Solace向后端服务器发送数据。由于我需要处理大量传入消息，因此我正在考虑启动一些侦听器实例来处理传入消息。但是，它没有帮助，因为MQTT pub/sub实际上是一对多消息传递，即相同的消息将被传递给所有订阅侦听器。我知道Solace支持DTO，但它支持使用MQTT的DTO吗？如果是这样，我该怎么做呢？如果没有，有什么建议我如何启动多个侦听器来处理大量的传入消息？我现在考虑的是创建订阅这些主题的非独占交付队列。不确定是否有其他更好的方法。
谢谢。
浏览 2提问于2016-06-06得票数 1
我希望将MQTT connect设置为this属性，并在其他线程中使用此连接，该线程将并发地向MQTT代理发送消息。我想要实现的是
将MQTT connect设置为Jmeter属性
一个线程，它将使用连接向MQTT代理发送消息。
MQTT断开
到目前为止，我所做的是在同一个线程组中使用MQTT连接、发布采样器和MQTT断开连接。但是，当运行多个线程时，消息无法发布到线程-1以外的其他地方。
请让我知道是否有任何方法来实现这一点。
浏览 5提问于2022-02-14得票数 0
我用蚊子做mqtt客户端。
例如，您有发布和订阅主题的用户。该主题实际上与REsT端点相关。
场景1(典型的pub/sub用法)
UserA订阅主题/设备/123/meta
UserB将一些数据发布到主题/设备/123/meta
根据定义，此发布是向订阅者广播的。
我们有一个订阅/设备/#的脚本，它知道如何在收到发布的数据时为主题/设备/123/meta保存有效负载。此数据被保存到数据库中。
场景2
有人通过ReST接口(或直接的DB更新，关键是它不是MQTT发布)更新数据/设备/123/meta。
数据库更新
将发布消息发送给MQTT代理，以便所
浏览 2提问于2016-07-10得票数 0
我从pimoroni买了一个触摸phat，我正在使用我的树莓Pi Zero W (stretch OS)。Touch phat基本上是一个电容式按钮，为覆盆子设备添加屏蔽。()。我决定在我的touch phat python脚本中实现Paho MQTT函数，该脚本取自pimoroni示例脚本()。例如，当我按下'A‘按钮时，脚本将向另一个同时运行的脚本(MQTT客户端)发布一条MQTT消息，通知该按钮已被按下，而MQTT客户端脚本将执行最后的操作(例如，播放音频文件)。当我的脚本处于非活动状态大约5分钟时，问题就出现了。当我再次触摸按钮时，终端打印一个错误，指出带有MQTT发布函数的t
浏览 48提问于2018-01-12得票数 0
1回答
我有一个使用Amazon插件向mqtt MQ发送消息的NodeJS程序。我配置了队列和订阅，然后发布消息。Here是代码。 监听程序使用MQTT客户端，而我使用OpenWire或WSS发送消息。在这两种情况下，JMS客户端都没有接收到任何消息。 如果我为接收器编写NodeJS代码，它可以正常工作。 JMS客户端必须使用MQTT / WSS来接收消息吗？协议在这里很重要吗？
浏览 13提问于2021-03-20得票数 0
回答已采纳
我正在使用Mosquitto (现在是Paho) python客户端连接到HiveMQ代理。代码是非常基本的，摘自这里的文档- 。
#SUBSCRIBER
import paho.mqtt.client as mqtt
# The callback for when the client receives a CONNACK response from the server.
def on_connect(client, userdata, rc):
client.subscribe("GB/node0/", 2)
# The callback for when
浏览 1提问于2014-09-12得票数 5
回答已采纳
当我将带有QOS的MQTT消息发送到0时，我能得到传递的确认吗？
如何使用javascript，node.JS拦截答案？
浏览 5提问于2015-05-30得票数 0
回答已采纳
我在nodejs支持的应用程序中使用mqtt，在该应用程序中，可以与物联网设备通信，并且能够发布和订阅不同的topic.every，我可以发布和订阅不同的主题。
我能够发送客户端id或发布主题的发布者id，这是每个发布者的重复任务。
在订阅主题的同时，我们能知道谁是出版商吗？我在nodejs的mqtt客户端代码是
var mqtt = require('mqtt')
var url = "http://127.0.0.1:1883";
var client = mqtt.connect(url);
client.on('connect&
浏览 4提问于2018-01-05得票数 1
由于不断断开/重新连接，我的MQTT.js客户端无法从Mosquitto接收所有消息。当添加发布和订阅选项clean: false时，客户端将完全停止接收消息。我已经尝试了qos的所有设置，但都没有成功。我想我用错了cleanSession，有人知道吗？
我的配置如下：
var options = {
clientId: "python_pub",
clean: false,
qos: 2
};
// connect to the message server
var client = mqtt.connect('mqtt://PATH_T
浏览 44提问于2019-10-30得票数 1
2回答
Mosqitto ()支持哪些消息队列？另外，我想知道在MQTT协议中，为每个主题创建了不同的消息队列，或者在内存约束的情况下可以不需要消息队列。
浏览 2提问于2014-10-08得票数 5
回答已采纳
是的，正如问题所说，是否可以让发行者知道所有订阅特定主题的订阅者都收到在MQTT中发送的消息？
浏览 8提问于2014-09-06得票数 0
回答已采纳
2回答
我已经写了一个angularjs应用程序。有一个表单，用户可以在其中键入备注。这个应用程序使用一个特定的mqtt主题，比如“app/form/note”。此应用程序中的paho js客户端发布和订阅相同的主题。如果用户正在键入某些内容，则会发生onchange事件，并将新值发布到主题。
现在客户端正在接收他发送给代理的消息，因为他订阅了这个主题。但是接收到的消息是无用的，因为值是相同的。处理此问题的最佳方法是什么？
浏览 4提问于2016-05-09得票数 2
和标题一样，我可以区分新消息和保留的MQTT消息吗？以及如何知道消息何时由客户发布？所有这些没有的都在主题或消息中指定时间戳字符串。
浏览 2提问于2016-06-17得票数 3
3回答
最近，我开始使用paho mqtt for java和mqtt，我一直使用mqtt broker和paho客户端it self提供的持久性机制。也许我误解了(可能是这样) mqtt上下文中持久性的概念。
我们必须支持的用例如下：我们的mqtt客户端已经断开了7天(我非常怀疑这将发生，但很好)，甚至应用程序在这7天没有恢复连接的情况下关闭，并且一旦启动并运行，在断开连接时发送所有7天的所有消息。
Paho客户端支持缓冲消息在其或代理故障时的持久性，一旦网络恢复或代理运行，就会发送缓冲消息，但如果应用程序在客户端断开连接或代理不可用时关闭，则无法发送缓冲消息。
基本上，我的问题是-断开连接的缓冲消
浏览 0提问于2017-03-09得票数 2
目前我们有一个应用程序，可以通过MQTT控制多个设备。每个设备订阅一个唯一的主题，该主题以其设备ID命名。例如，设备A具有设备ID 123，因此它将订阅主题123。然后，如果应用程序想要向设备A发布控制消息，则它将发布名为123的主题，该主题是设备A的设备ID。
通过这样做，如果我们有1000个设备，那么我们将有1000个主题。这是一个非常糟糕的设计。所以我们想，也许我们可以通过设置接收主题的客户端ID来将主题发布到特定的客户端，因为每个连接到代理的客户端都必须设置一个客户端ID。但是，我们没有找到任何允许发布到特定客户端的方法。而且看起来MQTT不能处理这样的事情。它只发布给订阅相同主题的客
浏览 2提问于2017-02-16得票数 5
回答已采纳
1回答
我正在使用MQTCEP4.2.0，并且已经创建了WSO2输入事件适配器。我还创建了接收器，它将接收来自外部主题的数据，然后使用流，我添加了一些逻辑，然后使用发布者将相同的消息发布到另一个外部主题。
现在，当我重新启动应用程序时，我得到以下两条消息：
INFO {org.wso2.carbon.event.input.adapter.core.internal.InputAdapterRuntime} - Connecting receiver mqttreceiver_test
INFO {org.wso2.carbon.event.input.adapter.mqtt.internal.u
浏览 4提问于2019-06-19得票数 0
1回答
我正在用Eclipse实现MQTT客户端，有一些问题：
发布服务器和订阅服务器都使用qos =1和setCleanSession = false连接到代理。
我的流量：
将订阅者和发布服务器连接到代理，没关系。
断开订阅服务器(强制停止我的项目，其中包括订阅服务器)，发布服务器继续发布消息。
重新连接订阅服务器->它不能连接并抛出异常: connectionLost。
如果设置订阅服务器= 0的qos，则不会引发异常，但在订阅服务器脱机时，客户端不会接收发布服务器发送的消息，而我不希望这样做。
有人能帮我吗？
这是我的代码
try {
//
浏览 1提问于2018-05-08得票数 0
这段代码向我订阅了一个代理，然后我输出特定主题系列的消息。现在当我第一次开始的时候，我有一个和设备数量一样多的消息列表……一种对所有设备的状态检查。在为每一行编写的代码中，通过pyautogui库在远程屏幕上生成一个操作。有没有可能告诉他，对于前n行，他让我不要做任何事情，然后开始做我告诉他的操作？
import paho.mqtt.client as paho
import pandas as pd
import pyautogui
import os
import platform
def on_subscribe(client, userdata, mid, granted_qos)
浏览 2提问于2020-08-17得票数 0
我试图通过docker和docker组合运行本地蚊虫代理、发布者和订阅者设置，但发布者无法连接到代理。但是，通过cli连接到本地代理很好。在安装程序下运行时获取以下错误。
{ Error: connect ECONNREFUSED 127.0.0.1:1883
at TCPConnectWrap.afterConnect [as oncomplete] (net.js:1088:14)
errno: 'ECONNREFUSED',
code: 'ECONNREFUSED',
syscall: 'connect',
addres
浏览 5提问于2020-08-27得票数 3
回答已采纳
1回答
我正在使用安卓和Apache Active MQ中的MQTT库。我可以订阅和发布消息，但我不知道如何才能获得消息id以及订阅者已经接收到消息的确认。
在publishArrived中，我得到了以下信息
topicName
payload,
qos,
retained
但是在有效负载中，我只是收到我发送的字符串消息，我如何提取以下信息。我想使用这些字段我可以得到确认。
浏览 2提问于2014-08-29得票数 0
2回答
我使用MQTT协议在两台计算机之间发送消息。我已经从这段代码中得到了模式。出版商：
import paho.mqtt.client as mqtt
from random import randrange, uniform
import time
mqttBroker ="mqtt.eclipse.org"
client = mqtt.Client("Temperature_Inside")
client.connect(mqttBroker)
while True:
randNumber = randrange(10)
client
浏览 5提问于2020-11-22得票数 1
MQTTUtils似乎只提供了三个方法，def createStream(jssc: JavaStreamingContext，brokerUrl: String，topic: String，storageLevel: StorageLevel)：JavaDStreamString
创建一个输入流，用于接收由MQTT发布者推送的消息。def createStream(jssc: JavaStreamingContext，brokerUrl: String，topic: String)：JavaDStreamString
创建一个输入流，用于接收由MQTT发布者推送的消息。def createS
浏览 2提问于2015-01-05得票数 1
我在追踪蚊子几天，我想问几个问题：
MQTT代理是否会在发布/订阅时存储所有pub/sub主题？如果是，在哪里？
哪个结构(还是文件？)在发布发送消息时，publisher将搜索是否已使用过主题的结构，然后再使用它？
感谢大家对mqtt初学者的回答。
浏览 0提问于2018-07-14得票数 0
我是MQTT的新手。我使用mqttTopic.publish(message)，我能检查订阅主题的订阅者是否收到消息吗？
浏览 1提问于2018-06-27得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
