mqtt_udp

MQTT/UDP

UDP를 통해 MQTT의 SimPified 버전 : Network는 브로커입니다!

기타 리포지기를 참고하십시오 : https://gitverse.ru/dzavalishin/mqtt_udp

러시아어 버전 / русская версия з десь를 참조하십시오

MQTT는 IoT 및 유사한 것들에 적합한 귀여운 간단한 프로토콜입니다.

그러나 MQTT/UDP는 단순히 UDP를 통해 방송 된 MQTT 게시 패킷 일뿐입니다.

mqtt/udp입니다

• 매우 간단합니다
• 매우 빠르고 최소한의 가능한 대기 시간
• 브로커 제외 (단일 실패 지점)
• 네트워크 트래픽을 낮추십시오 (각 마시스트는 정확히 한 번 모두에게 전송됩니다)
• 합리적으로 신뢰할 수 있습니다 (센서에 사용하는 경우 일반적으로 몇 초마다 데이터를 재개합니다)
• TCP를 지원할 수없는 하드웨어에서도 지원할 수 있습니다. 실제로 UDP 전송 만 필요합니다.
• 제로 구성 - 센서 노드는 설정이 필요하지 않으며 데이터 만 방송됩니다. (그리고 여전히 필요한 경우 MQTT/UDP는 네트워크를 통한 원격 구성을 지원합니다.)
• 디지털 서명을 지원합니다

추가 읽기를 위해

• MQTT/UDP Wiki
• 선적 서류 비치

이 저장소에는 포함됩니다

• 일부 인기있는 프로그래밍 언어에서 간단한 MQTT/UDP 구현.
• Pyton에서 가장 간단한 MQTT에서 MQTT/UDP 브리지 구현.
• MQTT/UDP에서 OpenHab으로 데이터를 보내는 도구
• MQTT/UDP 트래픽 (도구/뷰어)을 덤프하기위한 디버그 응용 프로그램.
• 기타 도구 및 유틸리티

프로젝트를 돕고 싶다면

자유롭게

• 좋아하는 프로그래밍 언어로 구현을 추가하십시오
• 클래식 MQTT 프로토콜에 다리를 작성하십시오 (여기에는 파이썬으로 작성된 매우 간단한 것이 있습니다)
• MQTT/UDP 지원으로 좋아하는 MQTT 브로커 또는 IoT 시스템 (OpenHab?)을 확장하십시오.
• MQTT 사양에 대한 MQTT/UDP 사양/구현을 확인하십시오. 우리는 가능한 경우 호환되어야합니다.

정말 쉽습니다.

MQTT/UDP를 피하는 이유

• 긴 페이로드를 전송해야합니다. 일부 시스템에서 UDP 데이터 그램의 크기는 제한적입니다.
• 데이터 그램이 확실히 제공되었는지 알아야합니다. UDP는 불가능합니다. 그러나 신뢰할 수있는 전달 하위 시스템이 현재 개발 중이며 곧 제공 될 예정입니다.

MQTT/UDP를 연장하는 방법

• 데이터 스푸핑을 방지하기 위해 패킷에 일종의 서명을 추가하는 것이 합리적입니다. 실제로, 그것은 이미 Java 구현을 위해 이루어졌으며, C와 Pythin은 곧 올 것입니다.
• 방송은 데이터를 전송하는 가장 좋은 방법이 아닙니다. 멀티 캐스트가 훨씬 좋습니다. 멀티 캐스트는 IoT OS 또는 모니터에서 잘 지원되지는 않습니다.

빠른 시작 지침

• 로컬 디스크에 대한 복제 저장소
• Howto 파일을 읽으십시오

지원 도구

이 저장소에는 MQTT/UDP 통합 및 테스트를 지원하는 도구가 포함되어 있습니다.

• 도구/뷰어 디렉토리에서 전송 된 현재 데이터 상태를 표시하는 GUI 도구; Viewer 도움말 페이지도 참조하십시오.
• python3/examples 디렉토리의 랜덤 데이터 생성기 (random_to_udp.py)
• 순차적으로 번호가 매겨진 패킷을 보내기/확인하십시오. lang/python3/examples 디렉토리의 seq_storm_send.py 및 seq_storm_check.py를 참조하십시오
• Lang/Lua/Wireshark 디렉토리의 네트워크에서 프로토콜 데이터를 볼 수있는 Wireshark Dissector

코드 예제

파이썬

데이터 보내기 :

 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를 다운로드하십시오

기음

데이터 보내기 :

 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 Language 구현이 있습니다. 자세한 내용은 Lang/Go를 참조하십시오.