我只是在玩蚊子和mqtt协议，遵循非常好的视频
尝试在我的本地主机上测试它
在终端窗口中，我运行：
mosquitto_sub -t "nodeconf/eu" -v
但是当我运行这段代码时：
var mqtt = require('mqtt');
var client = mqtt.connect();
client.on('connect', function () {
client.subscribe('nodeconf/eu');
client.publish('nodeconf/eu',
浏览 1提问于2015-06-14得票数 3
当我按照每个IoT文档在CLI中触发以下命令(在AWS IoT中创建自定义授权程序)时，
aws iot create-authorizer --authorizer-name mqtt-authorizer
--authorizer-function-arn arn:<arn>
它给出了以下错误：
An error occurred (InvalidRequestException) when calling the CreateAuthorizer operation: Token key name for authorizer mqtt-authorizer cannot b
浏览 7提问于2022-07-18得票数 0
1回答
我需要使用MQTT将消息从我们的服务器传送到android设备，于是我决定使用开源服务器MQTT。我已经设置了所有的安装要求的蚊子和托库服务。
现在出现的问题是如何实现向设备发送消息的主要目标。我怎样才能做到这一点。
我参考了链接以供参考。
为了发送简单的文本消息和接收响应，我在下面实现了服务代码。
$srv = new soap_server();
$srv->configureWSDL('send mqtt msg', 'urn:mqttwsdl');
$srv->register("send_mqtt_msg",
array(&
浏览 6提问于2013-12-26得票数 1
问题出在服务器上还是发送请求上？
删除门代码
func mqttDidPing(_ mqtt: CocoaMQTT) {
print("mqttDidPing")
}
func mqttDidReceivePong(_ mqtt: CocoaMQTT) {
print("mqttDidReceivePong")
}
func mqtt(_ mqtt: CocoaMQTT, didPublishAck id: UInt16) {
print("didPublishAck : \(id)")
}
func mqtt(_
浏览 4提问于2018-05-18得票数 1
我们正在开发一个基于STORM的IoT信号处理平台，考虑到横向可伸缩性。该平台旨在同时处理多个信号(从一个MQTT主题中收集)，向它们应用一系列的信号处理算法。到目前为止，我们的解决方案包括，如描述的
MQTT服务器，其主题名称包括信号的标识符(例如，“病人/1”、“病人/2”、…、“病人/N”。
MQTT喷口，它订阅其名称的所有主题。
匹配模式“耐心/+”(因此，接收所有信号的值和每个信号的标识符)。我们用这个
当我们不知道在某一时刻可以接收多少信号时，我们就会接近，我们不希望每一个可能的信号都有不同的喷口
信号！
几个链式螺栓，每个信号处理步骤一个
(算法)
我们的解决
浏览 1提问于2018-04-04得票数 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
回答已采纳
MQTT是一种发布/订阅协议。每当发布者发布到某个主题时，所有订阅了该主题的订阅者都将通过MQTT代理获得消息。我想知道MQTT代理可以处理的最大客户端数。这有没有上限？
浏览 6提问于2018-01-08得票数 1
我正在尝试使用作为我正在构建的NativeScript应用程序的一部分。
当我试图要求的时候，我遇到了一个问题。
我的代码使用var mqtt = require('mqtt');作为示例指示，但是当试图编译NativeScript应用程序时，我得到以下错误：
com.tns.NativeScriptException:未能找到模块："mqtt"，相对于:/app/tns_mqtt。
我已经验证了mqtt文件夹在我的node_modules文件夹中，我尝试创建一个tns_modules文件夹并在那里复制mqtt文件夹。
不过，我还是会犯错误。我试着加载爆
浏览 1提问于2016-04-14得票数 0
回答已采纳
我使用vcpkg安装了paho-mqttpp3: x64 -windows，并在Visual中使用x64中的build选项运行了下面的代码。
#include <iostream>
#include "mqtt/async_client.h"
int main()
{
std::cout << "Hello World!\n";
}
当我运行上面的代码时，它会生成以下错误
> 1>d:\vcpkg\packages\paho-mqtt_x64-windows\include\paho-mqtt\mqttpropert
浏览 2提问于2020-01-15得票数 1
回答已采纳
我正在使用连接internet mqtt服务。
var name = '/#';
var mqttclient = mqtt.createClient(1883, service.getHost(),{username:"" ,password: service.getKey() });
mqttclient.on('connect', function onConnect(){
winston.info('MQTT Connected'.green, '/'+service.getPattern()+nam
浏览 2提问于2013-12-08得票数 0
1回答
我遵循连接摩斯基托和卡夫卡与MQTT源连接器。我正在把摩斯基托出版商发送给摩斯基托用户和卡夫卡消费者的数据。但是我的卡夫卡-使用者的ConsumerRecord对象中的键和值字段有一些占优势的字节字符。下面是我得到的代码片段和输出。
mqttPublisher.py
while v3 < 3:
data3 = {
"time": str(datetime.datetime.now().time()),
"val": v3
浏览 0提问于2018-12-18得票数 3
回答已采纳
1回答
我找到了Linux中安装的paho MQTT库的列表：
libpaho-mqtt3a.so -> libpaho-mqtt3a.so.1
libpaho-mqtt3a.so.1 -> libpaho-mqtt3a.so.1.3
libpaho-mqtt3a.so.1.3
libpaho-mqtt3as.so -> libpaho-mqtt3as.so.1
libpaho-mqtt3as.so.1 -> libpaho-mqtt3as.so.1.3
libpaho-mqtt3as.so.1.3
libpaho-mqtt3c.so -> libpaho-mqtt3c.
浏览 7提问于2021-11-24得票数 1
flespi.io使用身份验证令牌作为用户名，如果需要，您也可以将令牌设置为密码。如何使用HiveMQ Java实现连接到flespi？
Mqtt3AsyncClient client = MqttClient.builder()
.useMqttVersion3()
.identifier(UUID.randomUUID().toString())
.simpleAuth()
.username(mqttClientConfig.getUser())
浏览 28提问于2020-02-11得票数 1
回答已采纳
如何将rabbitmq web mqtt插件绑定到只回送接口？
我正在尝试使用配置文件/etc/rabbitmq/rabbitmq.conf。
listeners.tcp.1 = 127.0.0.1:5672
management.listener.ip = 127.0.0.1
management.listener.port = 15672
mqtt.listeners.tcp.1 = 127.0.0.1:1883
web_mqtt.tcp.ip=127.0.0.1
web_mqtt.tcp.port=15675
而配置可以正常工作。
AMQP (5672)
Management (156
浏览 4提问于2018-03-21得票数 2
回答已采纳
1回答
我在Bluemix上使用Node-RED与带温度传感器的Arduino Uno对话。我使用了一个将温度发布到MQTT主题的方法，并添加了来自paho pubsubclient库@knolleary的示例中的代码，以添加订阅MQTT主题的代码。我在尝试订阅时遇到错误。我如何查看MQTT日志来找出哪里出了问题？
浏览 2提问于2015-10-05得票数 2
我正在尝试gcc在Ubuntu20.04上的Azure的以下项目：https://github.com/Azure/azure-umqtt-c
当我通过cmake安装该项目时，我尝试使用gcc mqtt_client.c，但遇到以下错误：
omic@omic-virtual-machine:~/azure-umqtt-c/src$ gcc mqtt_client.c
mqtt_client.c:18:10: fatal error: azure_umqtt_c/mqtt_client.h: No such file or directory
18 | #include <azure
浏览 0提问于2022-04-10得票数 0
1回答
我需要一些帮助来创建从CloudMQTT到Thingspeak的桥梁。连接URL (mqtt://mqtt.thingspeak.com:1883)无效，因为没有添加用户信息。
尝试了mqtt://zr87:@mqtt.thingspeak.com:1883，但没有成功。
浏览 8提问于2018-02-06得票数 0
这里是我的脚本
import paho.mqtt.subscribe as subscribe
topics = ['#']
m = subscribe.simple(topics, hostname="eu.thethings.network", retained=False, msg_count=2)
for a in m:
print(str(a.topic))
print(str(a.payload))
将此作为错误消息返回：
Traceback (most recent call last):
File "MQTT_s
浏览 0提问于2018-03-08得票数 1
回答已采纳
1回答
我正在使用这个库：
使用此选项：
MQTT mqtt = new MQTT();
mqtt.setClientId(deviceId() + "-device");
mqtt.setHost(getResources().getString(R.string.jms_uri));
mqtt.setUserName(getResources().getString(R.string.jms_user));
mqtt.setPassword(getResources().getString(R.string.jms_password));
mqtt.setReconn
浏览 3提问于2016-10-19得票数 0
在我当前的Android项目中，我使用Paho-Mqtt客户端从服务器获取实时提要。根据我的要求，我只需要MQTT服务，而应用程序是在前台。以及应用程序的每个屏幕链接到不同的mqtt-主题。示例：
If user in Activity A, I need to subscribe to a MQTT topic A.
If your move to Activity B I need to unsubscribe from topic A and subscribe to topic B.
现在的问题是，何时应该连接到MQTT服务，何时应该断开连接？
我可以在每个活动的onResum
浏览 2提问于2018-02-21得票数 3
1回答
将MQTT协议路由到PM2
、、、、
我们有一些连接到MQTT Broker (mosquitto)的设备，发布一些事件。我们希望通过node应用程序捕获所有这些事件。一个简单的解决方案是创建一个node应用程序作为客户端，它连接到MQTT Broker，侦听每个事件并为它们做特定的工作。但是从可伸缩性的角度来看，如果我们想要扩展我们的node应用，我们必须运行我们的node应用的多个实例，并使用PM2作为负载均衡器。但问题是，当我们创建多个实例时，所有实例都会收到相同的事件，并且对于该特定事件，所有实例都会多次执行与我们拥有的实例数量相同的工作。
如何将所有MQTT事件路由到PM2负载均衡器？
浏览 12提问于2019-07-14得票数 1
回答已采纳
我正在尝试在rabbitmq中启用mqtt。插件已成功启用，但当我在rabbitmq_mqtt的配置中进行更改时，它无法启动服务。即使在谷歌了很多次之后，我也不能看到同样的问题被提出。即使端口可用，RabbitMQ_MQTT也无法加载。
Starting broker...
BOOT FAILED
===========
Error description:
{could_not_start,rabbitmq_mqtt,
{{function_clause,
[{rabbit_networking,tcp_liste
浏览 3提问于2018-01-28得票数 0
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回答
我正在使用node.js mosca MQTT代理为一些物联网(物联网)应用程序。
MQTT代理(特别是mosca )能够处理的最大主题数是多少？
如果我想增加允许的主题数量，是否有可以修改的配置参数，或者可以更改代码的哪一部分？
浏览 8提问于2015-12-30得票数 3
回答已采纳
我的目标是将数据保存到在MQTT上接收到的不同类型消息的Django模型中。为此，我假设我需要导入我想要保存的模型。但是当我这么做的时候，我得到了"Django.core.exceptions.AppRegistryNotReady:应用程序还没有加载“。
我的MQTT连接设置: mqtt.py
import paho.mqtt.client as mqtt
from print.views import *
def on_connect(client, userdata, rc, properties=None):
client.subscribe("foo/pri
浏览 0提问于2021-11-09得票数 0
我需要一些帮助，将我的react项目连接到myqtt中心，以发布和接收数据。这是我使用的代码：
import React, { Component } from 'react';
var mqtt = require('mqtt');
var options={
clientId:"id",
username:"ArduinoProject",
password:"ssssss",
protocolId: "MQTT",
protocolVersion:
浏览 1提问于2021-02-05得票数 1
我想验证给定的IP和端口是否在MQTT中运行，如果不是，则必须向用户显示异常。这是我的代码，
try {
MqttMessage message2 = new MqttMessage();
MQTT mqtt_connect = new MQTT();
mqtt_connect.setHost(Host_Address, port);
String topic = "/call/MQTT_Config";
mqtt_
浏览 0提问于2015-12-15得票数 2
我需要帮助，因为我对kafka和mqtt是个新手。我将试着简要解释一下我正在使用的架构。我使用的是Confluent 5.3.1平台，并配置了一个连接器(源mqtt连接器)，用于将数据从mqtt代理传输到kafka代理。为了连接到mqtt代理，我需要一个Json Web令牌，但我不知道怎么做。我已经阅读了Confluent文档，但我找不到任何可能的解决方案。有人能帮我吗？
浏览 0提问于2019-11-28得票数 1
我有一个主应用程序，它初始化fastAPI并使用fastAPI MQTT。现在，该文件在事件循环中运行，并正在寻找常规的MQTT端口。
我有第二个应用程序，它使用MQTT Websocket并运行在一个事件循环中。现在，我想让这两个应用程序互相交换信息。我如何使他们交换，information.One是使用websocket，另一个是使用快速API。让他们彼此交谈的方法是什么。这是
main.py -运行fastapi和mqtt -普通的。
from fastapi import FastAPI
from fastapi_mqtt import FastMQTT, MQTTConfig
fro
浏览 14提问于2022-02-21得票数 0
我们使用node作为服务器，使用mqtt作为库。
我们安装了蚊子作为网页插座的brocker。
现在我们必须跟踪新客户端连接和断开时的记录，但问题是我们无法获得任何事件。
那么，有什么方法可以做到这一点吗？
const mqttServer = require('mqtt');
const clientId = appName + "_" + moment().valueOf();
const conOptions = {
clientId,
username: mqtt.user,
password: mqtt.pass,
k
浏览 11提问于2019-08-06得票数 3
回答已采纳
1回答
MQTT与activeMQ连接
、、、、
我已经为mqtt编写了一个客户端代码，它应该连接(现在只连接到服务器)到活动的mq服务器。代码如下：
#include "stdafx.h"
#include<iostream>
#include<winsock2.h>
#include "mqtt.h"
#pragma comment(lib,"ws2_32.lib") //Winsock Library
#include <stdlib.h>
#include <winsock2.h>
void mqtt_init(mqtt_broker
浏览 2提问于2014-03-12得票数 0
1回答
我正试图通过在英特尔爱迪生板上运行以下脚本来连接安装在本地的莫斯基托服务器-
var client = mqtt.connect("ws://localhost:9001");
client.on('connect', () => {
console.log("connected");
})
但是，连接事件或日志从未被调用。请注意，当我试图从网页上调用这段视频时-
var client = new Paho.MQTT.Client("localhost", 9001, "clientId");
浏览 5提问于2017-09-07得票数 0
回答已采纳
我们计划在设备上运行多个码头容器，使用MQTT相互通信。
到目前为止，我们成功地安装并连接了greengrass，部署了容器，并将与greengrass组件一起使用。
ipc_client = awsiot.greengrasscoreipc.connect()
使用套接字连接。
如何使用主机、端口和身份验证将应用程序连接到本地MQTT代理？
像这样的东西
myAWSIoTMQTTClient = AWSIoTPyMQTT.AWSIoTMQTTClient(CLIENT_ID)
myAWSIoTMQTTClient.configureEndpoint(ENDPOINT, PORT)
if PA
浏览 1提问于2021-08-03得票数 4
1回答
嗨，我正在尝试使用spring集成来接收MQTT消息，处理它们并发布到另一个主题。
下面是integration.xml：
<int-mqtt:outbound-channel-adapter id="mqtt-publish"
client-id="spring-foo-1"
client-factory="clientFactory"
auto-startup="true"
url="tcp://localhost:1883"
default-qos="
浏览 0提问于2016-10-14得票数 2
回答已采纳
我试图使用ionic 3中的ngx-mqtt插件包含一个MQTT代理配置，我使用一个变量来配置代理。在我的app.module.ts中，是这样的。
MQTT_SERVICE_OPTIONS = {
hostname: '172.30.66.232',
port: 9001,
path: '/ws'
};
export { MQTT_SERVICE_OPTIONS };
export function mqttServiceFactory() {
return new MqttService(MQTT_SERVICE_OPTIONS);
}
在
浏览 4提问于2018-06-02得票数 0
我正在尝试按照提供者架构模型来实现一系列传输提供商。因此，我创建了一个抽象的传输提供者，然后由特定的提供者进行扩展，比如mqtt、nats等等。然而，我在初始化mqtt客户机时遇到了问题。初始化、连接和与客户端交互的代码(当放在处理程序之外时)将正确运行。但是，提供程序方法connect()中的相同代码不起作用(它似乎在使用调试器监视时初始化客户机，然后跳过所有client.on函数)。
这是抽象提供程序，它简单地概述了需要使用的方法：
class abTransProvider {
constructor() {
this.client;
this
浏览 6提问于2022-09-16得票数 0
回答已采纳
1回答
我是MQTT的新手。我用ssl创建了一个蚊子代理，并成功连接。我创建证书的命令如下：
openssl req -new -x509 -days durations -keyout mqtt_ca.key -out mqtt_ca.crt
openssl genrsa -des3 -out mqtt_server.key size_bits
openssl req -out mqtt_server.csr -key mqtt_server.key -new
openssl x509 -req -in mqtt_server.csr -CA mqtt_ca.crt -CAkey mqtt_ca.k
浏览 1提问于2018-06-30得票数 0
我正在处理一个ESP32项目，在该项目中，我将从一个保存在that中的文件中获取一些数组值。在获取使用IRsend函数发送IR原始值的值之后，将MQTT确认发送到aws。但是在发布时，我会得到错误堆栈溢出错误。发送确认
{
"Device_Type": "IR",
"Sub_Device_Type": "AC",
"Message_Type":"user",
"DeviceName":"Whirlpool",
"
浏览 1提问于2021-06-03得票数 1
回答已采纳
我在node.js中使用MQTT语法风格来制作继承类，有两个类，其中基类是构建ES6客户端，继承类是扩展基类。
然而，问题是继承的类不能使用基类中定义的变量。
例如，在我的基类中，有一个名为this.mqtt_client的公共变量，当我试图在继承的类中使用此变量时，它总是产生一个未定义的问题
我的基类如下
var mqtt = require('mqtt'),
EventEmitter = require('events').EventEmitter;
class MQTTBaseClass extends EventEmitter{
co
浏览 2提问于2017-02-07得票数 0
回答已采纳
1回答
使用MQTT的Django信道
、、、、
我试图使用django通道创建websocket，并将mqtt与通道集成，mqtt发布消息应该由consumer.py内部的函数接收到websocket客户端。我有如下的消费者频道
consumer.py
from channels.consumer import AsyncConsumer
from paho.mqtt import client as Mqtt
class Testing(AsyncConsumer):
async def websocket_connect(self, event):
obj = Mqtt.Client()
o
浏览 5提问于2021-09-23得票数 1
2回答
我想在Artemis activemq中使用mqtt。我尝试为mqtt添加一个模块，就像本文中的一样。我的问题是一样的，我看不到添加对MQTT的协议支持。
有人能帮我吗？
浏览 4提问于2017-07-31得票数 1
回答已采纳
订阅留存主题时获取重复留存消息。 我在我的Iot项目中使用了spring mqtt集成。在这里，一旦接收到保留的消息，它将继续订阅，直到我将空白消息发布到保留标志设置为true的同一主题。我注意到，当我在终端中使用mqtt命令执行相同的过程时，订阅保留的主题时，它只订阅一次，不会发生重复订阅。 我使用以下代码通过使用#订阅所有主题 @Bean
public MessageChannel mqttInputChannel() {
return new DirectChannel();
}
@Bean
public DefaultMqttPahoC
浏览 203提问于2019-04-04得票数 0
1回答
我在未加密的MQTT通信中捕获了数据包：
📷
协议被检测为TCP。如何让Wireshark分析作为MQTT的数据包？
📷
UPD
如果我将MQTT服务器设置为默认的1883端口，则Wireshark会像MQTT一样处理数据包。但是，当Wireshark在默认端口上运行时，如何要求Wireshark处理包lime？
📷
浏览 0提问于2020-01-20得票数 0
我正在尝试用MQTT.js创建一个持久的会话，所有事情似乎都很好，除了一件事，正如标题所说的那样。我还使用了QoS 2，因此客户端应该只接收1条没有重复的消息
以下是代码：
broker.js不重要
publisher.js
const mqtt = require("mqtt");
const getWeather = require("./api-clients/openWeatherMap/openWeatherMapClient");
const client = mqtt.connect("mqtt://localhost", {
浏览 6提问于2021-10-06得票数 0
回答已采纳
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
回答已采纳
我正试图在python项目中使用paho-mqtt，我使用py魅力作为我的IDE。我使用：pip安装paho-mqtt安装了paho-mqtt，但似乎有些地方不对劲。因为当我部署以下脚本时：
import paho.mqtt.client as mqtt
# The callback for when the client receives a CONNACK response from the server.
def on_connect(client, userdata, flags, rc):
print("Connected with result code "
浏览 2提问于2019-05-09得票数 0
回答已采纳
项目要求将文件中的某些字符串替换为特殊字符，例如
示例文件-示例输入
file.conf
bridge.mqtt.aws.mountpoint = aws/
bridge.mqtt.aws.certfile = etc/certs/client-cert.pem
sed命令一
I键入sed命令，如下所示
sed -i "s/aws/test/g" ./file.conf
结果一
结果如下：
bridge.mqtt.test.mountpoint = test/
# The line I would expect would be `bridge.mqtt.test.mount
浏览 3提问于2020-03-01得票数 0
我正在尝试使用来自cpan的Net::MQTT::Simple包。下面是同一个cpan页面上的“面向对象”示例的修改版本： use Net::MQTT::Simple;
my $mqtt = Net::MQTT::Simple->new("test.mosquitto.org");
#This doesn't actually execute
print "After new";
$mqtt->run(
"test" => sub {
my ($topic, $message) = @_
浏览 14提问于2019-05-06得票数 1
回答已采纳
这是我找到的代码
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe("IOT_NEAT_TOPIC01")
def on_message(client, userdata, msg):
print(msg.topic+" "+str(msg.payload))
client = mqtt.Clien
浏览 9提问于2017-07-30得票数 0
1回答
我对MQTT集群非常困惑，它似乎不是MQTT协议的一部分，我想知道是否每个MQTT代理实现都有自己的方法来实现它。另外，您是否知道群集节点之间共享哪些类型的信息？它似乎保留了与发布/订阅相关的会话相关的信息，但没有保留消息，对吗？谢谢!
浏览 2提问于2021-07-09得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
