如何从cumulocity连接和订阅MQTT broker
从Cumulocity连接和订阅MQTT broker的步骤如下：
- 首先，确保你已经有一个Cumulocity账户，并且已经创建了一个应用程序。
- 登录到Cumulocity控制台，并导航到你的应用程序。
- 在应用程序页面上，点击左侧导航栏中的"设备管理"选项。
- 在设备管理页面上，点击"设备模拟器"选项。
- 在设备模拟器页面上，点击"添加设备"按钮。
- 在添加设备页面上，填写设备的相关信息，包括设备名称、设备类型等。
- 在设备模拟器页面上，找到你刚刚创建的设备，并点击设备名称进入设备详情页面。
- 在设备详情页面上，点击"连接"选项卡。
- 在连接选项卡中，找到"MQTT"部分，并点击"添加连接"按钮。
- 在添加连接页面上，填写MQTT broker的相关信息，包括broker地址、端口号、用户名、密码等。
- 点击"保存"按钮，完成MQTT broker的连接配置。
- 在设备详情页面上，点击"订阅"选项卡。
- 在订阅选项卡中，点击"添加订阅"按钮。
- 在添加订阅页面上，填写订阅的主题和QoS等相关信息。
- 点击"保存"按钮，完成订阅配置。
通过以上步骤，你已经成功地从Cumulocity连接和订阅了MQTT broker。你可以通过Cumulocity提供的API和工具来发送和接收MQTT消息，实现设备与云平台之间的通信和数据交换。在实际应用中，这种连接和订阅MQTT broker的方式可以用于物联网设备的数据采集、监控和控制等场景。
腾讯云提供了一系列与物联网相关的产品和服务，例如腾讯云物联网套件、腾讯云物联网通信、腾讯云物联网边缘计算等。你可以访问腾讯云官方网站了解更多关于这些产品的详细信息和使用指南。
腾讯云物联网套件：https://cloud.tencent.com/product/iot-suite 腾讯云物联网通信：https://cloud.tencent.com/product/iot-communication 腾讯云物联网边缘计算：https://cloud.tencent.com/product/iot-edge
相关·内容
我已经有了一个cumulocity客户机，它通过MQTT与cumulocity代理进行通信。
为了将cumulocity中中断的MQTT数据发送回mqtt客户端，我应该做些什么？(假设客户端发送了一些数据，我希望确认数据已成功发送)
由于某些原因，无法在cumulocity文档中找到任何有关此信息的信息，这是客户端的唯一信息。
浏览 0提问于2018-02-26得票数 0
回答已采纳
我的客户端无法从MQTT服务器接收消息有效负载。我已经在我的电脑上设置了蚊虫作为服务器和发行者，并执行以下命令：
mosquitto_pub -h 192.168.1.2 -t topic/test -m "testing" -i simulator -d
订阅我自己的作品，并收到有效载荷。
但是，使用paho mqtt的客户端只接收到成功的连接，而没有有效负载消息。因此，这里有以下代码：
def on_connect(client, userdata, flags, rc):
print("connection ok")
client.subs
浏览 8提问于2022-03-28得票数 0
回答已采纳
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
回答已采纳
我有一个外部代理，我们Apache Active MQ-MQTT。 我在云上有一个cumulocity IoT平台。 我不明白如何连接和订阅我的cumulocity应用程序到代理MQTT。
浏览 8提问于2019-02-18得票数 0
我使用的是Arduino Wemos Esp32 D1 R32。我正在尝试在我的Arduino板和MQTT代理之间建立MQTT连接。当我尝试从我的Arduino发送消息时，它工作得很好。(我正在使用上拉按钮发送消息。)每当我按下按钮时，就会发送一条消息。但是，当我试图用回调函数读取一条消息并将其写在Serial上时，它就是不起作用。有人能帮我解决这个问题吗？ 下面是我的代码： [code]
#include <ETH.h>
#include <WiFi.h>
#include <WiFiAP.h>
#include <WiFiClient.h>
浏览 23提问于2019-12-14得票数 0
回答已采纳
1回答
将MQTT协议路由到PM2
、、、、
我们有一些连接到MQTT Broker (mosquitto)的设备，发布一些事件。我们希望通过node应用程序捕获所有这些事件。一个简单的解决方案是创建一个node应用程序作为客户端，它连接到MQTT Broker，侦听每个事件并为它们做特定的工作。但是从可伸缩性的角度来看，如果我们想要扩展我们的node应用，我们必须运行我们的node应用的多个实例，并使用PM2作为负载均衡器。但问题是，当我们创建多个实例时，所有实例都会收到相同的事件，并且对于该特定事件，所有实例都会多次执行与我们拥有的实例数量相同的工作。
如何将所有MQTT事件路由到PM2负载均衡器？
浏览 12提问于2019-07-14得票数 1
回答已采纳
当收到带有有效负载"0“的MQTT消息时，我使用mqtt-launcher ()执行命令。
下面是配置
logfile = '/home/user/mqtt-launcher/logfile'
mqtt_broker = 'broker' # default: 'localhost'. If using TLS, this must be set to the domain name signed by$
mqtt_port = 1883 # default: 18
浏览 0提问于2018-12-16得票数 0
回答已采纳
我用的是蚊子到MQTT协议。我想知道何时在MQTT代理中创建队列，同时发布或订阅，还是同时订阅和发布？
$SYS/broker/clients/connected显示连接客户端的数量，同时我们可以在MQTT中找到多个队列。
提前谢谢..。
浏览 2提问于2017-08-17得票数 1
我正在使用SCADA软件向主机IP为85.119.83.194的MQTT broker写入数据，并且我还在尝试读取名为EZware的软件中的数据。我可以从Indusoft Plus软件写入MQTT broker，并在EZware软件中查看它。我还可以看到MQTT代理软件TT3中的数据。但是，当我尝试更改Indusoft软件中的值时，我可以在Ezware MQTT broker软件中看到它，但它不会显示在Ezware Plus软件中，即使我订阅了它。有没有可能发布和订阅同一主题？
任何帮助都将不胜感激。
浏览 93提问于2020-03-11得票数 0
我有一个发布者，它在"/ex/topicA/“下发送消息，另一个发布者在"/ex/topicB/”下发送消息给蚊子代理。
订阅者在"/ex/#“下不断地从broker订阅。
现在，由于网络连接不良，一个主题为"/ex/topicA“的出版商没有将数据发送给蚊子经纪人。
现在，paho mqtt订阅者如何知道哪个发布者没有将数据发送给mqtt？
浏览 17提问于2019-08-07得票数 0
回答已采纳
我借用了Toms硬件中关于如何使用MQTT和订阅的代码。JRMI是消息的发布者，它不断地重复它们。有消息只发送一次吗？当我通过订阅MQTT时，我没有这个问题，我使用的是broker.hivemq.com服务
对于那些不熟悉JRMI的人来说，它是模拟铁路用于控制轨道、照明、DCC等的JAVA程序。
到汤姆‘s的链接在这里，
改编自汤姆的代码是
import network
import time
from machine import Pin
from umqtt.simple import MQTTClient
wlan = network.WLAN(network.STA_IF)
wlan
浏览 16提问于2022-10-29得票数 0
回答已采纳
我们设置了一个由驱动的MQTT客户机(无论是在桌面PC上还是在实际的板上，都是相同的)和一个由驱动的MQTT代理，这个代理运行在桌面PC上。
我们能够成功地从客户端发送带有特定主题的消息到代理，但现在我们遇到了相反的情况:将消息从代理发送到客户端。
我们遵循在两个项目文档中提供的代码示例，但没有任何结果。客户端能够正确地注册到主题，但在发送消息时不会以任何方式作出反应。代理能够正确地发送消息，也能够侦听自己的消息，因为它无论如何都在监听所有消息。
摘自MQTT代理：
broker.on('published', function(packet, client) {
cons
浏览 4提问于2015-05-04得票数 3
我设法发表了几个主题，并阅读了其中一个。我需要做的是倾听和阅读所有已发表的主题，并获取信息。这是我使用的代码：
将消息发布到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
回答已采纳
我的问题是在MQTT-SN网关上使用MQTT主题名称和MQTT-SN主题ids来配置RSMB。
使用“开始使用非常小的Message”信息对于了解如何在将两个非常小的Message连接在一起的情况下配置主题名称映射非常有用。
关于"6.10网关的发布过程“部分中的，网关(在我的例子中是使用broker_mqtts实现包括在RSMB中的网关)可以发送一条注册消息，通知客户端主题名称及其指定的主题ID值。现在，我想将MQTT主题名称的映射配置为预定义的MQTT-SN主题ID。
能否在RSMB broker.cfg配置中配置映射，以便在成功连接到RSMB后告知MQTT客户端预定义的主题ID？
浏览 4提问于2014-11-04得票数 3
回答已采纳
1回答
我在python2.7中使用来收听代理在订阅特定主题后播放的消息。
它被初始化为
import paho.mqtt.client as mqtt #python mqtt package
# initialize MQTT client
mqttc = mqtt.Client()
# register listener functions
mqttc.on_connect = on_connect
mqttc.on_subscribe = on_subscribe
mqttc.on_message = on_message
# connect to MQTT bro
浏览 3提问于2017-06-29得票数 1
回答已采纳
我使用Artemis 2.6.3作为嵌入在Spring 5应用程序中的MQTT代理：
@Bean(initMethod = "start", destroyMethod = "stop")
fun embeddedActiveMQ(securityManager: ActiveMQJAASSecurityManager) =
EmbeddedActiveMQ().apply {
setConfiguration(getEmbeddedActiveMQConfiguration())
setConfi
浏览 0提问于2020-06-22得票数 0
回答已采纳
场景：--我有一个python虚拟传感器(一个python程序)，它通过协议向我的ThingsBoard设备提交数据。我可以在仪表板上可视化数据，所以我确信数据是接收到的。
问题:当我尝试使用泛美卫生组织将python订阅服务器连接到thingsboard broker (demo.thingsboard.io)时，获得连接代码为0，所以连接是OK的，但是--不过，--我看到仪表板停止可视化来自虚拟传感器的数据，但是订阅服务器没有收到任何信息。
虚拟传感器发布在v1/设备/me/遥测，用户订阅的主题是v1/设备/me/遥测。
如何在订阅服务器客户端上显示虚拟传感器发布的数据？
虚拟传感器代码：
浏览 1提问于2020-03-22得票数 0
我使用的是NodeJS的mqtt模块。一切工作正常，比如发布，订阅一个特定的主题，处理连接错误等等。问题是当我试图订阅所有主题时，这通常是作为client.subscribe('#',callback)完成的，它没有订阅任何主题。 相关代码如下： // Connecting to a specific topic
client = mqtt.connect(broker,options)
console.log("MQTT Connected")
client.on('connect',()=>{
client.subscribe
浏览 67提问于2021-11-16得票数 0
回答已采纳
当kura在Kapua上发布到localhost:1883时，我得到了以下错误：
WARN o.e.k.b.c.p.KapuaSecurityBrokerFilter - User 1:kapua-broker (kapua-broker - tcp://10.0.2.2:56178 - conn id无权写入:topic://VirtualTopic.haha.kapua 1840321435420579455)-broker.DHT11Sensor.DHT11Data 13:26:43.493 ActiveMQ NIO Worker 5 WARN o.a.a.b.TransportCon
浏览 47提问于2017-07-21得票数 0
我试图通过一个反向代理通过Websockets建立一个MQTT连接。是否可以将角CLI代理配置为将请求转发到ws://localhost:4200/mqtt到wss://mqtt.example.com/mqtt
我一直在尝试多个，但似乎无法让它发挥作用。这是我在我的proxy.conf.json中拥有的
"/mqtt/*": {
"target": "wss://mqtt.example.com/",
"secure": false,
"ws": true,
"changeOrigin&#
浏览 16提问于2020-02-14得票数 2
回答已采纳
4回答
如何将MQTT broker与mongoDB集成？
我发布的全球定位系统坐标从客户端到经纪人，并希望存储在MQTT代理与mongoDB，
如果一些指针被共享，我将不胜感激
浏览 6提问于2014-06-06得票数 4
如何破解/拆分从mqtt broker(mosca)接收的消息？整个消息都带有数据包、主题、messageid、有效负载等。我只需要在调试节点上显示有效载荷{"T":"t"}。我尝试了拆分和切换节点，它似乎不工作，没有响应的输出。
mqtt装置
mqtt经纪人
浏览 2提问于2018-11-30得票数 0
回答已采纳
1回答
有没有人能详细解释一下MQTT协议的工作原理？broker和发布者/订阅者之间是否存在持久连接？或者，代理是否在需要时建立连接？
浏览 10提问于2017-02-10得票数 2
回答已采纳
我编写了一个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
我从一个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回答
我正在用Eclipse实现MQTT客户端，有一些问题：
发布服务器和订阅服务器都使用qos =1和setCleanSession = false连接到代理。
我的流量：
将订阅者和发布服务器连接到代理，没关系。
断开订阅服务器(强制停止我的项目，其中包括订阅服务器)，发布服务器继续发布消息。
重新连接订阅服务器->它不能连接并抛出异常: connectionLost。
如果设置订阅服务器= 0的qos，则不会引发异常，但在订阅服务器脱机时，客户端不会接收发布服务器发送的消息，而我不希望这样做。
有人能帮我吗？
这是我的代码
try {
//
浏览 1提问于2018-05-08得票数 0
2回答
我是Azure MQTT服务器的新手。我已经在Azure中创建了帐户，并且设备已注册。我收到了Hostname，DeviceID和shared access key。
我使用的是在C上工作的embedded设备。之前我连接的是另一个MQTT Broker。
如何从Azure获取MQTT broker的password？
什么是{signature-string}、{expiry}和{URL-encoded-resourceURI}？如果要在C中编码如何编码，我从哪里获得所有这些信息？
浏览 8提问于2020-08-05得票数 1
2回答
我有一个用Node编写的MQTT发行者和订阅者。
我想知道是否有可能以API的形式将其连接到并发布到使用PostMan的消息。
以下是出版商的代码：
Publisher.js：
const mqtt = require('mqtt');
let client = mqtt.connect('mqtt://broker.hivemq.com');
client.on('connect', () =>{
console.log(`MQTT Client Connected Successfully!`);
client.pu
浏览 0提问于2021-08-26得票数 2
回答已采纳
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
回答已采纳
我有一个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
回答已采纳
抱歉，如果这是菜鸟的话。我正在尝试学习AWS IOT的诀窍。
我知道我可以使用像MQTT.fx这样的客户端将消息发布到message broker中的主题。
我还可以看到AWS IOT资源控制台，我可以创建内容、附加证书、策略和创建规则。
如果我使用IOT资源控制台创建了一个叫做' car‘的东西，控制台是否提供了一些方法，可以让car将MQTT消息发布到一个主题？或者是使用SDK将模拟汽车连接到实际设备的唯一方法。
正如我所提到的，我知道通过MQTT客户端进行发布。我只想知道如何创建我在资源控制台中创建的“东西”，将MQTT消息发布到消息代理？
谢谢
浏览 5提问于2015-12-31得票数 2
我的脚本从MQTT服务器读取数据并将其写入postgres表。
我在用loop_forever()。这个程序应该不间断地运行。
当接收到第一个连接时，一切都正常，但是经过一段时间(从几分钟到几天)，on_connect()再次被调用。该程序可以工作(意思是在连接中没有错误)，但是再也没有接收到任何数据。
为了调试，我尝试了以下方法：
通过关闭网络connectionshutting和服务器调用client.disconnect()，会导致断开。
令我惊讶的是，第一件和第二件事什么也没做--没有关于新连接的日志，而且在连接恢复之后，运行的程序就一直在运行。
第三次尝试没有成功，我没能成功。
其他
浏览 5提问于2022-02-08得票数 0
无论我做什么，我都无法在我的角度应用程序中(在chrome和firefox中尝试)通过websocket连接到mqtt代理。为了简单起见，我使用了，我已经发布了一些关于/gat/38/openReservationRequests主题的数据
我遵循了这个关于如何用ngx在角度上连接到mqtt的，但是对我来说，它不起作用。
在我的应用中：
我已经安装了模块
npm install ngx-mqtt --save
我在我的app.module.ts中添加了配置并设置了模块app.module.ts
...
export const MQTT_SERVICE_OPTIONS: IMqttServic
浏览 1提问于2019-12-10得票数 4
回答已采纳
1回答
我正在研制一个IoT设备。我在raspberry pi 3中安装了Eclipse作为网关。我想使用Kura或直接使用raspberry pi向Kapua服务器(安装在同一网络中)发布一条消息。两种方法我都试过了。
1-使用库拉
我遵循了关于GitHub Kapua连接 #780的说明。在遵循这些步骤之后，我能够建立Kapua连接，但是无法发送数据，Example.publisher包也安装在库拉。我想创建一个主题并发布有关该主题的数据。
2-使用MQTT-客户端库
我已经在raspberry pi中安装了MQTT-客户机库，并使用以下命令发布和订阅数据。
出版：
sudo mosquitto_
浏览 3提问于2018-02-28得票数 4
当一个消息(MQTT (3.1) QoS1)没有客户端使用该底层主题时，它会物理地从KahaDB ActiveMQ (5.15)数据库中删除吗？
例01：
发送给主题"topic-foo".Broker的MQTT (3.1)内容为"foo“的消息是ActiveMQ 5.15，并且收到的消息是主题的使用者没有离开代理。当消息从KahaDB物理上删除？时，
例02：
发送给主题"topic-foo".Broker的内容为"foo“的MQTT (3.1)消息是ActiveMQ 5.15，并且接收到的是消费者通过ClientAcknowledge模式接收
浏览 4提问于2022-09-28得票数 0
1回答
M2mqtt包含在我的asp.net mvc项目中。同步订阅信息面临的问题。
当多个客户端发布在一个特定主题上时，客户端可以很容易地订阅它们。
假设在一种情况下，当发布发生时，当客户端活着时处于关闭/脱机状态，那么只得到最后发布的消息，而不是所有已发布的消息。怎么办?这是MQTT上的一个问题吗?客户端如何获得所有已发布的消息。
通过下面的语法使用与代理的M2mqtt连接
public static MqttClient SmartHomeMQTT { get; set; }
SmartHomeMQTT = new MqttClient(brokerAddress, MqttSetti
浏览 0提问于2016-02-23得票数 0
1回答
我遇到了一个非常奇怪的情况。我每隔2分钟将JSON数据从k8s cron作业推送到MQTT代理。
用于发布到mqtt的代码。
import paho.mqtt.client as mqtt
from bs4 import BeautifulSoup
import json
import os
MQTT_HOST = os.environ["MQTT_HOST"]
MQTT_PORT = int(os.environ["MQTT_PORT"])
MQTT_KEEPALIVE_INTERVAL = int(os.environ["MQTT_KEEPALIV
浏览 4提问于2022-09-23得票数 0
由于不断断开/重新连接，我的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
1回答
使用CloudIotCore文档，我能够在项目中运行Quickstart示例和EndtoEnd示例。
使用MQTT.fx工具，我无法连接到同一谷歌云项目
Username : unused
Password : Generated from cretae_jwt function using code in cloudiot_pubsub_example_mqtt_device.py
Broker Address: mqtt.googleapis.com
Broker Port: 8883
Client ID: projects/myprojectid/l
浏览 2提问于2017-12-21得票数 1
3回答
我仍在学习如何使用MQTT发布和订阅。
如果用户添加新主题，是否可以动态订阅该主题？
例如，现在的代码如下所示：
import anotherModule
topic = anotherModule.topic #the output is similar to this -> [('Test1', 0), ('Test2', 0)]
...
def connect_mqtt() -> mqtt_client:
def on_connect(client, userdata, flags, rc):
if rc == 0:
浏览 7提问于2022-02-04得票数 1
回答已采纳
1回答
我想测试MQTT Python客户端端口。
import json
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
"""Called when connected to MQTT broker."""
client.subscribe("hermes/intent/#")
client.subscribe("hermes/nlu/intentNotRecognized")
浏览 4提问于2020-11-19得票数 0
回答已采纳
MQTT和flask应用程序没有收到消息，我不确定是它没有被订阅，还是我的设备没有收到消息。发布消息起作用了我已经测试过了，但是接收消息没有。是不是我做错了什么？
from flask import Flask, render_template
import paho.mqtt.client as mqtt
import time
def on_message(client, userdata, message):
print((message.payload.decode("utf-8")))
broker = "broker.hivemq.com"
浏览 1提问于2020-05-14得票数 0
2回答
我需要认识到和经纪人的联系。现在我正在连接到互联网上的公共经纪人(http://www.mqtt-dashboard.com/)。我这样做的方式如下：
private static final String broker = "tcp://broker.mqttdashboard.com:1883"; //bridge and host
mqttClient = new MqttClient(broker, MqttClient.generateClientId(), new MemoryPersistence()); //URI, ClientId, Persisten
浏览 1提问于2018-11-19得票数 2
回答已采纳
我编写了基本的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
回答已采纳
1回答
我正试图连接一个托管在AWS上、端口8883上的蚊虫代理，但到目前为止我还没有成功。我正在使用TinyGSM和PubSubClient库。
GSM模块连接到互联网上，在没有SSL的代理中工作得很好。但是当我尝试切换到SSL时，他无法连接，MQTT客户端返回-2。但是这个错误不是很清楚，因为您可以在文档中看到PubSub。
#定义MQTT_CONNECT_FAILED -2
以下是它尝试连接到代理时执行的AT命令
AT+CIPRXGET=4,0
+CIPRXGET: 4,0,0
OK
AT+CIPSTATUS=0
+CIPSTATUS: 0,0,"TCP","
浏览 3提问于2020-08-07得票数 4
1回答
我正在尝试使用 pkg构建mqtt子客户端，当代理断开连接时，我的客户端有问题，我认为应该丢失消息，但这种情况不会发生，如果启动代理，mqtt子客户端无法获得由mqtt客户端发送的消息。
为什么会发生这种事，我怎么才能解决呢？
代码
package main
import (
"fmt"
"os"
mqtt "github.com/eclipse/paho.mqtt.golang"
)
var (
broker = "tcp://localhost:1883&#
浏览 0提问于2017-05-03得票数 4
回答已采纳
我可以在Cumulocity IoT上注册一个设备，并通过MQTT将测量数据从该设备发送到库姆库米蒂。现在我想用MQTT从Cumulocity发送测量到注册的设备。我怎样才能做到这一点？
我试着查阅了所有关于累积量的文档，但是在这些文档中并没有清楚地提到如何实现这个流程。我尝试了设备中的“控制”选项卡，该选项卡允许我们发送一些单一和批量操作，但没有找到解决方案。
浏览 5提问于2022-03-31得票数 0
2回答
我正在尝试使用我用Python构建的应用程序从我的主题中收集发布的数据。因此，当数据发布时，应用程序将对其进行处理。
问题是：订阅似乎总是成功的，但没有获取事件。
我能够使用MQTT客户端连接到代理。
下面是我当前处理连接和订阅的代码：
broker_address= "mqtt.googleapis.com"
port = 8883
client = mqtt.Client(client_id='projects/<project_id>/locations/<location>/registries/<registry_id>/d
浏览 2提问于2018-03-29得票数 1
回答已采纳
3回答
最近，我开始使用paho mqtt for java和mqtt，我一直使用mqtt broker和paho客户端it self提供的持久性机制。也许我误解了(可能是这样) mqtt上下文中持久性的概念。
我们必须支持的用例如下：我们的mqtt客户端已经断开了7天(我非常怀疑这将发生，但很好)，甚至应用程序在这7天没有恢复连接的情况下关闭，并且一旦启动并运行，在断开连接时发送所有7天的所有消息。
Paho客户端支持缓冲消息在其或代理故障时的持久性，一旦网络恢复或代理运行，就会发送缓冲消息，但如果应用程序在客户端断开连接或代理不可用时关闭，则无法发送缓冲消息。
基本上，我的问题是-断开连接的缓冲消
浏览 0提问于2017-03-09得票数 2
我正在做一个项目，我需要使用来创建一个安卓应用程序。我在Go中的示例代码如下所示
var broker = "127.0.0.1"
//var broker = "broker.mqttdashboard.com"
var port = 1883
opts := mqtt.NewClientOptions()
opts.AddBroker(fmt.Sprintf("tcp://%s:%d", broker, port))
opts.SetClientID("go_mqtt_client
浏览 7提问于2021-07-07得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
