背景 我一直在玩MQTT的一個項目，遇到了一個奇怪的問題。我使用paho作爲我的MQTT客戶端，並使用VerneMQ作爲代理。 VerneMQ代理服務已啓動並正在運行，我可以通過runnnig netstat來確認，我可以看到127.0.0.1:1883條目處於LISTENING模式。 這是我的客戶端代碼： public class Producer implements MqttCallback
我有以下代碼爲mqtt客戶端從代理接收消息。 如果客戶端與代理斷開連接，則客戶端嘗試再次使用connect()調用與代理進行連接。我已閱讀paho文檔說loop_start()將處理與經紀人的重新連接。請讓我知道是否正確使用connect()呼叫與經紀人重新連接，或讓其自行處理loop_start()。 import paho.mqtt.client as mqtt
import json
i
我從線程「Python MQTT連接只有有限的時間」下面的python腳本。 #!/usr/bin/python
import sys
import paho.mqtt.client as mqtt
import time
def on_message(client, userdata, msg):
if msg.topic == "foo/bar":
pri
我正在使用paho.mqtt.client。 下面是代碼的簡化版本，但它仍然顯示問題。 # -*- coding: utf-8 -*-
import sys
import os
import time
import logging
from time import sleep
import paho.mqtt.client as mqtt
mqtt_server_ip =