mqtt_udp

MQTT/UDP

UDP上的MQTT的Simpified版本：網絡是經紀人！

注意其他回購：https：//gitverse.ru/dzavalishin/mqtt_udp

參見俄語版本 /存在

MQTT是一種可愛的簡單協議，非常適合物聯網和類似內容。

但這可能更簡單，並且仍然非常有用：MQTT/UDP只是在UDP上廣播的MQTT發布數據包。

MQTT/UDP是

• 非常簡單
• 非常快，最小的潛伏期
• 不包括經紀人（單點失敗）
• 降低網絡流量（每個套管完全發送給全部一次）
• 合理可靠的（如果我們將其用於傳感器，通常每隔幾秒鐘左右重新安裝數據）
• 即使在無法支持TCP的硬件上也可以支持 - 實際上，只需要發送UDP
• 零配置 - 傳感器節點不需要設置，它只是廣播數據。 （而且，如果您仍然需要它，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集成和測試的工具：

• GUI工具以顯示工具/查看器目錄中傳輸的數據的當前狀態；另請參見查看器幫助頁面。
• python3/示例目錄中的隨機數據生成器（Random_to_udp.py）
• 發送/檢查工具，以序列編號的數據包。請參閱seq_storm_send.py和seq_storm_check.py in lang/python3/示例目錄目錄
• 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軟件包

爪哇

發送數據：

 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 )

下載Luarock

去

有一個GO語言實現，請參閱Lang/GO以獲取詳細信息