多个订阅的Paho mqtt回调
多个订阅的Paho MQTT回调是指使用Paho MQTT客户端库实现的一种机制，用于处理多个订阅主题的消息回调。Paho MQTT是一个开源的MQTT（Message Queuing Telemetry Transport）客户端库，用于在物联网和云计算应用中实现设备与服务器之间的可靠通信。
在使用Paho MQTT库进行订阅时，可以通过回调函数来处理接收到的消息。多个订阅的情况下，可以使用一个回调函数来处理所有订阅主题的消息，也可以为每个订阅主题设置不同的回调函数。
优势：
- 灵活性：多个订阅的Paho MQTT回调可以根据实际需求，自定义处理不同订阅主题的消息，提供了灵活性和定制化的能力。
- 高效性：Paho MQTT库采用轻量级的协议，具有较小的网络开销和资源消耗，能够在低带宽和不稳定网络环境下高效地传输消息。
- 可靠性：Paho MQTT库支持QoS（Quality of Service）级别，可以确保消息的可靠传输，保证消息不丢失和按顺序传递。
应用场景：
- 物联网应用：多个订阅的Paho MQTT回调适用于物联网设备与云平台之间的通信，可以实现设备状态监控、远程控制、数据采集等功能。
- 实时数据传输：通过多个订阅的Paho MQTT回调，可以实现实时数据的传输和处理，例如传感器数据的实时监测和分析。
- 智能家居：多个订阅的Paho MQTT回调可用于智能家居系统中，实现设备之间的消息交互和联动控制。
推荐的腾讯云相关产品：
腾讯云物联网通信（IoT Hub）：提供了基于MQTT协议的物联网设备接入和消息通信服务，支持多个订阅的Paho MQTT回调。详情请参考：https://cloud.tencent.com/product/iothub
腾讯云消息队列CMQ：提供了高可靠、高可用的消息队列服务，可用于实现消息的发布和订阅。详情请参考：https://cloud.tencent.com/product/cmq
腾讯云云服务器（CVM）：提供了弹性、安全的云服务器实例，可用于部署和运行Paho MQTT客户端。详情请参考：https://cloud.tencent.com/product/cvm
腾讯云云数据库MySQL：提供了高性能、可扩展的云数据库服务，可用于存储和管理与Paho MQTT相关的数据。详情请参考：https://cloud.tencent.com/product/cdb
相关·内容
我所编写的代码的输出是 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
回答已采纳
我已经安装了蚊子，并在终端使用没有问题，也安装了c++的paho，蚊子和paho都很好用。然后通过pip为python安装了paho。现在我尝试用这段代码来测试它，但是on_message和on_connect函数从未被调用过。我正在做
mosquitto_pub -h localhost -t "test" -m "This is a message"
虽然python脚本运行，但它不工作。它永远不会到达打印"on_message!“的代码行。
import paho.mqtt.client as mqtt
def on_connect(self,
浏览 5提问于2016-06-21得票数 3
假设我订阅了某个主题，而蚊子服务器将继续发布有关该主题的消息。
当一条来自蚊虫经纪人的新消息到达时，如何调用on_message方法？它是在主线程上运行，从而阻塞它，并且只在当前消息被处理时处理下一条消息，还是每次新消息到达时它都会使用on_message方法生成一个新线程？
import paho.mqtt.client as mqtt
def on_message(client, userdata, message):
print message.payload
return True
topics = ["topic1",]
client = mqtt
浏览 0提问于2019-09-13得票数 3
回答已采纳
我在paho-mqtt上测试了示例程序，我知道loop_forever()函数可以处理重新连接。但是我的问题是，尽管loop_forever()可以重新连接，但它不能重新订阅。服务器突然崩溃应该是个问题，在这种情况下，客户端还在监听，但当服务器重启时，客户端可以重新连接，但不能再订阅消息。我想也许我应该重写loop_forever()函数，但我不确定我是否正确，以及如何做到这一点。
import sys
try:
import paho.mqtt.client as mqtt
except ImportError:
# This part is only required to
浏览 0提问于2016-05-14得票数 1
回答已采纳
我设法发表了几个主题，并阅读了其中一个。我需要做的是倾听和阅读所有已发表的主题，并获取信息。这是我使用的代码：
将消息发布到3个主题：
#!/usr/bin/env将python3 paho.mqtt.client导入为mqtt client = mqtt.Client() client.connect("localhost",1883,60) client.publish("topic/1"，"400区350320,410")；client.publish("topic/2"，"200 x 350420x+ 110&
浏览 2提问于2017-09-13得票数 1
回答已采纳
我有一个python脚本，它在MQTT中调优到一个主题，它工作得很好。 import paho.mqtt.client as mqtt #import the client1
import time
import json
import requests
def on_log(client, userdata, level, buf) :
#print("log: "+buf)
k=0
def on_connect(client, userdata, flags, rc) :
if rc==0:
print("connected
浏览 87提问于2019-02-12得票数 3
回答已采纳
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
回答已采纳
1回答
我想实现paho-mqtt，在其中它应该异步处理传入的消息。 我已经用asyncio实现了gmqtt，它运行得非常好，但据我所知，使用paho-mqtt要比使用gmqtt (链接：https://www.emqx.io/blog/comparision-of-python-mqtt-client)更好。 带异步的gmqtt： def assign_callbacks_to_client(self, client):
""" Helper function which sets up client's callbacks. """
浏览 53提问于2021-01-11得票数 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
回答已采纳
在使用C++时，我试图了解Paho MQTT async_client库中各种回调机制的使用和行为，特别是：
mqtt::callbackmqtt::iaction listenermqtt::connection_handler
我想要达到的目标是:一种阻止初始化方法，它等待成功的连接并成功地订阅一个主题列表(首先是一个主题)，如果连接退出，再加上这些主题的自动重新连接和重新订阅。
“async_subscribe”示例()建议我订阅mqtt::callback::connected中的主题。但是，它没有说明如何等待订阅成功完成。我的理解是，我不应该在连接的回调中调用订阅令牌的“等待”。如果
浏览 1提问于2020-03-30得票数 0
回答已采纳
1回答
我已经使用paho.mqtt订阅了多个(大约4个)主题。
在收到来自每个主题的消息时，我想缓冲消息直到它达到某个阈值，然后将批量消息插入到MySQL数据库中。我想收集大约1000条消息并检查阈值是否大于1000，然后以一定的时间间隔(每隔1分钟)插入到数据库中。
对于每个主题，数据库中都有相应的表。我应该use on_message()回调还是message_callback_add()回调函数？在这种情况下，哪个更好？
浏览 0提问于2017-12-08得票数 0
回答已采纳
1回答
在下面的脚本中，我可以订阅一个主题，但是它不会发布我的数据字符串，也不会收到错误消息。有些功能不正常吗？
import paho.mqtt.client as mqtt
broker = "broker" #Broker address
port = 1883 #Broker port
user = "user" #Connection username
psw = "psw"
浏览 7提问于2022-09-29得票数 0
1回答
你好，这是我收到的关于“状态”的消息，我有一些客户端要发送关于“状态”的消息。
问题是‘如何打印客户端的名称以发送消息；“在下面的代码行中。
print("received message: " ,str(message.payload.decode("utf-8"))," from: ",str())
import paho.mqtt.client as mqtt
import time
def on_message(client, userdata, message):
print("received message: &#
浏览 3提问于2022-06-16得票数 -1
我一直在尝试将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
1回答
我可以发布和订阅一个主题，但是当取消订阅功能不起作用时呢？
var mqtt = require('mqtt');
var client = mqtt.connect('mqtt://localhost:1883');
var topic = 'home/machine1/lightSensor';
client .on('connect', ()=>{
client.unsubscribe(topic,console.log);
});
它返回null
浏览 10提问于2021-11-10得票数 0
我有一个mqtt类 class MQTT():
def __init__(self):
# Observer.__init__(self) # DON'T FORGET THIS
self.mqttClient = paho.Client(client_id=constants.MQTT_CLIENT_ID)
self.mqttClient.username_pw_set(username=constants.MQTT_BROKER_USERNAME, password=constants.MQTT_BROKER_PASSWO
浏览 24提问于2021-01-06得票数 1
回答已采纳
我试图围绕Paho MQTT JavaScript客户端编写一个简单的包装类。(其想法是对MQTT消息进行一些额外的验证，以确保按正确的顺序处理消息。)
我对JavaScript课程不太满意，我想弄清楚这是怎么回事.
class Hermes {
constructor(uri, topic, callback) {
var clientId = "clientID_" + parseInt(Math.random() * 1000);
this.client = new Paho.MQTT.Client(uri, clientId);
this.t
浏览 9提问于2020-09-11得票数 0
回答已采纳
3回答
假设我有几个设备，每个设备都有温度。与设备温度相关的所有消息都发布在主题device/1/temerature、device/2/temperature等上。我使用Python paho-mqtt和一个使用通配符表达式client.message_on_callback_add("device/+/temperature", ...)的回调函数来处理发布在这个主题上的所有消息。有没有办法直接获取通配符表达式的值，这里是+ (w.o.需要解析msg.topic)？
浏览 131提问于2020-01-24得票数 1
回答已采纳
当客户机订阅多个主题时，是否可以使用类似的概念(在javascript中)和paho python中使用的message_callback_add来使用多个回调？我已经看到了if条件在onMessageArrived()中的使用，但我想知道是否存在一种更高效、更干净的方法？
var mqtt; // MQTT variable/object
var reconnectTimeout = 5000; // 5 seconds for the reconnectTimeout
var host="localhost"
浏览 9提问于2021-06-07得票数 1
回答已采纳
我的脚本从MQTT服务器读取数据并将其写入postgres表。
我在用loop_forever()。这个程序应该不间断地运行。
当接收到第一个连接时，一切都正常，但是经过一段时间(从几分钟到几天)，on_connect()再次被调用。该程序可以工作(意思是在连接中没有错误)，但是再也没有接收到任何数据。
为了调试，我尝试了以下方法：
通过关闭网络connectionshutting和服务器调用client.disconnect()，会导致断开。
令我惊讶的是，第一件和第二件事什么也没做--没有关于新连接的日志，而且在连接恢复之后，运行的程序就一直在运行。
第三次尝试没有成功，我没能成功。
其他
浏览 5提问于2022-02-08得票数 0
之前，我在本地主机上遇到了问题，但现在我又遇到了另一个错误。我试图将我的MQTT数据存储在raspberry上的SQLITE数据库中。我做错了什么来得到下面的错误？
代码：
import paho.mqtt.client as mqtt
from store_Sensor_Data_to_DB import sensor_Data_Handler
# MQTT Settings
MQTT_Broker = "localhost"
MQTT_Port = 1883
Keep_Alive_Interval = 45
MQTT_Topic = "kuca/primanje
浏览 3提问于2017-10-30得票数 0
回答已采纳
我有一个mqtt的javascript，我写了一个paho python订阅，但我没有得到任何结果。我想打印收到的消息
var mqtt = require('mqtt');
var client = mqtt.connect('mqtt://127.0.0.1',{
username: process.env.TOKEN
});
client.on('connect', function () {
console.log('connected');
client.subscribe('v1/devices
浏览 0提问于2018-03-07得票数 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
回答已采纳
1回答
我在触发回调函数时遇到了问题。我正在使用Paho-MQTT，并使用python线程启动它。
class AquariumMonitor():
def __init__(self):
self.mClient = mqtt.Client(client_id="AQMonitor",clean_session=True, protocol=mqtt.MQTTv31)
self.mClient.connected_flag=False
self.mClient.on_message = self.incoming_mes
浏览 9提问于2019-07-29得票数 0
我正在使用paho js客户端连接蚊子。它连接正常。但是onConnect事件正在不间断地触发。我检查了broker中的日志，它看起来只连接了一次。为什么会发生这种情况？我只是使用了on官方网站上的代码：
<html>
<head>
<title>JavaScript MQTT WebSocket Example</title>
<script src="https://cdnjs.cloudflare.com/ajax/libs/paho- mqtt/1.0.1/mqttws31.js" t
浏览 6提问于2018-09-01得票数 0
下面是我的paho客户端连接
var client = new Paho.MQTT.Client(Constants.MQTT_HOST, Number(Constants.MQTT_PORT), Constants.MQTT_CLIENT_ID);
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;
client.onMessageDelivered = onMessageDelivered;
client.connect({onSuccess:onConnect});
浏览 0提问于2016-03-17得票数 0
1回答
我正在使用paho-mqtt库编写一个MQTT脚本，该脚本在有发布到某个主题的消息时触发回调函数，并且我正在尝试确定是否需要编写某种“消息队列”功能，以便将后续回调的执行推迟到前一个回调返回。
回调函数可能需要一段时间才能执行，并且可能存在在回调函数返回之前将另一条消息发布到触发器主题的情况。
看起来MQTT会将它自己推迟，连续的回调会被存储起来，直到前一个回调返回，但我只是希望得到一些关于这一点的确认。
谢谢
亚伦
浏览 12提问于2017-08-17得票数 0
目前，我需要编写一个python脚本，它应该分析通过MQTT提供的一些数据。为此，我必须使用的方法需要一个生成器/迭代器作为参数。遗憾的是，python中的paho-mqtt lib似乎只能通过on_message回调方法来访问消息，而仅仅在该回调中添加一个“that”应该是行不通的。有没有办法以生成器的形式访问发布的消息，或者有没有可能把它们放到一个生成器中(可能通过多线程)，或者有没有其他的包可以用来做这件事？我对python不是很熟悉，也找不到解决方案。希望有人能有个主意。为尼克拉斯干杯
浏览 12提问于2020-02-10得票数 0
我正在尝试编写一个脚本来保存mqtt数据并将其发送到influxDB。我遇到的问题是mqtt-paho模块的回调函数一直给出错误：AttributeError: 'Client' object has no attribute 'write_api'。我认为这是因为mqtt-paho的内部“Client”类中的self。我的完整脚本可以在下面找到： # Imported modules
# standard time module
from datetime import datetime
import time
# InfluxDB specific mo
浏览 131提问于2021-11-01得票数 1
回答已采纳
我写了这段MQTT发布代码： import paho.mqtt.client as mqtt
import time
HOST = "localhost"
PORT = 1883
KEEP_ALIVE_INT = 100
TOPIC = "noti"
def sendMsg():
MSG = ["1111", "2222", "3333", "4444", "5555"]
i = 0
try:
while i<5:
浏览 33提问于2021-08-31得票数 0
回答已采纳
我正在实现一个paho mqtt客户端。下面是我的代码：
import paho.mqtt.client as mqtt
def mess(client, userdata, message):
print("{'" + str(message.payload) + "', " + str(message.topic) + "}")
def subscribe(c_id, topic, server, port):
cl = mqtt.Client(c_id)
cl.connect(server, por
浏览 2提问于2016-06-18得票数 0
我正在尝试使用paho创建一个mqtt连接。发布后，rc返回成功状态，但消息尚未送达。 代码如下： import os
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("connected with rc: "+str(rc))
pass
def on_publish(client, data, result):
print("data published")
pass
client
浏览 74提问于2021-10-21得票数 0
我试图将MQTT与Ionic框架绑定。当试图向代理发送MQTT消息(我正在发布)时，当发生单击事件时，将得到以下错误：
"AMQJS0011E无效状态未连接.“"WebSocket连接到‘ws://test.zeto.org:8080/mqtt’失败: WebSocket握手时错误>：net::ERR_CONNECTION_RESET“
有人能帮我吗？我在任何地方都找不到解决办法。
我也尝试过1883端口，但问题依然存在。
var App = angular.module("App",["ionic","ngWebSocke
浏览 4提问于2016-02-24得票数 0
回答已采纳
2回答
我试图在MQTT服务器上读取消息。在某些情况下，连接是不稳定的，需要重新连接。但是在重新连接之后，我无法收到来自我以前订阅的主题的任何消息。我正在使用paho的python包来处理MQTT连接。下面是我正在使用的一些代码
TopicName='some/topic/name'
class Counter:
def __init__(self, mqttClient):
self.messages_recieved = 0
self.mqttClient = mqttClient
self.mqttClient.subsc
浏览 4提问于2020-12-02得票数 1
回答已采纳
每次我使用具有相同客户端id的JS paho客户端进行连接时，它都不会订阅我之前订阅的主题。
mqttClient = new Paho.MQTT.Client(constants.MQTT_HOST, Number(constants.MQTT_PORT), '/ws', "User-" + this.getCurrentUserDetails().id);
浏览 2提问于2016-10-03得票数 1
我正在为我的android项目实现Paho MQTT Java客户端。它基本上是一个即时消息系统。发布和订阅实现对我来说工作得很好，但我留下了一个问题。订阅的客户端能够在消息发布时接收消息，但是系统检查客户端(订阅者)是否接收/传递消息的能力有点难以实现，我认为这是因为MQTT不支持这一点。
有没有人知道如何以不同的方式实现这个逻辑？
浏览 4提问于2017-01-24得票数 2
我正试着绕着泛美卫生组织-MQTT图书馆转转。我很难理解在库的编码中什么是明显的约定，但这对我来说毫无意义。如果有人能给我一个我应该寻找的话题，我很乐意去查这个。
许多paho-mqtt教程和PAHO基础页面()都谈到了如何处理Client对象的on_message和on_connect方法(或者至少我认为是方法)。这些教程都提供了一种使用这些方法的标准方法，但我无法理解。其内容如下：
定义一个函数，该函数接受一定数量的参数。类似于：
def on_message(client, userdata, message):
print(message.payload, 'on&
浏览 11提问于2022-11-28得票数 0
我使用的是ruby中的paho-mqtt gem。
我想知道，如果客户端由于某种原因没有收到PUBACK，gem是否会自动将消息重新发送(重新发布)到MQTT代理，还是必须手动执行？QOS=1
例如(这是我使用QOS=1发布内容，不做其他任何事情)：
client = PahoMqtt::Client.new
client.on_puback do
puts "PUBACK received"
end
client.connect(@mqtt_server_ip, @mqtt_server_port)
client.publish(topic, message_payl
浏览 5提问于2018-05-31得票数 0
2回答
在等待消息时发送消息
、、、
我使用mqtt协议向蚊虫中介.What发送传感器数据消息，我想做的是每t秒发送一次传感器数据，但是如果我接收到一条消息并行处理，我正在使用time.sleep()，但我认为这将延迟使用paho-mqtt和python2.7的"on_message“函数.Im。对我怎么能完成这件事有什么想法吗？
客户端No1。(发送传感器数据)
from mysignals import mysignals
import paho.mqtt.client as mqtt
import time
def on_connect(client, userdata, rc):
mqttc.subs
浏览 1提问于2017-03-29得票数 0
回答已采纳
我正在使用eclipse paho java客户端连接到mqtt代理。我写了一个实现MqttCallbackExtended的订阅者客户端。
我得到了connectionLost()回调。但是我怎么知道哪个代理失去了连接呢？
我已经通过MqttConnectOptions的setServerURIs()接口指定了多个uri。
浏览 0提问于2018-08-31得票数 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
当对相同的clientId多次使用paho-mqtt5:test时，它会抛出异常Client not connected，但如果我将为每个to和from使用不同的clientId，那么它将正常工作
2021-10-05 19:25:28,650 ERROR [org.apa.cam.pro.err.DefaultErrorHandler] (Camel (camel-1) thread #0 - timer://test) Failed delivery for (MessageId: 871E4623819E4FB-000000000000001B on ExchangeId: 871E46
浏览 26提问于2021-10-05得票数 0
1回答
是否可以将消息发布到特定的客户端id？
我想用mqtt发布两件事：
1-一般信息，如用户得分，统计数据等。并且每个人都可以查看。
2-为私人用户保留的敏感信息，如自己的分数，姓名等。
有什么干净的方法可以使用Paho MQTT做到这一点吗？
顺便说一下，使用：
浏览 14提问于2019-10-29得票数 0
2回答
MQTT从主线程发送消息
、、、、
我在MqttHelper类中实现了简单的MQTT订阅服务器，它工作正常并接收订阅。但是当我需要从主程序发送消息到服务器时，我应该如何处理。我有publish方法，它可以很好地从IMqttActionListener中运行，但是如何在按下按钮的事件上从主程序发送文本呢？
package com.kkk.mqtt.helpers;
import android.content.Context;
import android.util.Log;
import org.eclipse.paho.android.service.MqttAndroidClient;
import org.eclips
浏览 4提问于2019-11-20得票数 0
1回答
我从Arduino发布MQTT消息，并从Raspberry Pi订阅这些消息。有时发布的速度比Raspberry可以接收(和处理)的速度更快。 我正在寻找一种方法来检查有多少消息在Raspberry端排队。我使用的是Paho-MQTT。我只看到可以设置最大队列大小，但我如何检查当前队列大小？(如果可能。)
浏览 44提问于2019-06-17得票数 0
回答已采纳
我是MQTT的新手。我在两台电脑里安装了蚊子和泛美卫生组织mqtt图书馆。计算机通过本地网络中的路由器连接。我在一台电脑上运行出版商和蚊子，在另一台电脑中运行订户。
# publisher.py code
# ===================================================================
#!/usr/local/bin/python3
import paho.mqtt.publish as publish
publish.single("paho/single", payload="boo", hos
浏览 2提问于2015-12-10得票数 0
回答已采纳
我正在使用面向Objective C语言的Paho Library for MQTT Connectivity。我能够成功地连接、发布和订阅。但问题是，当一个成功的发布/订阅发生时，我不知道从哪里得到回调。我找不到任何与此相关的文档。
请帮助任何人对此有任何想法。
浏览 1提问于2016-02-04得票数 0
我们正在进行一个项目，其中有些传感器将数据发送给mqtt代理，我们编写了一个python脚本，该脚本将这些数据存储在csv文件中。
现在，当我们添加更多的传感器时，我们的主题会发生如下变化：
主题/感觉1
专题/感觉2
诸若此类。现在我们想让这个脚本中的子主题自动化，而不是在传感器被添加或移除时对其进行硬编码。
你有什么建议吗，我们如何在一个循环中订阅所有的子主题？
到目前为止，我们有以下情况：
import paho.mqtt.client as mqtt
import logging
from datetime import datetime
def on_subscribe(mosq,
浏览 1提问于2021-04-30得票数 1
回答已采纳
在浏览器端，我使用的是paho客户端，服务器是Activemq。我发现paho JS客户端的功能非常有限，但java客户端有很多功能。
我想要的一些功能是消息传递确认，消息时间等，我如何在浏览器端客户端获得所有这些类型的功能，或者对于这些功能，MQTT聊天应用程序的通用架构应该是什么。我是否应该进行单独的Java api调用来获得这些功能？
浏览 3提问于2016-03-13得票数 0
2回答
我目前正尝试在面向对象的上下文中使用Python3中的paho mqtt库。但是，由于某种原因，回调函数不会被调用。
import paho.mqtt.client as mqtt
import time
import logging
logger = logging.getLogger("IDS_LOGGER.refining")
logging.basicConfig(level=logging.INFO)
class refiner(object):
def __init__(self,configpath="./sampleconfig.xml"
浏览 0提问于2019-03-26得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
