显示节点服务器API上的MQTT响应
MQTT是一种轻量级的消息传输协议，常用于物联网设备之间的通信。它基于发布/订阅模式，通过中间件（即MQTT服务器）实现消息的传递。
显示节点服务器API上的MQTT响应是指通过节点服务器API获取到的MQTT协议的响应信息。具体来说，当设备通过MQTT协议向节点服务器发送请求时，节点服务器会返回相应的响应信息，包括成功或失败的状态码、错误信息等。
MQTT的优势在于其轻量级和低功耗的特性，适用于资源受限的物联网设备。它具有以下特点：
- 简单易用：MQTT协议设计简洁，易于实现和集成。
- 低带宽消耗：MQTT协议采用二进制消息格式，传输效率高，节省带宽。
- 异步通信：MQTT支持发布/订阅模式，设备可以异步地发送和接收消息。
- 可靠性：MQTT协议支持消息的持久化和QoS（服务质量）等级设置，确保消息的可靠传输。
MQTT在物联网领域有广泛的应用场景，例如智能家居、工业自动化、智能交通等。在这些场景中，设备可以通过MQTT协议与云平台或其他设备进行通信，实现数据的采集、控制和监测等功能。
腾讯云提供了MQTT相关的产品和服务，例如物联网通信（IoT Hub），它是腾讯云提供的一站式物联网解决方案，支持MQTT协议，提供设备管理、数据采集、消息路由等功能。您可以通过以下链接了解更多信息： https://cloud.tencent.com/product/iothub
总结：MQTT是一种轻量级的消息传输协议，适用于物联网设备之间的通信。它具有简单易用、低带宽消耗、异步通信和可靠性等优势。在物联网领域有广泛的应用场景。腾讯云提供了物联网通信（IoT Hub）等相关产品和服务来支持MQTT协议。
相关·内容
如何破解/拆分从mqtt broker(mosca)接收的消息？整个消息都带有数据包、主题、messageid、有效负载等。我只需要在调试节点上显示有效载荷{"T":"t"}。我尝试了拆分和切换节点，它似乎不工作，没有响应的输出。
mqtt装置
mqtt经纪人
浏览 2提问于2018-11-30得票数 0
回答已采纳
2回答
我正在尝试使用express将从MQTT接收到的响应输出到节点服务设置。
每秒都会收到一条来自mqtt服务的json字符串消息。响应将在Ionic应用程序接口上输出，我将从我正在开发的/main 4移动应用程序中调用它。
然而，现在我不能仅仅为了检查而在服务器上显示数据，我还没有考虑如何不断地更新服务器上的数据。页面不会刷新，它只是继续加载。
const mqtt = require('mqtt')
const express = require('express')
const PORT = 8000
const app = express()
var c
浏览 27提问于2019-11-14得票数 0
回答已采纳
1回答
我有一个带有两个节点的本地节点-red实例: http in和http out。但是这个简单的节点需要6秒才能响应，并且没有进程。mes的其他流程(5 /6其他流程)也是如此。
有人有主意吗？为什么它真的很慢？
编辑:对coms的响应：
这里不是代码问题。在水流下面：
网络分析(服务器在云中具有很高的下载/上传速度)：
我也有10个其他流在节点-红色服务器上，与mqtt节点，http，udp等.但一切都是缓慢的。在执行期间，当两个流与HTTP通信时，几乎有5秒的时间。
硬件部分正常: CPU i5，8 Go内存等。
浏览 3提问于2016-03-12得票数 2
回答已采纳
1回答
我在我的windows机器上安装了节点red，当我部署它并开始配置mqtt节点时，当我不断地部署它时，我会写
下一步是mqtt配置：
服务器: 127.0.0.1
端口1883主题
传感器/#
qos 0
浏览 2提问于2017-12-25得票数 0
我有一个节点服务器，它连接到CloudMQTT并在app.js中接收消息。我让我的客户端web应用程序运行在同一节点服务器上，并希望在app.js中将收到的消息显示在.ejs文件中，我很难找到最佳的方法。
app.js
// Create a MQTT Client
var mqtt = require('mqtt');
// Create a client connection to CloudMQTT for live data
var client = mqtt.connect('xxxxxxxxxxx', {
username: 'xxxx
浏览 0提问于2015-09-23得票数 1
回答已采纳
我正在寻找一个解决方案，以轮询消息从MQTT代理。我将在这里简要描述解决方案。
我们有一个基于Spring的Controller类，它公开REST API来处理某些与车辆相关的诊断数据。通过这些API之一，我创建了一个Notify3P()客户端，并根据一些输入数据向MQTT代理发布关于给定主题的消息。我的要求是每次客户端在MQTT上发布消息时都要通知第三方系统。
一旦接收到通知，3P系统将从MQTT获取消息。然后，它需要通过一个getMessage() REST API从MQTT代理获取消息(我们需要在上面的控制器类上公开它)。MQTT需要轮询getMessage()中已经发布的消息，并将其传
浏览 3提问于2013-11-01得票数 0
我正在使用一个MQTT发布者，RabbitMQ和一个Mqtt订阅者。我已经在RabbitMQ上安装了用时间戳(rabbitmq_message_timestamp)标记消息的插件。我已经使用node.js构建了一个AMQP发布者、一个AMQP订阅者和一个MQTT订阅者，并使用Node-Red (和MQTT out块)构建了一个MQTT发布者，将主题设置为测试RabbitMQ用户、retain=true和no QoS的服务器url、用户名和密码。
第一个问题)当我使用AMQP发布者和AMQP订阅者时，我可以通过读取path: msg.properties.timestamp字段来检索Rabbit
浏览 4提问于2017-02-20得票数 0
还有人看过这个吗？Xively服务器(tcp://api.xively.com:1883)接受我的连接，但从不响应MQTT CONNECT消息。在Wireshark捕获中，我看到CONNECT消息传出(协议字段中包含MQIdsp )，但什么也没有返回。
我使用的是Paho MQTT客户端()，不幸的是，此服务器行为似乎暴露了客户端中的一个错误:阻塞模式下的connect()方法永远不会返回。在非阻塞模式下，它会超时，但会使客户端处于无效状态，例如close()方法会抛出一个异常，说明连接正在进行。这似乎就是这里报告的错误：
我可以切换到不同的MQTT客户机，但最根本的问题是Xively服务器停
浏览 0提问于2014-03-14得票数 0
当我们添加mqtt-in或mqtt-out节点时，我们获得一个带有选择列表和按钮的服务器字段，该按钮可以向列表中添加新的服务器。
。
请帮我改变按钮的功能，用铅笔代替默认。
浏览 2提问于2017-08-13得票数 0
回答已采纳
我一直在我的应用程序上面临负载问题，在运行了一些负载测试之后，我意识到当我通过http在端口8080上直接加载应用服务器时，应用服务器的响应非常快。
当我按下域名并使用https加载测试时，即我碰到的内毒素是https://load.api.example.in，响应时间增加了大约5倍。
这使我得出结论，介于两者之间的哈代是一个瓶颈。
我增加了haproxy服务器的大小，在重负载下CPU利用率飙升，但由于服务器较大，只有50%左右。(根据AWS监测)
为了解决这个问题，我需要在What配置(或其他任何地方)中更改什么？
我现在的haproxy配置(匿名)
global
ulim
浏览 0提问于2018-02-21得票数 0
我有测试计划与以下要求与2循环顺序。
ApiHttp请求
Mqtt请求
我需要运行第一个循环&验证API reaponse是正确的还是错误的：
如果为真，运行Mqtt请求，否则启动第二个循环，同样验证API响应，如果是真运行Mqtt，否则停止。
在上面的场景中，我使用beanshell来读取API响应：
vars.put("response", new String(data));
但是不知道如何验证它的真假&执行Mqtt。有什么帮助吗？
浏览 6提问于2020-08-17得票数 1
回答已采纳
我使用的是MQTT 3.1.1，我在我的电脑上安装了一个蚊子作为本地服务器。 我将一些传感器数据从pubsubclient (MQTT客户端库)发送给蚊子，并从蚊子服务器将其保存到数据库中 每当我启动会话到5-10分钟时，我都会收到消息，但在那之后，MQTT客户端无法发送任何消息并自动断开连接。 在断开连接之前，它会在命令行中打印以下消息 client <clientname> has exceeded timeout, disconnecting
Socket error on client <clientname>, disconnecting. 此外，除了QOS
浏览 132提问于2020-09-29得票数 1
在我目前的项目中，我们正在尝试使用Node-RED实现一个功能，用于实验和探索新技术。
功能如下所示。在这里，BadgeReader使用publish-subscribe将其数据发布到Proximity(可以在Node-Red中使用MQTT轻松实现)。Proximity组件从BadgeReader接收数据，并使用该数据通过request/response交互模式与ProfileDB进行交互。现在，我的问题是-我们如何在Node-RED中实现请求/响应交互？(请注意，- Request/Response可以使用MQTT实现，但这个问题与Node-RED中的专用请求-响应功能有关。)
浏览 6提问于2015-12-28得票数 0
我必须向html页面显示mqtt通道的数据。我已经为下面的代码准备了一个node js代码：
var mqtt = require('mqtt');
client = mqtt.createClient(1883, 'mqtt.beebotte.com',
//Authenticate with your channel token,
{username: 'token:TOKEN_KEY', password: ''});
client.on('message', function (topic, mess
浏览 1提问于2015-07-02得票数 0
1回答
我目前使用的是一个MQTT客户端，它与一些Arduino代码链接在一起，每隔2秒产生一次数字输出。这进一步链接到一个NodeRed流，在那里它读取通过代理传递的输入，并将其作为仪表板上的有效负载消息输出。我想生成一个连接到MQTT订阅者的图形节点，并在UI中显示实时数据。我尝试了示例图像中显示的方式，因为我希望仍然看到仪表板中的信息，但我无法获得正确的图形显示。有没有人能帮我教我怎么做？
浏览 1提问于2020-03-24得票数 0
我刚刚从Node-RED和InfluxDB开始，如果这是一个非常愚蠢的问题，我想道歉。
早些时候，我的服务器上有一个网络断开--在将服务器重新连接回网络后，错误错误: read 经常在接收到MQTT信号并试图将其写入进水数据库时显示。
关于我工作的一些背景-我正在从事一个工业IoT项目，在那里，每台机器将通过MQTT将信号发送到Node-RED，然后用Node-RED进行处理并登录到influxDB。在网络断开之前，代码一直在运行，我也看到其他帖子说重新启动Node-RED将解决问题--但我不能重新启动它，除非与工厂安排一个时间--直到那时，更多的数据将丢失。
"Error: read
浏览 7提问于2019-12-23得票数 0
我正忙于构建一个使用MQTT作为通信渠道的应用程序。数据以异步方式进入流中。因此，我想以双向通信的方式使用MQTT。我从为用户构建登录对话框开始。因此，将发生的是，应用程序将建立登录对话框，其中包含用户名和密码，当用户单击登录时，应用程序将发送一个关于服务器正在侦听的主题的命令，并且应用程序需要等待，而不是删除登录对话框，并向用户显示一个旋转器，以显示应用程序正在等待。应用程序将收到它正在监听的另一个主题的答案，服务器将在该主题上发送结果。 所以我的问题是。让登录对话框阻止/等待我们收到服务器将发送的主题的消息的最佳方法是什么？此数据将以不属于登录调用一部分的流的形式出现。我确实可以通过提供
浏览 43提问于2021-09-12得票数 0
1回答
这可能是我误解了Mongo的工作方式/新的Go开发--但我无法从Go连接到我的mongo实例。当我使用Studio 3T连接到我的Mongo实例时，我可以很好地连接，浏览表等等。但是如果我尝试使用Go模块连接，它会抱怨无法找到所有的节点。它是否需要能够访问所有节点？我以为复制集本身就是用来处理复制的？
例如，我有一个Go代码：
package main
import (
"context"
"go.mongodb.org/mongo-driver/mongo"
"go.mongod
浏览 1提问于2021-06-08得票数 0
回答已采纳
1回答
我正在使用IBM的IoT服务。注册了一个设备。现在，我希望从外部mqtt服务器(CloudMQTT)接收消息(此设备)。请提供有关订阅此外部服务器的方式的详细信息。
问候，Mindaugas
浏览 2提问于2020-03-06得票数 0
我试图动态地更改mqtt客户端处理程序和证书，这将导致订阅服务器EOF在订阅服务器和发布服务器连接时发生变化。
这就是我想做的，
1]我正在初始化订阅者/发布服务器(使用firstPubHandler、firstConnectHandler和默认证书)
2]使用publisher在服务器上发送注册消息以获取新的证书详细信息
3]服务器将返回证书详细信息，该响应将由主题.../id/Certificate上的firstConnectHandler处理，以下载证书。
4] firstPubHandler将处理服务器的响应并重新初始化发布服务器/订阅服务器(使用messagePubHandler、c
浏览 19提问于2021-11-01得票数 0
回答已采纳
2回答
我正试图将智能家居设备与谷歌家庭和Alexa集成在一起，但我面临以下问题。
Google /Alexa与我们的设备云服务器之间的通信是HTTP。
智能家居设备与我们的设备云服务器之间的通信是MQTT。
如何跟踪同步请求-响应？有没有更好的方法来实现这个系统？
浏览 0提问于2019-01-31得票数 0
我们可以阻止设备连接到MQTT服务器吗？
我们可以阻止设备订阅主题吗？
我们是否在MQTT服务器上注册了任何设备。所以我们只能允许已知的设备？如果我们有一些注册机制，我们可以使用API动态地做吗？
浏览 1提问于2014-12-19得票数 1
我已经能够使用Postman中的REST设置来创建设备、发送测量、通知和警报。
我还尝试了使用MQTTBox的Hello MQTT示例。
但是，我想要做的是使用Node-Red通过SmartRest API将MQTT消息发送到新的或现有的MQTT。
我已经尝试了"100，我的第一个MQTT设备，c8y_MQTTdevice"，"200，myCustomTemperatureMeasurement，华氏75.2，F“和使用MQTTBox的后续步骤，似乎工作得很好。
当我试图找出从Node-Red发送测量数据的方法时，我似乎无法理解Smart Rest的想法。我不想每次都在
浏览 1提问于2018-12-05得票数 1
1回答
在我的节点红流中，我将一个IBM IoT输入节点连接到IBM IoT输出节点。我使用命令行上的mosquitto_pub发布到WIoTP，以便启动节点红色流。同样，我使用mqtt sub (来自)订阅来自Node-RED流的消息。但是，我没有在我的订阅终端窗口接收有效负载。
发布
mosquitto_pub -h orgId.messaging.internetofthings.ibmcloud.com -p 8883 -i d:orgId:dType:default -u use-token-auth -P 'authToken' --cafile messaging.pem
浏览 0提问于2018-07-19得票数 0
回答已采纳
据我所知，Raspbian (2019-04-08-raspbian-stretch-full.img)以点红为特色。
我看过youTube示例，这些例子显示了节点-红色配置MQTT服务器，并不禁想知道Raspbian映像是否已经有了MQTT服务器？
如果安装了默认代理，如何对代理进行“冒烟测试”？
我想了解如何(从命令行)测试是否安装了MQTT服务器，以便确定是否需要在rPi上安装MQTT。
浏览 0提问于2019-07-26得票数 1
我创造了一个alexa智能家居技能。我目前正在向我的树莓派发送来自AWS lambda的使用MQTT的技能请求。则响应由lambda生成，而不考虑在pi上运行的任何逻辑，或者它甚至根本不运行。我想发送一个响应，让lambda函数从pi返回。 我可以使用MQTT或API网关调用lambda函数，但这是没有用的，因为它需要能够访问实例，才能访问alexa调用的函数以返回响应。 我可以使用HTTP来做这件事，但是我必须向我的pi公开一个端口。我没有足够的关于安全问题的知识，所以我不愿意这样做。 有没有办法通过MQTT、web socket或任何其他安全方法来实现这一点？
浏览 17提问于2019-02-23得票数 0
1回答
无法删除节点红色的模块。
、、、
我有问题的节点红色，不能再运行任何流，我不知道该做什么了。
我得到以下错误
Imported unrecognised type: mqtt-env-broker
Flows stopped due to missing node types. Check logs for details.
尝试从调色板中删除此模块，但得到以下错误，我也无法禁用它
Failed to remove: node-red-contrib-mqtt-env
Error: Type in use: mqtt-env-broker
Check the log for more information
我已经安装了节点-
浏览 1提问于2017-03-21得票数 1
回答已采纳
1回答
我试图在Plotly Dash上显示订阅了特定主题的MQTT响应。不幸的是，订阅该主题的on_message函数没有显示任何内容。我是Python和Plotly dash的新手，还不能正常工作 import dash
import dash_html_components as html
import dash_core_components as dcc
import dash_bootstrap_components as dbc
import flask
from dash.dependencies import Input, Output, State
import json
imp
浏览 35提问于2021-07-17得票数 0
回答已采纳
2回答
是否有任何方法实现请求-响应模式与mosca MQTT，以“检查答复从客户端和重新发布，如果我没有收到预期的答复在预期的时间”。
我相信这在Mqtt 5中是可能的，但到目前为止，我必须在QoS 1(它支持Mqtt 3.1.1之前)使用Mosca。
我正在寻找一个节点js的解决办法来实现这一点。
浏览 9提问于2020-01-24得票数 0
1回答
我遇到了一种情况，我需要等待设备的响应(使用mqtt代理，这在当前的问题上下文中并不重要)。
每当我得到一个特定端点上的API调用
我需要等待(视需要而定)从另一个处理程序(mqtt处理程序=> )上的设备响应(2-5秒)。
这个处理程序需要以某种方式通知我，我得到了这个msg (如果处理程序那个时候收到了msg)，用于特定的设备id。
如果设备匹配并通知控制器操作方法，我们将返回成功响应，否则将发送失败响应。
在等待时间之前或之后收到的任何消息都不重要(只需将其视为未订阅)。
我不太清楚实现上述要求的最佳方式是什么。欢迎任何帮助，谢谢
浏览 1提问于2018-12-18得票数 0
2回答
我在Windows7平台上安装了xampp-v9，android打开了sql apache，安装了mqtt broker，确保mqtt服务已经打开，使用mqtt php管理服务器，运行时显示如下
Tokudu安卓推送演示服务器状态: connect(SAM_MQTT，array(SAM_HOST => '127.0.0.1'，SAM_PORT => 1883))；if ($result) { $conn->disconnect()；print_r("Online")；} else { print_r("Offline")；} ?
浏览 4提问于2012-11-05得票数 0
所有关于扩展蚊子到mqtt服务器的示例都提供了桥接示例，适合扩展到最多2个节点的集群。我们可以有超过2台，比如说10台蚊子到mqtt服务器彼此连接，以扩展服务的总连接数吗？
浏览 2提问于2017-03-15得票数 1
我试图用MQTT (实际上是mqtt-sn )做一些事情--并且想知道报告错误的方法是什么。
当在MQTT上使用类似于模式的命令/响应时，应该如何报告响应错误？
示例1:类似于MQTT上的FTP。
- Host sends "delete filename" - how would I report "file not found"
示例2:设备具有可配置的传感器。
- Host sends "configure sensor: parameter 1 = A, parameter = "
问题：如何报告“无效参数
浏览 0提问于2019-08-07得票数 1
1回答
我正在使用SocketRocket库： for mqtt over websockets。我已成功连接服务器。
let socket = SRWebSocket(url: mUrl, protocols: ["mqtt"], allowsUntrustedSSLCertificates: true)
socket.delegate = self
socket.open()
我检测到websocket是否准备就绪，如下所示：
func webSocketDidOpen(_ webSocket: SRWebSocket!) {
print("SRWebSocket w
浏览 3提问于2018-05-15得票数 0
2回答
我得到了一个项目，该项目通过Javascript使用Paho/MQTT客户端更新网页。该项目通过localhost:8080上的python启动http服务器，然后在加载网页时，main.js脚本启动客户端并运行连接，如下所示：
var client = new Paho.MQTT.Client("localhost",Number(8080),'0');
client.onConnectionLost = onConLost;
client.onMessageArrived = onMesArvd;
console.log("start connec
浏览 0提问于2019-01-22得票数 0
回答已采纳
我正在尝试编写一个UWP应用程序，它通过HTTPS使用MQTT与服务器通信。我使用StreamSocket通过线路发送整个MQTT数据包，但无法从服务器获得任何响应。如果我试图重新发送数据包，服务器将终止连接。使用Wireshark，我可以看到服务器响应了一个消息内容类型:警报(21)，其中包含26个字节的数据，但我无法通过StreamSocket.InputStream读取它
var streamSocket = new StreamSocket();
Buffer packet;
// Building Mqtt packet.
await streamSocket.ConnectAs
浏览 3提问于2019-06-21得票数 0
在我目前的项目中，我使用的是AM2302温度传感器，它连接到Raspberry Pi上的GPIO引脚上。Node.js中的温度传感器代码如下所示：
var sensorLib = require('node-dht-sensor');
var mqtt=require('mqtt');
var client=mqtt.connect('mqtt://test.mosquitto.org:1883');
var sensor = {
initialize: function () {
//Developer: By
浏览 4提问于2016-03-21得票数 0
我创建了一个客户机来使用安全连接和加密的有效负载进行测试，所以我想使用默认的SSL配置。我试过这样做，但我立即得到了一个ConnectionClosedException和服务器。我应该在服务器上配置一些东西吗？下面我留下了代码和异常。
HiveMQ：
代码：
// Creates the client object using Blocking API
subscriber = Mqtt5Client.builder()
.identifier(UUID.randomUUID().toString()) // the unique identifier of
浏览 4提问于2019-06-24得票数 0
回答已采纳
我对使用回环很陌生，我使用的是loopback4 (我认为它被称为回环-下一步)。
为了能够支持mysql的CRUD操作，我已经建立了控制器、模型和解决方案，这一切都很好。
我希望我的回送应用程序也能连接到MQTT服务器，这样我就可以订阅来自MQTT的消息，并通过在我的存储库中创建实体来响应这些消息。此外，我希望现有的控制器方法能够将消息放到MQTT (发布)上。
我很难理解如何在生态系统中正确地做到这一点.
我不想创建服务器，因为文档将服务器描述为包含侦听端口。我不希望我的环回应用程序是一个MQTT服务器。我只想让它和一个人互动。
类似地，我不认为这将是一个MQTT桥，或者一个数据源。
我怀
浏览 1提问于2019-04-21得票数 0
回答已采纳
1回答
我使用node-red通过MQTT获取数据。我得到了如图所示的响应..
不，我想在函数的帮助下分别获取Phase1，Phase2，Phase3，Phase4和Timestamp的数据。我不知道如何获得这样的数据。附注:我是node.red的新手。谢谢你
浏览 2提问于2018-02-07得票数 0
回答已采纳
以下代码在第一次执行时按预期工作。第二次失败时出现以下错误：
Error: Can't set headers after they are sent.
基本上，我试图从一系列已发布的mqtt主题中返回一条消息。我试过几种方法来做这件事，但对这种行为感到困惑。下面的代码显示了使用承诺的尝试，详见 MDN文章。我还尝试使用异步/等待(如果需要的话，我也可以发布这段代码)。
概念
一个get请求来自一个网页，这将触发一条mqtt消息发布到本地代理。另一个端点正在侦听此主题。在这种情况下，一个树莓π与连接的网络摄像头。该主题被接收，rpi做它的事情，并发布一个返回消息与一个url作为它的数据
浏览 0提问于2018-07-04得票数 0
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
回答已采纳
对于每个请求，HTTP和web套接字进行3路握手，然后是请求/响应和终止(持久连接)。
与上述类似，我们在websocket上有MQTT和MQTT，它们都是基于pub/sub模型的。MQTT在IoT硬件上是理想的，因为证书和密钥可以安全地存储在硬件设备上。因为MQTT的websocket是理想的移动/网络应用程序。
在MQTT和MQTT在websocket上的情况下，在握手/数据交换/TCP/UDP？方面会发生什么？
浏览 10提问于2020-10-07得票数 0
回答已采纳
我有以下调用rest API的序列。
invokehttp processor-->split JSON->jsonpath processor-->text replace processor (用于post数据创建)->InvokeHTTP->XPATH processor for attribute-> splitjson在调用http processor和create payload后生成的原始流程文件->mqtt。
在这里，我调用rest API，在拆分大型json之后，我使用文本替换来调用另一个api(POST请求)，该api使用来自第一个
浏览 8提问于2019-07-08得票数 0
我设置了一个RabbitMQ节点(RabbitMQ 3.6.10，Erlang20.2.2)，以启用使用AMQP和MQTT协议的连接。我还计划使用rabbitmq-auth-backend-http插件来验证/授权所有请求。
这是我的RabbitMQ节点配置(/etc/rabbitmq/rabbitmq.conf)：
loopback_users.guest = false
listeners.tcp.default = 5672
management.tcp.port = 15672
log.console.level = debug
mqtt.allow_anonymous = false
浏览 7提问于2020-05-07得票数 1
我需要编写一个API，当客户端调用该API时，它在MQTT请求主题上发布消息，并等待响应主题上的响应。如果response topic没有返回任何内容，那么API应该返回默认响应。
我的问题是在消费主题中的消息时。我可以发布，但是我如何等待特定主题的响应(消费消息)并将其作为响应发送，或者在特定时间后发送API的默认响应。
我使用的是Spring4，Java。
浏览 0提问于2018-08-03得票数 1
关于JSON通过MQTT树莓派和gps通过MQTT发送位置数据到服务器的问题。所有信息都由服务器接收，但是，当接收到有效负载时，它是一个字符串。
如何从我的json中删除"“。
来自GPS模块的原始数据：
2017-03-31 2:13:29 PMec04f460.a91eb8 msg.payload : Object
{ "class"："TPV"，"tag"："RMC"，"device"："/dev/ttyUSB0"，"mode"：3，"time"：
浏览 2提问于2017-04-01得票数 0
2回答
我正在计划建立一个家庭自动化系统，其中IoT设备与MQTT系统进行通信，还包括一个Django web服务器，为ios/安卓设备提供broker.The。我将描述一个我想要实现的示例。
从移动应用程序向Django服务器发出API调用，以打开设备。当向Django发出这样的API请求时，它应该通过MQTT协议向IoT设备推送‘打开’数据。
此外，IoT设备向MQTT代理发送一些实时数据。在收到这样的数据后，我想通过apns/fcm向移动应用程序发送推送通知。
我该如何实现这一点呢？Django通道是否会发挥作用，或者我是否应该编写Django服务器代码来充当MQTT客户机并与MQTT代理通信？
浏览 1提问于2017-09-15得票数 3
1回答
我正在运行两个码头:一个用于mqtt服务器，使用蚊帐，另一个使用flask_mqtt
烧瓶容器正在接收CONNACK并将订阅发送给代理，但是从未得到任何SUBACK。
但是，它成功地向/home/mytopic 发布了hello
这是相当奇怪的，因为它的工作没有任何问题以外的码头。
这是船坞的组成：
services:
mqtt:
container_name: mqtt_container
image: eclipse-mosquitto:latest
networks:
- local_net
ports:
- "1883
浏览 8提问于2022-10-10得票数 1
回答已采纳
1回答
我正在使用Eclipse 1.2.2、WSO2 DAS3.0.0和ActiveMQ 5.12.1在IoT世界中做一些实验。到目前为止，我成功地将DAS设置为M2M中间件服务器，Kura在Raspberry PI2上设置为IoT网关，ActiveMQ设置为MQTT服务器。
我还编写了一个非常基本的MQTT消息生成器，定期向MQTT服务器发送一条非常简单的MQTT消息，以模拟实际设备发送MQTT消息。这个想法是用一个定期发送数据的BlueTooth设备来代替这个应用程序。
当我使用MQTTSpy监视传入的消息时，我注意到MQTT消息是格式化为二进制的。库拉在使用MQTT发送数据时使用Google协
浏览 2提问于2015-12-02得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
