mqtt_udpダウンロードmqtt_udpソースコードダウンロード

mqtt_udp

その他のカテゴリー

Packages

ダウンロード

MQTT/UDP

simpifiedバージョンのMQTTを介してUDP：ネットワークはブローカーです！

メモその他のレポ：https：//gitverse.ru/dzavalishin/mqtt_udp

ロシア語バージョン /陶器を参照してください

MQTTは、IoTなどに適したかわいいシンプルなプロトコルです。

しかし、それはさらに単純であり、それでも非常に使いやすいことがあります。MQTT/UDPは、UDPを介して放送されるMQTT Publishパケットです。

MQTT/UDPはです

非常にシンプルです
非常に高速で、最小限のレイテンシ
ブローカーを除外します（これは単一の失敗ポイントです）
ネットワークトラフィックを低下させる（各充電はすべてに1回送信されます）
合理的に信頼性が高い（センサーに使用する場合、通常は数秒ごとにデータを再送信します）
TCPをサポートできないハードウェアでもサポートできます - 実際、UDP送信のみが必要です
Zero Configuration-センサーノードにはセットアップが必要ありません。データをブロードキャストするだけです。（そして、まだ必要な場合、MQTT/UDPはネットワーク上のリモート構成をサポートしています。）
デジタル署名をサポートします

さらに読むために

mqtt/udp wiki
ドキュメント

このリポジトリには含まれています

いくつかの一般的なプログラミング言語での単純なMQTT/UDP実装。
Pytonで最も単純なMQTT/UDPブリッジの実装。
MQTT/UDPからOpenHabにデータを送信するツール
MQTT/UDPトラフィック（ツール/ビューアー）をダンプするデバッグアプリケーション。
他のツールとユーティリティ

プロジェクトを支援したい場合

お気軽に：

お気に入りのプログラミング言語に実装を追加します
古典的なMQTTプロトコルへのブリッジを書く（ここにPythonで書かれた非常にシンプルなプロトコルがあります）
MQTT/UDPサポートを使用して、お気に入りのMQTTブローカーまたはIoTシステム（OpenHab？）を拡張します
MQTT仕様に対するMQTT/UDP仕様/実装を確認してください。可能な場合は互換性がなければなりません。

本当に簡単です。

MQTT/UDPを回避する理由

長いペイロードを転送する必要があります。一部のシステムでは、UDPデータグラムのサイズが制限されています。
データグラムが確実に配信されたかどうかを知る必要があります。 UDPでは不可能です。ただし、信頼できる配信サブシステムは現在開発中であり、まもなく利用可能になります。

MQTT/UDPを拡張する方法

データのスプーフィングを防ぐために、パケットに何らかの署名を追加することは合理的であると思われます。実際、それはすでにJavaの実装のために行われています、CとPythinはまもなく来るでしょう。
ブロードキャストは、データを送信する最良の方法ではありません。マルチキャストははるかに優れています。マルチキャストはIoT OSまたはモニターではあまりサポートされていませんが。

迅速な開始手順

ローカルディスクへのクローンリポジトリ
Howtoファイルを読んでください

サポートツール

このリポジトリには、MQTT/UDPの統合とテストをサポートするツールが含まれています。

TOULS/VIEWERディレクトリに送信されるデータの現在の状態を表示するGUIツール。ビューアーヘルプページも参照してください。
Python3/Examples Directoryのランダムデータジェネレーター（random_to_udp.py）
番号付きのパケットのためにツールを送信/チェックします。 lang/python3/examplesディレクトリのseq_storm_send.pyおよびseq_storm_check.pyを参照してください
wireshark解離器lang/lua/wiresharkディレクトリのネットワーク上のプロトコルデータを見る

コードの例

Python

データの送信：

 import mqttudp . engine

if __name__ == "__main__" :
    mqttudp . engine . send_publish ( "test_topic" , "Hello, world!" )

データを聞く：

 import mqttudp . engine

def recv_packet ( ptype , topic , value , pflags , addr ):
    if ptype != "publish" :
        print ( ptype + ", " + topic + " t t " + str ( addr ) )
        return
    print ( topic + "=" + value + " t t " + str ( addr ) )

if __name__ == "__main__" :
    mqttudp . engine . listen ( recv_packet )

PYPIパッケージをダウンロードします

Java

データの送信：

 PublishPacket pkt = new PublishPacket ( topic , value );
pkt . send ();

データを聞く：

 PacketSourceServer ss = new PacketSourceServer ();
ss . setSink ( pkt -> { System . out . println ( "Got packet: " + pkt ); });

jarをダウンロードします

c

データの送信：

 int rc = mqtt_udp_send_publish ( topic , value );

データを聞く：

 int main ( int argc , char * argv [])
{
    ...

    int rc = mqtt_udp_recv_loop ( mqtt_udp_dump_any_pkt );

    ...
}

int mqtt_udp_dump_any_pkt ( struct mqtt_udp_pkt * o )
{

    printf ( "pkt %x flags %x, id %d" ,
            o -> ptype , o -> pflags , o -> pkt_id
          );

    if ( o -> topic_len > 0 )
        printf ( " topic '%s'" , o -> topic );

    if ( o -> value_len > 0 )
        printf ( " = '%s'" , o -> value );

    printf ( "n" );
}

ルア

データの送信：

 local mq = require " mqtt_udp_lib "
mq . publish ( topic , val );

データを聞く：

 local mq = require " mqtt_udp_lib "

local listener = function ( ptype , topic , value , ip , port )
    print ( " ' " .. topic .. " ' = ' " .. val .. " ' " .. "	from: " , ip , port )
end

mq . listen ( listener )