DistMQTT

DistMQTT is an open source MQTT client and broker implementation. It is a fork of hbmqtt with support for anyio and DistKV.

DistMQTT provides a straightforward API based on coroutines, making it easy to write highly concurrent applications.

Features

DistMQTT implements the full set of MQTT 3.1.1 protocol specifications and provides the following features:

• Support for QoS 0, QoS 1 and QoS 2 messages flows
• Client auto-reconnection
• Authentication via password file (more methods can be added through a plugin system)
• Basic $SYS topics
• TCP and websocket support
• SSL support over TCP and websocket
• Plugin system
• Optional: Storage of retained messages in DistKV
• Testing: DistKV test server

Build status

Project status

Getting started

distmqtt is available on Pypi and can installed simply using pip :

$ pip install distmqtt

Documentation is available on Read the Docs.

Bug reports, patches and suggestions welcome! Just open an issue.