MQTT.js 无法建立本地主机代理连接

MQTT.js unable to make localhost broker connection

我在 React Native 移动应用程序上工作。我使用 MQTT.js to establish connection with a broker. As a first test I made a connection with the Mosquitto public broker。我设法只连接了 WebSockets 端口(8080 和 8081)。不幸的是,与我的本地主机 Mosquitto 代理的连接失败,没有错误。

首先,我在 Linux 计算机上安装了 Mosquitto 和 Node-RED。我分别从 $ mosquitto -v$ node-red 开始。在 Node-RED 上,我创建了我的第一个流:inject node 连接到 mqtt publishermqtt subscriber 连接到 debug node。 mqtt 发布者和订阅者在同一个主题上,并成功连接到我的 Mosquitto localhost 代理。我部署了:有效。

如果我尝试连接我的 React 应用程序:

let mqtt = require('mqtt')
let client = mqtt.connect('mqtt://localhost:1883')
console.log('client', client)

client.on('connect', function () {
    console.log('connected')
})

client.on('error', function (error) {
    console.log('error', error)
})

它 运行 但我的 Mosquitto 代理没有收到任何新连接。 console.log('client', client) return 这个:

'client', 
 { options: 
   { protocol: 'ws',
     slashes: true,
     auth: null,
     host: 'localhost:1883',
     port: 1883,
     ...
   }
}

protocol: 'ws' 代表 WebSockets,但我的 Mosquitto 代理使用 IP 协议,所以我在 /etc/mosquitto/conf.d 文件夹中创建了一个 protocol.conf 并写下行 protocol websockets。然后,当我重新启动 Mosquitto $ mosquitto -v -c /etc/mosquitto/conf.d/protocol.conf 时,它显示:

mosquitto version 1.6.4 starting
Config loaded from /etc/mosquitto/conf.d/protocol.conf.
Opening websockets listen socket on port 1883.

我重新编译我的 React 应用程序:不起作用。

除非console.log('client', client)我的日志是空的,任何错误。

我预计至少会出现连接错误,但即使是 Mosquitto 代理也没有收到连接尝试。

localhost 表示自己 - 正在执行引用 localhost 的代码的计算机。在 React 应用程序中,这将是 运行 正在加载 React 应用程序的网络浏览器的计算机,我敢打赌这不是 运行 你的 Mosquitto 代理的计算机。

您需要找出作为 运行 代理的计算机的 IP 地址并使用它而不是 localhost。那不会是 127.0.0.1,它是 localhost 的 IP 地址,意思是一样的,也会有同样的问题。它可能看起来像 10.0.x.x192.168.x.x.

您也不应该将端口 1883 用于 Web 套接字上的 MQTT。它可以工作,但 1883 是默认的 MQTT over TCP 端口。如果您没有更改 Mosquitto 的默认配置,它将已经在端口 1883 上侦听。端口 8883 通常用于 Web 套接字上的 MQTT - 确切的端口号并不重要,重要的是确保它尚未被使用。它现在可能正在运行,因为您只添加了 protocol websockets 行。如果你永远不会将代理用于 websockets 以外的任何东西,那么你可以安全地忽略这部分,但如果你想要使用 MQTT over TCP 连接到它,端口 1883 上的 websockets 将很快变得混乱。

Edit @hardlib 有一个很好的建议,指出如果网页由同一台计算机提供,而 MQTT 代理是 运行 你可以使用调用 location.host 以获取 server/broker.

的名称或 IP 地址