paho mqtt broker如何知道哪个发布者断开了连接？
Paho MQTT Broker是一个开源的MQTT消息代理服务器，用于实现MQTT协议的消息传输。当一个发布者（Publisher）断开连接时，Paho MQTT Broker可以通过以下几种方式来知道：
- 心跳机制：MQTT协议中定义了心跳机制，发布者和代理服务器之间会定期交换心跳包以保持连接。如果代理服务器在一定时间内没有收到来自发布者的心跳包，就可以判断该发布者已经断开连接。
- 客户端断开事件：Paho MQTT Broker可以监听客户端断开事件，当一个发布者断开连接时，代理服务器会触发相应的事件。通过监听这些事件，可以及时得知哪个发布者断开了连接。
- 会话超时：Paho MQTT Broker可以设置会话超时时间，当一个发布者在一定时间内没有发送任何消息或心跳包时，代理服务器会认为该发布者已经断开连接，并关闭与其相关的会话。
以上是Paho MQTT Broker知道哪个发布者断开连接的几种方式。Paho MQTT Broker是Eclipse Paho项目的一部分，它提供了一种轻量级的、可靠的、基于发布/订阅模式的消息传输解决方案。腾讯云提供了MQTT Broker的托管服务，称为物联网通信（IoT Hub），您可以通过腾讯云IoT Hub产品来实现MQTT消息传输和管理。详情请参考腾讯云IoT Hub产品介绍：https://cloud.tencent.com/product/iothub
相关·内容
我有一个发布者，它在"/ex/topicA/“下发送消息，另一个发布者在"/ex/topicB/”下发送消息给蚊子代理。
订阅者在"/ex/#“下不断地从broker订阅。
现在，由于网络连接不良，一个主题为"/ex/topicA“的出版商没有将数据发送给蚊子经纪人。
现在，paho mqtt订阅者如何知道哪个发布者没有将数据发送给mqtt？
浏览 17提问于2019-08-07得票数 0
回答已采纳
1回答
订阅客户端未收到消息MQTT
、、、、
我正在研究MQTT协议，我尝试发布和订阅两个不同的Java应用程序。
我的第一个应用程序是“发布”。我在MQTT服务器上发布了一条消息。
我的第二个应用程序是“订阅”。我订阅了一个主题，并尝试接收消息。但是我从来没有收到过这条消息。
当我运行这两个应用程序时，我从“订阅”应用程序开始，然后运行“发布”应用程序。当“发布”应用程序开始时，我失去了与“订阅”应用程序的连接，并且我无法接收我的消息。
在"Subscribe“应用程序中，client.setCallback(this)从不调用我的方法messageArrived()。(请参阅下面的代码)。
下面是我的两个代码应用程序：
发布应
浏览 3提问于2016-05-26得票数 0
我编写了一个lambda，它使用AWS客户端发布到AWS IoT Broker。
AWS MQTT客户端在其下划线中使用PAHO MQTT客户端。
每当我的Lambda被调用时，它都会将消息发布到AWS IoT Broker，该代理目前触发了一个IoT规则。
但是，当调用lambda的两个连续消息之间的持续时间超过30秒时，客户端连接就会丢失。尽管重试逻辑重新建立了连接，但损失了几毫秒。
我最初的想法是，可能是IoT代理由于不活动而断开了客户端的连接。因此，我编写了一个从本地运行的连接IoT代理的简单程序。
我打开了org.eclipse.paho.client.mqttv3.in
浏览 0提问于2018-05-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 java代码(paho)写的，当它试图连接到Mosquitto时工作良好。它能够建立、发布所有消息到一个主题。但是使用MQXR (包含在MQ中的代理)，我得到
严重:无法连接到MQTT broker，请求可能丢失。连接丢失(32109) -由以下原因引起的org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:138) at java.io.DataInputStream.readByte(DataInputStream.java:250) at java.io.EOFExcep
浏览 3提问于2016-06-16得票数 0
1回答
我目前正在MQTT eclipse/paho.mqtt.java库上为我的项目使用。这是eclipse/paho.mqtt.java库的链接。
我想用http协议与MQTT连接。但是最初的库为tcp协议做了准备。我试图通过创建一个mqtt客户端来与mqtt建立连接。我会在下面展示我的代码，
对不起，在IP地址和URL中使用xxx符号。
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
public class MQTT {
浏览 45提问于2019-09-19得票数 6
回答已采纳
我已经创建了一个简单的node js代理和发布器，并且工作正常，请看一下下面的代码。
broker
--------------
//MQTT broker
var mosca = require('mosca')
var settings = {port:3000}
var broker= new mosca.Server(settings)
broker.on('ready',()=>{
console.log("Broker is ready")
})
出版商是
//mqtt publisher
var mqtt=req
浏览 43提问于2021-02-13得票数 0
1回答
当我在互联网上尝试一个教程时，我没能连接到mqtt代理--有人可以帮我吗？
import paho.mqtt.client as mqtt
broker_url = "mqtt.eclipse.org"
broker_port = 1883
client = mqtt.Client()
client.connect(broker_url, broker_port)
print(client)
Traceback (most recent call last):
File "C:\Workspace\FI Systemintegration\Python\Mit
浏览 8提问于2022-01-11得票数 1
我在Ubuntu上托管了Mosquitto broker in Digital Ocean Cloud droplet。域名为instrux.live，域名IP为192.34.63.138。我从两个终端窗口发布和订阅消息，运行良好。
当我尝试使用Paho MQTT android客户端将其与android连接时，它无法连接。我还检查了它与MyMQTT安卓应用程序的连接，但它没有连接。在确保安卓代码没有任何错误后，我再次检查了它与eclipse.org网站上的Eclipse Paho Javascript客户端的连接，但它没有连接。现在，我意识到我的代理配置中可能缺少或错误的东西，不允许它与其他
浏览 1提问于2020-06-20得票数 0
1回答
注:我使用EMQX作为代理，python-paho作为客户端库。我不知道是谁对这个问题负责。
如果发布服务器在一段时间内不发送任何消息，则订阅服务器将断开连接，但也会再次重新连接(因为loop_forever会自动处理重新连接)。但是在重新连接之后，如果生产者再次开始发送数据，自动重新连接的服务器将不会收到任何消息。在这种情况下，订阅服务器需要重新启动(手动重新连接)。
我的订户
import paho.mqtt.client as mqttClient
import json
import datetime
def on_connect(client, userdata, flags, r
浏览 5提问于2021-05-20得票数 0
回答已采纳
我正在开发一个python应用程序，应该可以接收mqtt消息。我使用的是paho-mqtt库。
在设置了用户名/密码和回调函数on_message之后，我订阅了该主题并建立了到代理的连接。然后启动loop_forever()。
下面是我的代码：
import paho.mqtt.client as mqtt
MQTT_TOPIC = "my_topic"
BROKER_ENDPOINT = "my_broker_url"
BROKER_PORT = my_port
BROKER_USERNAME = "my_username"
BROKER_P
浏览 69提问于2019-08-19得票数 0
我设法在我的RPi中的Paho-MQTT客户端和VPS中的MQTT代理之间建立了连接。
现在，我正试图保护MQTT连接，并向代理添加了用户和密码。我已经更改了mosquitto.conf文件，添加了新的密码文件。
但是现在，当我试图连接我的Paho-MQTT客户端时，我得到了以下错误：
错误结果代码:5
这是我的paho-mqtt客户端脚本：
#!/usr/bin/env python
import paho.mqtt.client as mqtt
import subprocess
import datetime
import time
# Broker data
broker
浏览 1提问于2018-01-11得票数 9
回答已采纳
1回答
我对mqtt协议很陌生。我很难将我的mqtt客户端(它连接到另一个网络)与我的mqtt代理连接到我的pc上，它有ip地址。
我的mqtt代理连接到我的家庭wifi，当我的客户连接到一个不同的家庭wifi。
我使用的是蚊帐经纪人，配置如下：
listener 1883 0.0.0.0
allow_anonymous true
Mqtt客户端代码：
import paho.mqtt.client as mqtt
from random import randrange, uniform
import time
broker = "10.18.124.166"
port = 188
浏览 6提问于2022-05-25得票数 0
回答已采纳
有三个文件: broker.py；sub.py；pub.py； broker.py： import logging
import asyncio
from hbmqtt.broker import Broker
logger = logging.getLogger(__name__)
config = {
'listeners': {
'default':{
'type': 'tcp',
'bind': 'localhost:99
浏览 17提问于2020-07-29得票数 0
1回答
我正在尝试创建一个插件，允许NativeScript应用程序连接到MQTT服务器。当我试图运行应用程序时，我在我的应用程序中得到以下错误：
ComponentInfo{org.nativescript.testMQTT/com.tns.NativeScriptActivity}：java.lang.RuntimeException:无法启动活动com.tns.NativeScriptException:调用js方法onCreate失败
TypeError:无法读取未定义文件的属性'paho‘："，行: 1，列: 265
框架:功能：‘NativeScriptMQTTClien
浏览 2提问于2016-04-21得票数 0
回答已采纳
1回答
我一直试图找到这个问题的答案或信息，但还没有结果。这个想法是用python将相同的主题发布到两个不同的MQTT服务器中。我是说，就像这样：
import paho.mqtt.client as paho
import datetime, time
mqttc = paho.Client()
host1 = "broker.hivemq.com" # the address of 1st mqtt broker
host2 = "192.168.1.200" # the address of 2nd mqtt broker
topic= "testin
浏览 3提问于2017-05-24得票数 0
回答已采纳
我使用 Java (JAR)连接到MQTT。
但是我想连接两个使用同一个库的代理。我已经实现了与两个代理连接的代码，它确实是连接的，但问题是在某个连接之后，随机断开连接(任何一个连接)。
那么，使用一个MQTT客户端库与两个MQTT Broker连接的最佳方法是什么。
更新的
连接代码如下所示：
import org.eclipse.paho.client.mqttv3.MqttClient;
Class com.test.A
{
MqttClient mMqttClient;
A()
{
mMqttClient = new MqttClient(&#
浏览 0提问于2017-07-21得票数 1
我正在尝试使用Python类来设置MQTT连接器。我面临的问题是，self.connected总是被打印为False，即使在on_connect模块中我已经更改了它的值。此外，没有执行on_connect模块中的两个打印指令。但是，如果我这样做了：
print(self.client.connect(host=broker, port=port, keepalive=120))
在bootstrap_mqtt模块中，结果为0，这意味着客户端已连接。
我做错了什么？
我使用这个例子来更好地理解Python类是如何工作的，特别是如何管理类中的模块/变量。
谢谢!
这是我的密码：
import pa
浏览 14提问于2022-07-18得票数 0
回答已采纳
1回答
我正在尝试构建一个Tizen Web应用程序，它使用Paho MQTT JS库连接到MQTT代理。
但是，每次运行应用程序时，我都会收到以下错误：
Error: AMQJS0011E Invalid state already connected.
这是我的密码
/**
*
*/
var broker="broker.mqttdashboard.com";
var port=8000;
var client=new Paho.MQTT.Client(broker,port,"myWebClientID_"+parseInt(Math.random(
浏览 0提问于2018-12-02得票数 0
回答已采纳
我正在开发一个连接到本地代理( dyson )的webapp，问题是我不能直接从浏览器直接连接到MQTT协议，并且我不能编辑dyson broker配置来打开websockets端口。因此，我正在创建一个新的代理，其中包含桥接到dyson代理的开放websockets。我已经测试了通过服务器MQTT直接访问dyson，并且工作得很好，我可以从中检索数据。但是当我尝试从我的代理连接时，它会连接，然后抛出连接被拒绝。 这是我的代理配置： listener 9001
protocol websockets
allow_anonymous true
listener 1883
protocol m
浏览 114提问于2021-11-02得票数 0
我从一个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
回答已采纳
这是我的代码，它连接，执行1发布，然后读取本地主机服务器中出现的消息。
import time
import paho.mqtt.client as paho
broker="localhost"
def on_message(client, userdata, message):
time.sleep(1)
print("received message =", str(message.payload.decode("utf-8")))
client = paho.Client("client-001"
浏览 10提问于2021-04-14得票数 0
我一直在尝试将MQTT整合到我的一个Android应用程序中。我最初让它在一个活动中工作，后来尝试将它移到一个服务中在后台运行。我可以连接并发送来自该服务的消息，但无法接收消息。我的服务实现了MqttCallback并覆盖了messageReceived()函数，但它似乎从未被调用过。有人能帮我解释一下为什么回调没有触发吗？
package com.example.test;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import org.eclipse.paho.client.mqttv3.IMqttDel
浏览 7提问于2017-08-13得票数 1
MQTT问题：
嗨，我正在尝试设置多个Raspberry Pis之间的MQTT网络(从两个开始)。我有一个连接了热敏传感器的raspberry pi (RPi-A) MQTT客户端和一个raspberry (RPi-B) MQTT代理/客户端，作为我的网络的集线器。通过python脚本，我希望温度每30分钟从RPi-A通过MQTT发送到主题传感器/数据，并由RPi-B接收。当RPi-B通过主题传感器/数据从RPi-A接收到消息时，我希望它通过MQTT主题传感器/指令响应RPi-A的指令。下面是我的脚本，到目前为止，RPi-A可以发送消息，RPi-B可以接收消息，但我不知道RPi-B如何响应。
浏览 2提问于2016-05-03得票数 6
回答已采纳
1回答
我有一个mqtt beoker，我正在尝试连接和订阅python。代码
client = mqtt.Client("P1",clean_session=True) #create new instance
client.on_connect = on_connect
client.on_message = on_message #attach function to callback
client.on_disconnect = on_disconnect
print("connecting to broker")
client.connect(broker_a
浏览 54提问于2019-08-07得票数 2
回答已采纳
目前，我使用以下函数发布到MQTT代理：
import paho.mqtt.client as mqtt
import paho.mqtt.publish as publish
def publish_to_broker(data):
publish.multiple(data, hostname=example_host, port=8883, client_id="example_id", keepalive=60,
will=None, auth={'username': "example_use
浏览 43提问于2019-12-02得票数 0
我正试着绕着泛美卫生组织-MQTT图书馆转转。我很难理解在库的编码中什么是明显的约定，但这对我来说毫无意义。如果有人能给我一个我应该寻找的话题，我很乐意去查这个。
许多paho-mqtt教程和PAHO基础页面()都谈到了如何处理Client对象的on_message和on_connect方法(或者至少我认为是方法)。这些教程都提供了一种使用这些方法的标准方法，但我无法理解。其内容如下：
定义一个函数，该函数接受一定数量的参数。类似于：
def on_message(client, userdata, message):
print(message.payload, 'on&
浏览 11提问于2022-11-28得票数 0
因此，我有一个托克/蚊子码头集装箱运行，我可以连接从外部码头。
然后，我使用了一个Python码头容器，它应该向我的蚊虫经纪人发布数据。这是我的密码：
import paho.mqtt.client as paho
import time
import random
broker = "localhost"
port = 1883
def on_publish(client, userdata, result):
print("Device 1 : Data published.")
pass
client = paho.Client(&
浏览 6提问于2020-04-05得票数 5
回答已采纳
2回答
我有一个通过python连接的mqtt代理。
如果连接成功，我想检查我是否能够连接到我的代理并触发邮件。
我打算使用全局变量connected，如果在尝试连接后该变量为false，我将触发警报。
我的代码：
import paho.mqtt.client as mqtt
import time
broker_address="ip"
port = "port"
global connected
def mqttConnection():
connected = False
print(connected)
client = mq
浏览 0提问于2019-08-30得票数 0
尝试简单地订阅，而不断开与Mosquitto的连接，从发布特定主题中的数据的设备中获取所有消息，将它们保存在BD中，并将它们发布到一个执行"staff“操作的php中。
这是我的subscribe.py
import paho.mqtt.client as mqtt
from mqtt_myapp import *
topic="topic/#" # MQTT broker topic
myclient="my-paho-client" # MQTT broker My Client
user=
浏览 7提问于2016-10-05得票数 2
回答已采纳
我正在尝试从运行在我的raspberry pi上的Paho库订阅并发布到我在windows机器上运行的nodejs服务器上的MOSCA MQTT代理，但是没有发生任何事情，那么问题是什么呢注意:当我从nodejs客户端连接到代理时，它在这里工作
var mosca = require('mosca');
var settings = {
port: 1883
};
//here we start mosca
var server = new mosca.Server(settings);
server.on('ready', setup);
// fi
浏览 2提问于2018-07-01得票数 0
2回答
我在cloudMQTT创建了mqtt broker，下面是我获得的关于端口和服务器的信息
现在，我编写了代码来运行连接到该代理并发送hello world的网页。
<html>
<head>
<title>JavaScript MQTT WebSocket Example</title>
<script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.js" type="text/java
浏览 43提问于2018-03-02得票数 0
回答已采纳
1回答
mqtt客户端问题
、、、
我有以下代码用于mqtt客户端从代理接收消息。如果客户端与broker断开连接，则客户端再次尝试使用connect()调用与broker连接。我读过paho文档，说loop_start()将处理与broker的重新连接。请让我知道使用connect() call与broker重新连接或让它自己处理是否正确。
import paho.mqtt.client as mqtt
import json
import time
is_connect = False
# The callback for when the client receives a CONNACK response from
浏览 0提问于2017-10-15得票数 0
我使用Mosquitto库创建了一个MQTT代理。我已经创建了一个Angular 5 Ionic 3移动应用程序，它充当paho客户端。我能够启动mqtt代理。当我在Android设备上运行移动应用程序时。它尝试连接到代理，我得到“套接字错误的客户端，断开连接。”马上就去。
我想知道如何解决这个问题。另外，我想知道如何在mac上创建Paho代理
Musquitto :以下步骤用于在mac上安装和运行broker
/usr/bin/ruby -e "$(curl -fsSL
https://raw.githubusercontent.com/Homebrew
/install/maste
浏览 4提问于2019-01-24得票数 0
我编写了基本的MQTT python客户端。但它不体面地断绝了联系，没有给出任何错误。当我查看事件日志文件时，我发现它是连接的，同时也是不正常地断开连接的。
import paho.mqtt.client as mqtt
Broker = "192.168.43.246"
def on_connect(client, userdata, flages, rc):
print("Connected with result code=",rc)
client = mqtt.Client(client_id="Client123"
浏览 0提问于2018-07-09得票数 1
回答已采纳
我所编写的代码的输出是 on_publish
('Connected', '0')
('message received ', 'test1234')
('message topic=', u'paho/test') 代码如下： import paho.mqtt.client as mqtt
import time import json
def on_connect(client,data,flag,rc):
print("Connected",str(rc))
浏览 44提问于2019-02-22得票数 0
回答已采纳
1回答
我正在尝试让两个mqtt客户端在具有以下配置的mqtt服务器上通信：
listener 1883
persistence true
connection_messages false
log_timestamp true
allow_anonymous false
这段代码是: File Pong.py
import paho.mqtt.client as mqtt
broker = 'ipserver'
pub_topic = "Pong"
sub_topic = "Ping"
def on_connect(client, userdata
浏览 4提问于2021-02-22得票数 0
1回答
短的 当浏览器失去焦点时，有没有办法防止浏览器中的mqtt断开连接？ 长的那个 在此之前，我在浏览器中使用Paho mqtt与安全的web套接字通信。Paho有时在建立与Paho的连接时会遇到问题，因此我们改用mqtt.js 我发现它在建立连接方面要好得多。 但是，当我离开浏览器一段时间后，它似乎断开了连接，但是当选项卡重新获得焦点时，它又很快连接了起来。 我可以看到有超时功能的原因，但应该可以将其关闭。 是吗?
浏览 188提问于2021-09-17得票数 0
我正在尝试同时建立RPi作为发行者和订阅者。我将这样做，将subscriber.py和publisher.py作为线程，并一个接一个地运行它们。当涉及到代码时，我遵循了，我也从这里取了代码。一开始，我在没有线程的情况下运行这两种代码。Publisher.py工作得很好。当我运行subscriber.py时，我得到以下信息：
Traceback (most recent call last):
File "/home/pi/subscriber.py", line 34, in <module>
mqttc.loop_forever()
File &#
浏览 4提问于2022-04-21得票数 0
回答已采纳
我对Python有一个问题(我是一个Python新手，正在学习它)。我在Debian 9系统上使用了2.7.9版。我在python中安装了paho和tinkerforge包。
我使用Paho MQTT客户端开发了一个脚本，将我的蚊子连接到代理。我想使用加密连接。我的连接在未加密时工作正常，但在加密时失败。在openHAB (MQTT-Subscriber)和MQTTFX (MQTT-Subscriber和Producer)上，连接可以很好地加密
我在我的脚本中使用了以下参数：
self.client = mqtt.Client()
self.client.tls_set("/home/
浏览 1提问于2017-09-09得票数 2
我正在运行一个示例solace broker (使用命令here)，并尝试从web浏览器连接到它。我已经成功地使用客户端库连接到它，但我知道应该可以使用paho-mqtt库连接到它。不幸的是，所有的例子都是针对Java库的，它使用了不同的连接API。有没有人有一个直接调用"mqtt.Connect“并获得成功返回代码的示例？
浏览 16提问于2019-02-18得票数 0
回答已采纳
1回答
我有一个MQTT程序，它接受名为"message“的字符串变量。如何将变量"message“输出到外部，以便将其导出到另一个python程序
import paho.mqtt.client as paho
import time
def onMessage(client,userdata,msg):
message=str(msg.payload.decode())
client = paho.Client()
client.on_message = onMessage
client.connect("b
浏览 9提问于2022-10-04得票数 0
场景：--我有一个python虚拟传感器(一个python程序)，它通过协议向我的ThingsBoard设备提交数据。我可以在仪表板上可视化数据，所以我确信数据是接收到的。
问题:当我尝试使用泛美卫生组织将python订阅服务器连接到thingsboard broker (demo.thingsboard.io)时，获得连接代码为0，所以连接是OK的，但是--不过，--我看到仪表板停止可视化来自虚拟传感器的数据，但是订阅服务器没有收到任何信息。
虚拟传感器发布在v1/设备/me/遥测，用户订阅的主题是v1/设备/me/遥测。
如何在订阅服务器客户端上显示虚拟传感器发布的数据？
虚拟传感器代码：
浏览 1提问于2020-03-22得票数 0
1回答
MQTT代理测试
、、
尝试创建订阅MQTT代理并处理数据的Python脚本。然而，到目前为止，MQTT代理还没有接收到任何数据，因此很难进行测试。
我找到了以下脚本来订阅主题并打印出有效负载，但似乎无法连接到测试代理：
import paho.mqtt.client as mqtt
broker_url = "iot.eclipse.org"
broker_port = 1883
def on_connect(client, userdata, flags, rc):
print("Connected With Result Code "+rc)
def on_messa
浏览 0提问于2020-01-24得票数 1
回答已采纳
我正在运行一个交通灯(π-停止)解决方案，我的项目与MQTT集成。因此，发布者将向订阅者发送计数的数量，而订阅者将控制和更改交通灯。然而，我无法从出版商中发出任何点票。请指教，谢谢
MQTT_pub.py (出版商)
import paho.mqtt.client as mqtt
import paho.mqtt.publish as publish
sub_topic = "light" #recieve message on this topic
pub_topic = "light" #send message to this topic
Broke
浏览 4提问于2017-01-18得票数 0
回答已采纳
1回答
在python中使用MQTT的web应用程序(使用paho-mqtt )中，我想知道是否有一种实时获取代理状态的方法，因为我找到的唯一方法是将变量"rc“存储到方法on_connect中，但它更像客户机/连接状态。
编辑1:在阅读了蚊帐代理文档之后，我发现您可以订阅'$SYS/broker/connection/#'，如果连接打开，它应该给你返回1，如果连接关闭，它会给你返回0。然而，当我这样做时：
subscribe.callback(self.message_callback, '$SYS/broker/connection/#', port = p
浏览 0提问于2018-05-22得票数 1
回答已采纳
我正试着通过paho-mqtt发送图像。我可以通过client.publish()发送一个简单的字符串，或者当不使用paho.client -> client.publish()时发送一个简单的字符串，但是使用publish.single()我的字节数组。 当尝试用client.publish()发送字节数组时，我在我的代理上得到一个套接字错误，并且它不发送我的消息(没有on_publish调用)。我遗漏了什么？ client = paho.Client()
client.on_connect = on_connect
client.on_publish = on_publish
cl
浏览 259提问于2020-04-08得票数 2
回答已采纳
我设置了一个Paho MQTT客户端来接收消息，它看起来像下面的代码…… class PrimaryListener:
def __init__(self):
self.client = mqtt.Client("paho-test-subscriber", False)
self.client.on_connect= self.on_connect
self.client.on_message= self.on_message
self.client.on_disconnect = self.
浏览 27提问于2020-04-12得票数 0
回答已采纳
1回答
我正在使用Paho连接到我的MQTT brooker，然而，回调并不像预期的那样工作。我已经了解了这些文档，并且无法理解为什么这些函数被忽略了。
import paho.mqtt.client as mqtt
import mqttUtils as utils
# Subscribe To Topic
def subscribeToTopic(client, topic):
try:
result = client.subscribe(topic, 2)
if result[0] == 0:
utils.logging.in
浏览 0提问于2019-11-30得票数 0
我正在尝试在我的项目中实现eclipse.paho来连接Mqtt Broker (包括订阅和发布目的)。问题是，当我使用订阅功能(实现MqttCallback接口)时，我不知道如何在连接丢失的情况下重新连接。MqttCallback接口有一个connectionLost方法，但它对于调试导致连接丢失的原因很有用。我搜索了一下，但找不到建立自动重新连接的方法。关于这个问题，你能推荐一种方法或文档吗？
浏览 0提问于2015-11-16得票数 11
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
