Python에서 websocket을 통한 MQTT

스밋 가르 다리 야

파이썬에서 포트 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에서 웹 소켓을 지원하지만이 paho 라이브러리는 작동하지 않습니다. 파이썬에 대한 해결책은 무엇입니까? Windows 10에서 Python 2.7을 사용하고 있습니다.

Fl0v0

Paho MQTT 모듈은 며칠 전에 웹 소켓 지원을 도입했습니다. 아직 릴리스되지 않은 것 같지만 Linux 브랜치의 마스터에서 다음을 사용하여 설치할 수 있습니다.

pip install git+git://github.com/eclipse/paho.mqtt.python.git

창문 아래에서도 작동합니다. (댓글의 정보에 감사드립니다)

다음과 연결하여 웹 소켓을 전송으로 사용할 수 있습니다.

mqttc = mqtt.Client(transport="websockets")

최신 정보:

브라우저 클라이언트 (예 : MQTT.js)도 연결해야하기 때문에 python 클라이언트와 함께 websocket 프로토콜을 사용하려는 경우 웹 소켓 및 일반 mqtt 프로토콜 을 수신하도록 mosquitto를 구성 할 수도 있습니다 .

예를 들어 구성 파일을 생성하십시오.

/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 브라우저 클라이언트 를 사용하여 websocket 리스너를 테스트 할 수 있습니다 . 그냥 가리켜ws://localhost:9001

이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.

침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제

에서 수정
0

몇 마디 만하겠습니다

0리뷰
로그인참여 후 검토

관련 기사

분류에서Dev

반응 네이티브에서 웹 소켓을 통한 MQTT 대 MQTT

분류에서Dev

STS 임시 자격 증명을 사용하는 Websocket을 통한 AWS IoT MQTT

분류에서Dev

MQTT 토픽을 사용한 ActiveMQ 스프링 통합

분류에서Dev

ServiceStack : WebSocket을 통한 서버 전송 이벤트 선택

분류에서Dev

Spring MVC + Mosquitto + MQTT 통합에서 메시지를받을 수 없음

분류에서Dev

SSL을 통한 WebSocket : Cloudflare

분류에서Dev

SSL을 통한 WebSocket : Cloudflare

분류에서Dev

Aedes와 동시에 Mqtt 및 Websocket

분류에서Dev

ngx-mqtt는 webapp을 통해 SSL / TLS mosquitto broker에 연결합니다.

분류에서Dev

Python Azure IoT Hub 클라이언트 SDK에서 mqtt 게시 메시지에 대한 QoS 수준 0을 설정하는 방법은 무엇입니까?

분류에서Dev

GPRS / HSDPA를 통한 MQTT 긴 폴링

분류에서Dev

WebSocket 연결을 통한 Spring SseEmitter

분류에서Dev

JSON 데이터는 MQTT Python을 통해 잘못된 형식을 수신합니다.

분류에서Dev

Python에서 목록을 통한 루프의 "백 로그"

분류에서Dev

Windows 8에서 OpenVPN을 통한 RDP

분류에서Dev

Chromebook에서 Crouton을 통한 Ubuntu 문제

분류에서Dev

VM에서 VPN을 통한 VNC

분류에서Dev

VM에서 VPN을 통한 VNC

분류에서Dev

cron을 통해 호출 될 때 MQTT Python이 Bash 스크립트를 시작할 수 없음

분류에서Dev

IoT를 통해 AWS Lambda와 웹 앱간에 MQTT 메시지의 안정성을 높이는 방법

분류에서Dev

TLS를 통한 MQTT (모스키토)-일부 프로그램의 인증서 오류

분류에서Dev

Paho MQTT 대 MQTT Paho Spring 통합

분류에서Dev

mqtt 용 WebSocket 실행 문제

분류에서Dev

Java에서 MQTT를위한 TLS / SSL 연결

분류에서Dev

mqtt 통신을 위해 역방향 프록시로 nginx 구성

분류에서Dev

Tornado에서 websocket을 통해 .png 또는 .jpg 파일을 전송하는 방법

분류에서Dev

중앙 집중식 통신 프로토콜로서의 MQTT

분류에서Dev

Python Websocket을 통해 타이머 기반 데이터 재생

분류에서Dev

CloudFormation을 사용하여 AWS Websocket API에 통합 응답 추가

Related 관련 기사

  1. 1

    반응 네이티브에서 웹 소켓을 통한 MQTT 대 MQTT

  2. 2

    STS 임시 자격 증명을 사용하는 Websocket을 통한 AWS IoT MQTT

  3. 3

    MQTT 토픽을 사용한 ActiveMQ 스프링 통합

  4. 4

    ServiceStack : WebSocket을 통한 서버 전송 이벤트 선택

  5. 5

    Spring MVC + Mosquitto + MQTT 통합에서 메시지를받을 수 없음

  6. 6

    SSL을 통한 WebSocket : Cloudflare

  7. 7

    SSL을 통한 WebSocket : Cloudflare

  8. 8

    Aedes와 동시에 Mqtt 및 Websocket

  9. 9

    ngx-mqtt는 webapp을 통해 SSL / TLS mosquitto broker에 연결합니다.

  10. 10

    Python Azure IoT Hub 클라이언트 SDK에서 mqtt 게시 메시지에 대한 QoS 수준 0을 설정하는 방법은 무엇입니까?

  11. 11

    GPRS / HSDPA를 통한 MQTT 긴 폴링

  12. 12

    WebSocket 연결을 통한 Spring SseEmitter

  13. 13

    JSON 데이터는 MQTT Python을 통해 잘못된 형식을 수신합니다.

  14. 14

    Python에서 목록을 통한 루프의 "백 로그"

  15. 15

    Windows 8에서 OpenVPN을 통한 RDP

  16. 16

    Chromebook에서 Crouton을 통한 Ubuntu 문제

  17. 17

    VM에서 VPN을 통한 VNC

  18. 18

    VM에서 VPN을 통한 VNC

  19. 19

    cron을 통해 호출 될 때 MQTT Python이 Bash 스크립트를 시작할 수 없음

  20. 20

    IoT를 통해 AWS Lambda와 웹 앱간에 MQTT 메시지의 안정성을 높이는 방법

  21. 21

    TLS를 통한 MQTT (모스키토)-일부 프로그램의 인증서 오류

  22. 22

    Paho MQTT 대 MQTT Paho Spring 통합

  23. 23

    mqtt 용 WebSocket 실행 문제

  24. 24

    Java에서 MQTT를위한 TLS / SSL 연결

  25. 25

    mqtt 통신을 위해 역방향 프록시로 nginx 구성

  26. 26

    Tornado에서 websocket을 통해 .png 또는 .jpg 파일을 전송하는 방법

  27. 27

    중앙 집중식 통신 프로토콜로서의 MQTT

  28. 28

    Python Websocket을 통해 타이머 기반 데이터 재생

  29. 29

    CloudFormation을 사용하여 AWS Websocket API에 통합 응답 추가

뜨겁다태그

보관