# mqtt_udp

**Repository Path**: jerryang/mqtt_udp

## Basic Information

- **Project Name**: mqtt_udp
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-12-02
- **Last Updated**: 2025-12-02

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# MQTT/UDP
Simpified version of MQTT over UDP: Network is broker!

Note other repo: https://gitverse.ru/dzavalishin/mqtt_udp

[![Codacy Badge](https://api.codacy.com/project/badge/Grade/c498fc36dbea4e41a05f4ba5a8c0ff96)](https://www.codacy.com/app/dzavalishin/mqtt_udp?utm_source=github.com&utm_medium=referral&utm_content=dzavalishin/mqtt_udp&utm_campaign=Badge_Grade) 
[![Build Status](https://travis-ci.org/dzavalishin/mqtt_udp.svg?branch=master)](https://travis-ci.org/dzavalishin/mqtt_udp) 
[![Documentation Status](https://readthedocs.org/projects/mqtt-udp/badge/?version=latest)](https://mqtt-udp.readthedocs.io/en/latest/?badge=latest)
[![PyPI version](https://badge.fury.io/py/mqttudp.svg)](https://badge.fury.io/py/mqttudp)

[See Russian version / Русская версия здесь](./README.ru.md)

MQTT is a cute simple protocol well suited for IoT and similar things.

But it can be even simpler and still be very usable: MQTT/UDP is
merely an MQTT Publish packets broadcast over an UDP.

## MQTT/UDP is 

*   Extremely simple
*   Extremely fast, minimal possible latency
*   Excludes broker (which is single point of failure)
*   Lowers network traffic (each masurement is sent exactly once to all)
*   Reasonably reliable (if we use it for sensors, which usually resend data every few seconds or so)
*   Can be supported even on a hardware which can not support TCP - in fact, only UDP send is required
*   Zero configuration - a sensor node needs no setup, it just broadcasts its data. (And, if you still need it, MQTT/UDP supports remote configuration over network.)
*   Supports digital signature

## For further reading

*   [MQTT/UDP Wiki](../../wiki)
*   [Documentation](https://mqtt-udp.readthedocs.io/en/latest/)

## This repository contains

*   A simple MQTT/UDP implementation in some popular programming languages.
*   A simplest MQTT to MQTT/UDP bridge implementation in Pyton.
*   A tool to send data from MQTT/UDP to OpenHAB 
*   A [debug application](https://github.com/dzavalishin/mqtt_udp/wiki/MQTT-UDP-Viewer-Help) to dump MQTT/UDP traffic ([tools/viewer](tools/viewer)).
*   Other tools and utilities

## If you want to help a project

Feel free to:

*   Add implementation in your favorite programming language
*   Write a bridge to classic MQTT protocol (we have very simple one here written in Python)
*   Extend your favorite MQTT broker or IoT system (OpenHAB?) with MQTT/UDP support
*   Check MQTT/UDP specification/implementation against MQTT spec. We must be compatible where possible.

It is really easy.

## Reasons to avoid MQTT/UDP

*   You need to transfer long payloads. On some systems size of UDP datagram is limited.
*   You need to know if datagram was delivered for sure. It is impossible with UDP. Though, reliable delivery subsystem is being in development now and will be available soon.

## Ways to extend MQTT/UDP

*   It seems to be reasonable to add some kind of signature to packets to prevent data spoofing. Actually, it is already done for Java implementation, C and Pythin will come soon.
*   Broadcast is not the best way to transmit data. Multicast is much better. Though multicast is not so well supported in IoT OS's or monitors.

## Fast start instructions

*   Clone repository to local disk
*   Read [HOWTO](https://raw.githubusercontent.com/dzavalishin/mqtt_udp/master/HOWTO) file

## Support tools

This repository contains tools to support MQTT/UDP integration and test:

*   GUI tool to show current state of data transmitted in [tools/viewer](https://github.com/dzavalishin/mqtt_udp/tree/master/tools/viewer) directory; see also [viewer help page](https://github.com/dzavalishin/mqtt_udp/wiki/MQTT-UDP-Viewer-Help).
*   Random data generator (random_to_udp.py) in [python3/examples](https://github.com/dzavalishin/mqtt_udp/tree/master/python3/examples) directory
*   Send/check tool for sequentially numbered packets. See seq_storm_send.py and seq_storm_check.py in [lang/python3/examples](https://github.com/dzavalishin/mqtt_udp/tree/master/python3/examples) directory
*   WireShark dissector to see protocol data on the network in [lang/lua/wireshark](https://github.com/dzavalishin/mqtt_udp/tree/master/lua/wireshark) directory


## Code examples

### Python

**Send data:**

```python
import mqttudp.engine

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

**Listen for data:**

```python
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)
```

Download [pypi package](https://pypi.org/project/mqttudp/)

### Java

**Send data:**

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

```

**Listen for data:**


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

```

Download [JAR](https://github.com/dzavalishin/mqtt_udp/blob/master/build/mqtt_udp-0.4.1.jar)

### C

**Send data:**

```c
int rc = mqtt_udp_send_publish( topic, value );

```

**Listen for data:**

```c

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


**Send data:**


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

```

**Listen for data:**


```lua
local mq = require "mqtt_udp_lib"

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

mq.listen( listener )
```

Download [LuaRock](http://luarocks.org/modules/dzavalishin/mqttudp)


### Go

There is a Go language implementation, see lang/go for details