对于每个请求，HTTP和web套接字进行3路握手，然后是请求/响应和终止(持久连接)。
与上述类似，我们在websocket上有MQTT和MQTT，它们都是基于pub/sub模型的。MQTT在IoT硬件上是理想的，因为证书和密钥可以安全地存储在硬件设备上。因为MQTT的websocket是理想的移动/网络应用程序。
在MQTT和MQTT在websocket上的情况下，在握手/数据交换/TCP/UDP？方面会发生什么？
浏览 10提问于2020-10-07得票数 0
回答已采纳
1回答
我正在使用蚊子mqtt与MQTT协议和MQTT之上的websockets协议。有些客户端使用mqtt协议，有些客户端使用websocket协议，这是由于它们的局限性。MQTT端口为1883，websocket端口为8083。问题是，我想分享两个端口上的所有主题，即websocket和MQTT。在MQTT代理或任何其他解决方案中，我应该做什么类型的配置？
换句话说，我想听关于websocket(端口8083)的所有主题，这些主题是在同一个代理上在mqtt(端口1883)上发布的，反之亦然。
mosquitto.conf文件如下
allow_anonymous false
password_fil
浏览 0提问于2018-02-08得票数 0
与直接MQTT相比，MQTT相对于WebSocket有什么优点？
我正在考虑在我的项目中使用MQTT，所以我想知道为什么有些人选择MQTT而不是直接MQTT而不是WebSocket。
浏览 16提问于2015-06-03得票数 72
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
有人能给我解释一下在Websocket上传输MQTT而不是直接在MQTT上传输MQTT的优缺点吗？我计划在我的ESP8266项目中使用websocket上的MQTT。我处于不能直接使用MQTT的情况
浏览 25提问于2019-02-28得票数 0
我想问您是否可以在运行MQTT客户端的同时使用Python Backend Framework Tornado监听WebSocket。
我的目标是创建一个MQTT客户端，该客户端将从MQTT代理接收到的消息发送到React前端的WebSocket。
但我的第一步是在后端成功运行MQTT Client和WebSocket。
提前谢谢你
浏览 33提问于2021-02-14得票数 0
javascript mqtt websocket连接在localhost中工作正常，在https服务器中不工作 代码 <html>
<head>
<meta charset="utf-8">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title>Hello MQTT World</title>
<meta name="
浏览 72提问于2021-05-01得票数 0
我有一个MQTT客户机/代理实现，客户端是基于浏览器websockets的，服务器是ASPNetCore 1.1和Kestrel & Websockets (0.1.0)。
作为MQTT规范的一部分，我正在使用"MQTT“作为子协议启动websockets连接，服务器在建立websockets连接时会查找它。
使用以下方法建立的JavaScript连接：
var wsMQTT = new WebSocket(g.protocol + "//" + g.serverName + ":" + net.WSPORT, "MQTT");
浏览 1提问于2017-06-11得票数 1
回答已采纳
2回答
基于Websocket协议的MQTT
我正在尝试使用端口443(ssl/tls)上的erlang连接IBM服务。但是，我收到了错误。
IBM ()表示支持websocket连接。除了正常的tcp连接之外，没有提到websocket的使用(教程/指南)(我成功地获得了连接)。
我想要一个简单的、一步一步的文档，比如Amazon ( IoT，)，将websocket连接作为客户端应用程序。
我正在计算URL/URI，我认为这可能是不适当的，例如ws://host:port/path。目前，我将其命名为wss://fybr123mqtt.mybluemix.net (其中fybr123mqtt是我
浏览 6提问于2016-12-07得票数 1
我试图将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
回答已采纳
控制台浏览器中的错误日志：
"WebSocket连接到'ws://127.0.0.1:1883/mqtt‘失败: WebSocket握手时出错: net::ERR_CONNECTION_RESET“
我的代码.js将蚊子连接到服务器：
var options = {
clientId: 'web-client',
connectTimeout: 5000,
hostname: '127.0.0.1',
port: 1883,
p
浏览 6提问于2019-01-12得票数 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
回答已采纳
我使用这样的服务器：
const aedes = require('aedes')()
const httpServer = require('http').createServer()
const ws = require('websocket-stream')
const port = 8888
ws.createServer({ server: httpServer }, aedes.handle)
httpServer.listen(port, function () {
console.log('websocket se
浏览 5提问于2021-05-18得票数 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
回答已采纳
我正在做一些需要通过websocket进行MQTT的工作(我的服务器限制在端口80上)
我到处都找过了，但是要么没有人有能力!ratain，要么(\)发送websocket数据包。:D
我已经在arduino中找到了这个词
#include "mqtt_client.h"
在我的代码中这样做：
esp_mqtt_client_config_t mqttConfig;
mqttConfig.uri = "ws://test.mosquitto.org";
mqttConfig.port = 8080;
mqttConfig.transport = M
浏览 1提问于2020-01-13得票数 0
我找不到解决这个问题的办法。其他帖子谈到几分钟后断开连接。我的配置在握手期间第一次回复后立即断开连接。超时似乎不起作用。错误日志什么也不告诉我。
为什么连接不能保持畅通？
nginx.conf
user nginx;
#user root;
error_log /var/log/nginx/error.log warn;
pid /var/run/nginx.pid;
worker_processes 2;
events {
worker_connections 1024;
multi_accept off;
}
http {
inclu
浏览 13提问于2018-05-02得票数 0
我正在尝试使用CocoaMQTT框架通过url：wss://cpl-emqx-socket.staging-bitcastle.work:8083/mqtt连接到我的mqtt主机，并创建一个管理器类，如下所示： import CocoaMQTT
class MqttSocketManager: NSObject, CocoaMQTTDelegate {
static let shared = MqttSocketManager()
var mqtt: CocoaMQTT!
func start() {
let
浏览 77提问于2021-10-31得票数 0
1回答
我遇到了websocket重新连接的问题。第一次启动应用程序时，创建websocket连接没有问题。然后我关闭了wifi，几秒钟后我又打开了wifi，在我的onFailure回调中我得到了下面的异常。 WS onFailure javax.net.ssl.SSLException: Read error: ssl=0xbf4618c0: I/O error during system call, Software caused connection abort
E/Mqtt: WS onFailure java.io.InterruptedIOException: executor
浏览 114提问于2020-01-10得票数 1
回答已采纳
我已经实现了mqtt使用服务器连接tcp套接字在我的机器上与蚊虫经纪人。我完全理解mqtt协议及其帧格式。我想在支持mqtt的webserver上发布我的数据。
我怎么能从这件事开始？
我不清楚websocket的概念。
我是否可以使用tcp实现websocket，或者是否有其他方法。我是否必须使用http在web套接字上实现mqtt作为通过web服务器发送数据？
由于http和mqtt使用不同的方法发送或接收数据。
我不想使用像paho这样的现成库。我是全新的这个套接字programming.any帮助或指南将非常感谢！
浏览 1提问于2018-05-23得票数 0
回答已采纳
对于MQTT在WebSocket上提供的额外功能与传统的MQTT与传统的MQTT在响应本机中提供的功能，我有点困惑。MQTT是否是浏览器的解决方案，以便实时接收事件，还是添加了一些我无法捕捉到的内容？
浏览 2提问于2020-03-21得票数 1
回答已采纳
我试图连接到的websocket客户端，但无法与服务器进行握手。
我的守则：
<html>
<head>
<title>test Ws mqtt.js</title>
</head>
<body>
<script src="//unpkg.com/mqtt@2.5.0/dist/mqtt.min.js"></script>
<script>
var options = {
clientId: 'ser
浏览 6提问于2017-03-24得票数 1
我正在运行一个RabbitMQ实例，它通过rabbitmq_web_mqtt插件在websockets上提供MQTT。
由于遗留的原因，我需要支持一个非默认的WebSocket网址。
我在文档中看到，可以通过{ port, 1234 }配置更改端口，但是我找不到任何方法来更改WebSocket URL。它当前设置为/ws的默认路径。
是否可以在不修改插件的情况下更改WebSocket URL？
浏览 9提问于2017-10-05得票数 2
回答已采纳
1回答
我正在构建一个AngularJS应用程序，并使用Paho JavaScript客户端通过web套接字连接到MQTT (test.mosquitto.org)。这个很好用。我想通过直接的MQTT连接到MQTT代理(为了完整地支持没有启用websockets的代理)。
由于Paho客户端不支持直接MQTT，所以我尝试了mqtt.js (browserMqtt.js)的浏览器序列化版本。
下面是我代码中的主要行：
//var options = { host: "test.mosquitto.org", port: 8080 }; //works!
var options = { h
浏览 7提问于2017-03-12得票数 5
回答已采纳
1回答
我正在使用mqtt.js从mqtt服务器接收websocket，订阅工作正常，但我需要通过更改websocket的配置来动态地将订阅更改为主题，问题是更改配置后，我开始接收来自新主题和旧主题的消息，即使我执行client.unsubscribe()，旧的侦听器仍保持活动状态。 有没有办法删除旧的lister或停止旧的websocket，只保留新的websocket，下面是代码的一个片段： import React, { Component } from 'react'
import mqtt from 'mqtt';
var options = {
浏览 41提问于2020-11-11得票数 0
2回答
请帮助我使用esp8266 12e连接亚马逊云联网服务。我正在使用aws-mqtt-websocket示例，但我无法连接到AWS IOT。代码如下，我得到的错误是：please start sntp first ! error connection to the websocket server。
#include <Arduino.h>
#include <Stream.h>
#include <ESP8266WiFi.h>
//AWS
#include "sha256.h"
#include "Utils.h"
#in
浏览 1提问于2017-02-07得票数 3
2回答
你好，我是所有这些IOT的新手，我希望能够使用作为我们的代理，通过mqtt发送和接收来自Arduino的数据。为了连接，我使用了以下代码：
import React, { Component } from 'react';
var mqtt = require('mqtt');
var options={
clientId:"mqttjs01",
username:"user",
password:"password",
clean:true};
var client =
浏览 0提问于2020-12-13得票数 0
回答已采纳
我在Ubuntu EC2上安装了一个emqx broker。 ? 当我尝试通过带有IP地址的websocket连接到emqx时，它工作得很好。 ? 但是当我使用子域时，连接失败。我的Apache配置是 <VirtualHost *:80>
ServerName subdomain.example.com
ServerAlias subdomain.example.com
ServerAdmin admin@domain.in
RewriteEngine On
#RewriteCond %{REQUEST_URI} ^/socket.io
浏览 20提问于2020-04-21得票数 0
我管理一个启用了MQTT和WebSocket MQTT的WebSocket代理。在测试服务器时，我们无意中将客户机的最后遗嘱和遗嘱标记为retain = true。这会产生意想不到的后果，例如当客户端连接到LWT主题时总是接收LWT消息。这也会在应用程序中产生下游问题。
管理控制台中没有显示排队的消息，即使它们在通过MQTT连接时会出现。过了一段时间，LWT消息清除了，一切都恢复了正常。当这种情况发生时，我仍然无法从代理中识别和手动清除保留的MQTT消息。
如何查看和清除RabbitMQ中保留的所有MQTT消息(和LWT消息)？
浏览 6提问于2017-10-03得票数 1
回答已采纳
我有这个mosquitto.config
listener 1885
allow_anonymous false
listener 9001 127.0.0.1
protocol websockets
user manish
auth_opt_backends postgres
auth_plugin /etc/mosquitto/auth-plug.so
auth_opt_dbname mqtt
#auth_opt_host localhost
#auth_opt_port 5432
auth_opt_user postgres
auth_opt_pass 123
auth_opt_user
浏览 7提问于2016-03-11得票数 2
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
回答已采纳
我正试图使用Paho在Blazor中的websocket客户端订阅服务器上实现mqtt。问题在于它坚持使用wss而不是ws，并在连接时抛出ERR_SSL_PROTOCOL_ERROR错误。
下面是一个简化的代码块：
var mqtt;
var host = "api.mydomainexample.com";
var port = 1884;
function onConnect(){
console.log("connected ! Now listening for messages ..");
mqtt.subscribe("someT
浏览 8提问于2022-07-28得票数 0
2回答
我在Chrome中运行的SPA中使用paho-mqtt库，并使用示例代码调用connect，得到两个交替的错误 var client = mqtt.connect('mqtts:mqtt.ably.io', {
keepalive: 30,
username: 'keyPartA1.artA2',
password: 'keyPartB',
port: 8883
}); 错误重复出现，并不总是以相同的顺序出现。 stream.js?553e:64 WebSocket connection to 'ws://mqtt.ab
浏览 45提问于2020-01-25得票数 0
回答已采纳
我很难让HAProxy与RabbitMQ的Web (通过Web的MQTT )一起工作。我尝试了一些配置和教程，但没有成功(、、)。也尝试过设置HAProxy和，但没有成功。
我真的很想在这个问题上使用HAProxy，但是我很难使用它。
我的意图是使用浏览器中的Javascript Paho MQTT客户端连接到RabbitMQ网络套接字MQTT代理，其中HAProxy将使用所提供的TLS/SSL证书加密http/ws连接(也称为SSL/TLS卸载)。
当试图使用HAProxy打开安全的websocket连接时，浏览器将获得一个HTTP1.1 503服务不可用响应
RabbitMQ服务器正在本地
浏览 18提问于2020-03-27得票数 1
我们在后端有一个Mqtt代理，它是用来通过WebSocket接受连接的。当我直接连接到这台机器时，一切都正常。但是我们想通过企业集成商传送所有的呼叫。我似乎不能让这件事正常运作。后端websocket监听的是路径，而不是根(例如: machine:9999/api/mqtt)。出于测试目的，后端Mqtt代理没有实现安全性。它接受所有的连接，所有的连接都可以订阅和发布。
更改axis.xml
<transportReceiver name="mqtt" class="org.apache.axis2.transport.mqtt.MqttListener"&
浏览 0提问于2018-04-18得票数 1
回答已采纳
我有一个域x.com，它正在运行一个web应用程序--有一个MQTT服务器运行在子域mqtt.x.com上，websockets / wss都设置好了，
使用Chrome：
如果我转到，并在控制台中运行它：
let ws = new WebSocket('wss://mqtt.x.com')
我得到以下错误：
WebSocket connection to 'wss://mqtt.x.com/' failed:
如果我转到一个完全不同的域(如stackoverflow.com)并运行该命令，它可以正常工作。
在firefox/opera/edge中，没有错误，而
浏览 12提问于2022-03-21得票数 0
我想用Javascript连接一个MQTT代理，以便订阅一个主题并发布消息。连接需要通过端口1883上的tcp完成。我正在使用MQTT.js库。前端是angularjs。下面的示例是MQTT.js页面中的示例，但无法实现连接。有人能帮帮忙吗？
通过index.html连接：
<script src="../node_modules/mqtt/browserMqtt.js"></script>
连接代码：
var client = mqtt.connect('url.com:1883',{clientId :'client1'
浏览 264提问于2019-06-10得票数 0
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
1回答
我正在创建一个python3龙卷风web服务器，它可以侦听MQTT代理，每当从它听到新消息时，通过网络套接字向连接的浏览器广播它。然而，龙卷风似乎不喜欢从与IOLoop.current()不同的线程调用它的API，而且我无法找到另一个解决方案.
我已经试过写一些代码了。我已经将整个MQTT客户机(在本例中称为PMCU )放在一个分离的线程上，该线程循环并侦听MQTT通知。
def on_pmcu_data(data):
for websocket_client in websocket_clients:
print("Sending websocket mess
浏览 1提问于2019-04-26得票数 0
我试图让Aedes作为一个MQTT代理和Websocket服务器工作。根据那位医生的说法：我应该理解什么。理想情况下，如果是websocket客户端或mqtt客户端，我希望侦听器启动任何内容。
是否可以做这样的事情：
server.broadcast('foo/bar'，{data:''})
所有客户端，websockets和mqtt都收到消息了吗？文档不是很清楚，我很惊讶websocket流被使用了。是很低的lvl对吗？
这里有一些服务器端代码：
const port = 1883
const aedes = require('aed
浏览 2提问于2020-03-11得票数 1
回答已采纳
我正在尝试使用Paho、MQTT Javascript客户端连接IBM平台，如下面的示例代码所述。
var client = new Messaging.Client("myOqgId.messaging.internetofthings.ibmcloud.com", 8883, "myclientid_" + parseInt(Math.random() * 100, 10));
//Gets called if the websocket/mqtt connection gets disconnected for any reason
clie
浏览 1提问于2017-04-06得票数 6
1回答
我需要通过websocket连接到代理。
<script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.min.js" type="text/javascript"></script>
<script>
// Create a client instance
client = new Paho.MQTT.Client("broker.hivemq.com", 8000, "" , "
浏览 8提问于2020-06-08得票数 0
回答已采纳
使用蔚蓝-物联网设备sdk为节点工作在一个独立的节点程序。当试图在React应用程序中使用相同的节点代码时，与IoT集线器的连接将失败“iothub errorcode: InvalidProtocolVersion”，并出现以下错误：
stream.js:61 WebSocket connection to 'wss://my-iothub.azure-devices.net/' failed: Error during WebSocket handshake: Unexpected response code: 400
App.js
var Protocol = requi
浏览 5提问于2019-10-02得票数 0
我有一个案例场景，其中健康传感器将流发送到siddhi-android，因为我没有真正的健康传感器，所以我使用了事件模拟器，现在问题是我应该为这个场景使用哪个输入适配器，以及为什么。
Email Event Receiver
File-tail Event Receiver
HTTP Event Receiver
JMS Event Receiver
Kafka Event Receiver
MQTT Event Receiver
SOAP Event Receiver
WebSocket Event Receiver
WebSocket Local Event Receiver
WSO2Ev
浏览 2提问于2018-01-22得票数 0
回答已采纳
我有一个主应用程序，它初始化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
我有一个用Chrome打开的test.html文件：
<html>
<head>
<script src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>
</head>
<body>
<script>
var client = mqtt.connect('ws://broker.hivemq.com:8000')
client.subscribe("mqtt/d
浏览 7提问于2020-01-09得票数 0
回答已采纳
我需要解决上游的很多数据每秒钟。通过无线(WiFi)或乙烯网络每秒200 200kBytes。
我选择了MQTT，因为对于与需要少量代码占用的远程位置的连接很有用，而且/或网络带宽是非常高的。
MQTT在网络带宽的使用上比Socket.io更好？或者，MQTT是一个很好的实时上传/发布解决方案。MQTT可用于与socket.io(WebSocket)相同的绘图系统。
浏览 1提问于2019-03-04得票数 4
2回答
如何每隔X毫秒执行一次函数？
、、、、
我对javascript和node非常陌生，目前正在开发一个node.js应用程序，该应用程序使用express和mongoDB，其想法是通过web钩子、websocket和mqtt收听一些第三方服务，并将所有数据存储到mongoDB中。
但是我有一个小问题，一些第三方应用程序经常给我发送数据，例如，mqtt流每秒发送大约2条消息，我每分钟只需要存储其中的一条消息。
这就是我将mqtt实例转换为app.js的方式。
var mqttHandler = require('./mqtt/mqtt_handler'); //mqtt
var mqttClient = new mqtt
浏览 1提问于2018-10-15得票数 0
回答已采纳
因此，我使用的是库，如果我想连接一个无websocket代理，我会收到以下错误消息：
到'ws://iot.eclipse.org:1883/mqtt‘的WebSocket连接失败: WebSocket握手时出错: net::ERR_CONNECTION_RESET
那么，是否有可能在无websockets上连接呢？
浏览 1提问于2017-03-06得票数 0
回答已采纳
我是在我的第一个mqtt项目，我的项目是好的，在当地。但是当我把它部署到heroku的时候，它失败了。这是一个错误：
混合内容:在'‘处的页面是通过HTTPS加载的，但试图连接到不安全的WebSocket端点'ws://mqtt.eclipse.org/mqtt’。此请求已被阻止；此端点必须在WSS上可用。k._doConnect @ mqttws31.min.js:36 k.connect @ mqttws31.min.js:31 I.connect @ mqttws31.min.js:65 (匿名)@ app.js:10
我在app.js文件中声明了客户端。
浏览 2提问于2020-02-21得票数 0
回答已采纳
我需要连接到MQTT服务器，获取一些消息，然后重新连接(断开连接并再次连接)。 我使用的是sgcWebSockets v4.2.1和官方连接代码： // Create websocket client and set server options
oClient := TsgcWebSocketClient.Create(nil);
oClient.Host := 'wss://myserver';
oClient.Port := 443;
// Create MQTT protocol and assign to websocket client
oMQTT := Tsg
浏览 62提问于2019-02-18得票数 0
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
