ดาวน์โหลด mqtt_udp - ดาวน์โหลดซอร์สโค้ด mqtt

mqtt_udp

หมวดหมู่อื่นๆ

Packages

ดาวน์โหลด

MQTT/UDP

MQTT เวอร์ชัน Simpified ผ่าน UDP: Network is Broker!

หมายเหตุ repo อื่น ๆ : https://gitverse.ru/dzavalishin/mqtt_udp

ดูเวอร์ชันภาษารัสเซีย / рускаяверсиสาธารณะ

MQTT เป็นโปรโตคอลที่เรียบง่ายน่ารักเหมาะสำหรับ IoT และสิ่งที่คล้ายกัน

แต่มันอาจจะง่ายกว่าและยังคงใช้งานได้มาก: MQTT/UDP เป็นเพียงการเผยแพร่แพ็คเก็ต MQTT ที่ออกอากาศผ่าน UDP

MQTT/UDP คือ

ง่ายมาก
แฝงที่รวดเร็วและน้อยที่สุด
ไม่รวมโบรกเกอร์ (ซึ่งเป็นจุดเดียวของความล้มเหลว)
ลดทราฟฟิกเครือข่าย (การปลอมแปลงแต่ละครั้งจะถูกส่งไปยังทั้งหมด) ทั้งหมด)
เชื่อถือได้อย่างสมเหตุสมผล (ถ้าเราใช้เป็นเซ็นเซอร์ซึ่งมักจะส่งข้อมูลทุกสองสามวินาทีหรือมากกว่านั้น)
สามารถรองรับได้แม้ในฮาร์ดแวร์ซึ่งไม่สามารถรองรับ TCP - อันที่จริงแล้วจำเป็นต้องมีเฉพาะการส่ง UDP
Zero Configuration - โหนดเซ็นเซอร์ไม่จำเป็นต้องตั้งค่า แต่เพียงแค่ออกอากาศข้อมูล (และหากคุณยังต้องการ MQTT/UDP รองรับการกำหนดค่าระยะไกลผ่านเครือข่าย)
รองรับลายเซ็นดิจิตอล

สำหรับการอ่านเพิ่มเติม

mqtt/udp wiki
เอกสาร

ที่เก็บนี้มี

การใช้งาน MQTT/UDP อย่างง่ายในภาษาการเขียนโปรแกรมยอดนิยม
การใช้งาน MQTT ที่ง่ายที่สุดถึง MQTT/UDP Bridge ใน Pyton
เครื่องมือในการส่งข้อมูลจาก MQTT/UDP ไปยัง OpenHab
แอปพลิเคชันดีบั๊กเพื่อถ่ายโอนข้อมูล MQTT/UDP (เครื่องมือ/ผู้ชม)
เครื่องมือและสาธารณูปโภคอื่น ๆ

หากคุณต้องการช่วยโครงการ

อย่าลังเลที่จะ:

เพิ่มการใช้งานในภาษาการเขียนโปรแกรมที่คุณชื่นชอบ
เขียน Bridge to Classic MQTT Protocol (เรามีสิ่งที่ง่ายมากที่นี่เขียนใน Python)
ขยาย MQTT Broker หรือระบบ IoT ที่คุณชื่นชอบ (OpenHab?) ด้วยการสนับสนุน MQTT/UDP
ตรวจสอบข้อกำหนด/การใช้งาน MQTT/UDP กับ MQTT Spec เราต้องเข้ากันได้ในกรณีที่เป็นไปได้

มันง่ายจริงๆ

เหตุผลในการหลีกเลี่ยง MQTT/UDP

คุณต้องโอนน้ำหนักบรรทุกที่ยาว ในบางขนาดระบบของ DataGram UDP มี จำกัด
คุณจำเป็นต้องรู้ว่ามีการส่งข้อมูลอย่างแน่นอนหรือไม่ เป็นไปไม่ได้กับ UDP แม้ว่าระบบย่อยการจัดส่งที่เชื่อถือได้กำลังอยู่ในระหว่างการพัฒนาในขณะนี้และจะพร้อมใช้งานในไม่ช้า

วิธีขยาย MQTT/UDP

ดูเหมือนว่าจะมีเหตุผลที่จะเพิ่มลายเซ็นบางชนิดให้กับแพ็กเก็ตเพื่อป้องกันการปลอมแปลงข้อมูล ที่จริงแล้วมันทำไปแล้วสำหรับการใช้งาน Java, C และ Pythin จะมาเร็ว ๆ นี้
การออกอากาศไม่ใช่วิธีที่ดีที่สุดในการส่งข้อมูล มัลติคาสต์ดีกว่ามาก แม้ว่ามัลติคาสต์จะไม่ได้รับการสนับสนุนอย่างดีใน IoT OS หรือจอภาพ

คำแนะนำเริ่มต้นอย่างรวดเร็ว

ที่เก็บโคลนไปยังดิสก์ท้องถิ่น
อ่านไฟล์ howto

เครื่องมือสนับสนุน

ที่เก็บนี้มีเครื่องมือในการสนับสนุนการรวมและการทดสอบ MQTT/UDP:

เครื่องมือ GUI เพื่อแสดงสถานะปัจจุบันของข้อมูลที่ส่งในไดเรกทอรีเครื่องมือ/ผู้ชม ดูเพิ่มเติมที่หน้าความช่วยเหลือของ Viewer
ตัวสร้างข้อมูลแบบสุ่ม (random_to_udp.py) ในไดเรกทอรี Python3/ตัวอย่าง
ส่ง/ตรวจสอบเครื่องมือสำหรับแพ็กเก็ตที่มีหมายเลขตามลำดับ ดู seq_storm_send.py และ seq_storm_check.py ในไดเรกทอรี lang/python3/ตัวอย่าง
Wireshark dissector เพื่อดูข้อมูลโปรโตคอลบนเครือข่ายในไดเรกทอรี Lang/Lua/Wireshark

ตัวอย่างรหัส

งูหลาม

ส่งข้อมูล:

 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" );
}

Lua

ส่งข้อมูล:

 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 )