Janus MQTT प्रॉक्सी एक सेवा है जिसे मैंने गो पर एक शौक परियोजना के रूप में लिखा है। वह एमक्यूटीटी ब्रोकर से जुड़ता है और सभी घटनाओं के लिए सब्सक्राइब करता है, और क्लाइंट, बदले में, प्रॉक्सी से कनेक्ट होते हैं और एमक्यूटीटी ब्रोकर के साथ उसके साथ संवाद करते हैं।

यह आपको इसकी अनुमति देता है:

• विभिन्न विषयों के लिए ग्राहक की पहुँच को प्रतिबंधित करें। जिसमें रीड एंड राइट एक्सेस को अलग से शामिल करना शामिल है;
• विषय के नाम और ईवेंट सामग्री को regexp s से बदलें।

क्यों जरूरी है?

MQTT . , - 1 /my/lamp/on, - On /my/lamp. , , . , .

Janus MQTT : , , MQTT- . / , .

. , /light/main. «, — , — , , ». , .

, , , . Janus MQTT / , . , , , — .

Janus MQTT

, , — , .

Janus MQTT , . — :

broker_to_client: #       

  #    MQTT discovery.
  - topic: ^/devices/wb-gpio/controls/LIGHT_([^/]*)/meta/type$
    template: /homeassistant/light/{{.f1}}/config
    val_map:
      switch: >-
        {
        "command_topic":"/light/{{.f1}}/state",
        "state_topic":"/light/{{.f1}}/state",
        "name":"{{.f1}}"
        }

  - topic: ^/devices/wb-gpio/controls/LIGHT_([^/]*)$
    template: /light/{{.f1}}/state
    val_map: {0: OFF, 1: ON}

client_to_broker: #       

  - topic: ^/light/([^/]*)/state$
    template: /devices/wb-gpio/controls/LIGHT_{{.f1}}/on
    val_map: {OFF: 0, ON: 1}

, . .

, Home Assistant , .

MQTT discovery : Wiren Board , . , . switch. retained — . JSON-, , MQTT discovery .

Janus MQTT

Go paho.mqtt.golang. MQTT- . , , MQTT-.

: , , . . .. MITM.

:

• QoS — 2 1 , ;
• - QoS message_id, uint16 ;
• Janus MQTT . , ;
• , in-memory retained-.

MQTT- client.serveIncoming, TCP-. MQTT- :

• ConnectPacket — Connack ;
• SubscribePacket — Suback retained-;
• UnsubscribePacket — Unsuback ;
• PingreqPacket — Pingresp;
• PublishPacket — ;
• PubackPacket, PubrelPacket, PubcompPacket ;
• DisconnectPacket — .

QoS. MQTT QoS:

• QoS 0: ;
• QoS 1: ;
• QoS 2: .

, 1 2 , , , ( 2 , QoS 1, ).

publish- QOS=2

publish- QOS=2

Janus MQTT :

• Wiren Board — ;
• Home Assistant — ( );
• Yandex2mqtt — .

Wiren Board

. . MQTT-.

Yandex2mqtt

oAuth API . . munrexio, bawdiest , .

, :

$ mosquitto_sub -h localhost -u yandex2mqtt -P yandex2mqtt -t '#' -v
/light/LIVING_TABLE/state 1

Home Assistant

. . , .

Home Assistant , , .

, Home Assistant MQTT Discovery — , Home Assistant MQTT. JSON-, .

Home Assistant :

mqtt:
  username: !env_var MQTT_USER
  password: !env_var MQTT_PASS
  broker: !env_var MQTT_HOST
  discovery: true
  discovery_prefix: /homeassistant

Janus MQTT

Janus MQTT Home Assistant . 100 , 17 , 6 (/) 5 . . .

Docker

NanoPi docker-compose.yml.

, , , .
10 M. Golang!

/ :
https://github.com/phoenix-mstu/janus-mqtt-proxy.

docker-compose :
https://github.com/phoenix-mstu/smart_home/tree/master/raspberry.

, : 52.59.242.204:26927 ( ), / — habr/habr, — MQTT, . . , :

1. ( ).
2. .

- — , . , , . , DoS- — . .