python 中基于 WebSocket 的 MQTT

MQTT over websocket in python

python是否支持使用端口 8080 订阅 mqtt 代理

 import sys
 import paho.mqtt.client as mqtt

 def on_connect(mqttc, obj, flags, rc):
     print("rc: "+str(rc))

 def on_message(mqttc, obj, msg):
     print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))

 def on_publish(mqttc, obj, mid):
     print("mid: "+str(mid))

 def on_subscribe(mqttc, obj, mid, granted_qos):
     print("Subscribed: "+str(mid)+" "+str(granted_qos))

 def on_log(mqttc, obj, level, string):
     print(string)

 mqttc = mqtt.Client()   
 mqttc.on_message = on_message
 mqttc.on_connect = on_connect
 mqttc.on_publish = on_publish
 mqttc.on_subscribe = on_subscribe
 mqttc.connect("test.mosquitto.org", 8080, 60)
 mqttc.subscribe("test/iot", 0)

 mqttc.loop_forever()

我无法连接此代码。 Mosquitto 在端口 8080 上支持 websocket,但是这个 paho 库不支持它。 python 的任何解决方案? 我在 windows 10.

上使用 python 2.7

不,Paho 库的 Python 版本不支持基于 Websockets 的 MQTT。

事实上,我认为唯一支持基于 Websockets 的 MQTT 的本机客户端(不在浏览器中)MQTT 库是 NodeJS 模块 (https://www.npmjs.com/package/mqtt)

Paho MQTT 模块几天前引入了 websocket 支持。我认为它尚未发布,但您可以使用

从 Linux 分支下的 master 安装
pip install git+git://github.com/eclipse/paho.mqtt.python.git

也适用于 windows。 (感谢评论中的信息)

您可以通过连接

使用 websockets 作为传输
mqttc = mqtt.Client(transport="websockets")

更新:

如果你因为还需要连接浏览器客户端(例如MQTT.js)而尝试在python客户端使用websocket协议,那么你也可以配置mosquitto来监听websockets 和正常的 mqtt 协议.

只需创建一个配置文件,例如

/etc/mosquitto/mosquitto.conf

内容如下:

listener 1883
protocol mqtt

listener 9001
protocol websockets

然后你就可以运行蚊子用

mosquitto -c /etc/mosquitto/mosquitto.conf

您应该会看到类似的输出:

1469015320: mosquitto version 1.4.8 (build date 2016-05-3112:07:40+0200) starting
1469015320: Config loaded from /etc/mosquitto/mosquitto1.conf.
1469015320: Opening ipv4 listen socket on port 1883.
1469015320: Opening ipv6 listen socket on port 1883.
1469015320: Opening websockets listen socket on port 9001.

然后您的 python 客户端连接到端口 1883,浏览器客户端连接到 9001

您可以使用 what-mqtt browser client 来测试 websocket 侦听器。只需将其指向 ws://localhost:9001

从 2 月到现在,paho.mqtt.python 代码库已得到修复。只需按照 Fl0v0 的建议添加 transport='websockets',它就可以正常工作。以下是订阅 $SYS/ 下的所有内容或所有内容的完整代码。测试的代码在 2016 年 6 月 3 日提交散列 e56f913 的主分支上。

#!/usr/bin/python

import sys
import paho.mqtt.client as mqtt

def on_connect(mqttc, obj, flags, rc):
    print("rc: "+str(rc))

def on_message(mqttc, obj, msg):
    print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))

def on_publish(mqttc, obj, mid):
    print("mid: "+str(mid))

def on_subscribe(mqttc, obj, mid, granted_qos):
    print("Subscribed: "+str(mid)+" "+str(granted_qos))

def on_log(mqttc, obj, level, string):
    print(string)

mqttc = mqtt.Client(transport='websockets')   
mqttc.on_message = on_message
mqttc.on_connect = on_connect
mqttc.on_publish = on_publish
mqttc.on_subscribe = on_subscribe

mqttc.connect("test.mosquitto.org", 8080, 60)

mqttc.subscribe("#", 0)
#mqttc.subscribe("$SYS/#", 0)

mqttc.loop_forever()

更新:通过从一个版本的 Cygwin(不是 cygwin python尽管)。主题 "#""$SYS/#" 的 None 返回任何已发布的消息。

相反,pub 或 sub to solid topics 的工作原理如下所示。补丁 paho.mqtt.python examples/pub-single.pyexamples/sub-simple.py。然后在一个终端中 运行 sub-simple.py 。 运行 pub-single.py 在另一个终端,两次。订阅者终端将打印出发布者发布的两条消息。

补丁 examples/pub-single.py:

-publish.single("paho/test/single", "boo", hostname="test.mosquitto.org")
+publish.single("/HelloWorld", "boo", hostname="test.mosquitto.org",
+               port=8080, transport='websockets')

examples/sub-simple.py 的补丁:

-topics = ['#']
+topics = ['/HelloWorld']

-m = subscribe.simple(topics, hostname="iot.eclipse.org", retained=False, msg_count=2)
+m = subscribe.simple(topics, hostname="test.mosquitto.org",
+                         retained=False, msg_count=2,
+                         port=8080, transport='websockets')