我在网络和证券交易所搜索了我在连接 MQTT 时遇到的这种奇怪行为的解释。但我找不到类似的案例,我想了解问题出在哪里。
因此,我在 Raspberry Pi 上设置了一个 Mosquitto MQTT 代理来侦听端口 1883。我还在路由器上设置了端口转发,这样我就可以从家庭网络外部访问 Pi(尽管我可以重现该行为)下面还有像
broker.hivemq.com
这样的公共服务器)。当我执行以下 Node.js 脚本时,我可以连接到代理并订阅和发布消息,它工作得很好:
const mqtt = require('mqtt')
const client = mqtt.connect('tcp://my.address.net:1883')
client.on('connect', () => {
console.log('Connected!')
client.subscribe("chat")
})
var readline = require('readline');
var rl = readline.createInterface({
input: process.stdin,
output: process.stdout,
terminal: false
});
rl.on('line', function(line){
client.publish('chat',line)
})
client.on('message', (topic, message) => {
console.log('>> '+message)
})
但是,当我省略
tcp://
协议并有
const client = mqtt.connect('my.address.net:1883')
作为主机地址,我没有得到连接,但也没有错误消息。该程序会一直挂起,直到我终止它。我不明白。 MQTT不是默认使用TCP吗?
这与我的客户或我的经纪人有关吗?这可能与我的系统(OSX)有关吗?
也许这与它无关,但是当我在Python中使用Paho MQTT包时,我得到了类似的行为,这对我来说实际上是更重要的情况,因为在这里我没有得到它根本就跑。这是我的代码:
import paho.mqtt.client as paho
def on_connect(client, userdata, flags, rc):
print("connected")
client.disconnect()
def on_disconnect(client, userdata, rc):
print("disconnected")
client = paho.Client()
client.on_connect = on_connect
client.on_disconnect = on_disconnect
client.connect("my.address.net", 1883)
使用这个没有协议的版本,我没有得到任何响应。程序运行一秒钟然后终止。如果我使用协议
client.connect("tcp://my.address.net", 1883)
我收到错误
socket.gaierror: [Errno 8] nodename nor servname provided, or not known
我不知道我错过了什么。
有人可以解释一下在地址中声明
tcp://
协议与省略它的区别吗?
这是两个问题。
对于 python 部分,python 客户端需要分别将主机和端口作为其连接参数。它不是 URI。因此没有 TCP//。
python 程序完全按照您的要求进行操作 - 连接,然后退出。如果您希望它执行其他操作,则必须在 connect 调用下添加更多代码。该代码是什么取决于您想要做什么,但是
loop_forever()
是一个好的开始。
另一个客户端需要 URI。我相信它使用 TCP/SSL 来区分普通连接和加密连接。
这两个库需要不同的东西。
NodeJS 库正在请求一个 URI,其中包括
由此可以轻松解析主机和端口。
Python 库明确要求 2 个独立的东西
这些被视为单独的变量。
这取决于不同的作者选择不同的方法来收集信息。