Welcome to FluxMQ - a high-performance, multi-protocol message broker with MQTT, WebSocket, HTTP, and CoAP support

FluxMQ

A high-performance, multi-protocol message broker written in Go designed for scalability, extensibility, and protocol diversity. Supports MQTT 3.1.1 and 5.0 over TCP and WebSocket, plus HTTP-MQTT and CoAP bridges for IoT integration.

Features

Multi-Protocol Support - MQTT 3.1.1/5.0, WebSocket, HTTP-MQTT Bridge, CoAP Bridge
High Performance - 300K-500K msg/s per node with zero-copy packet parsing
Clustering - Embedded etcd for distributed coordination, no external dependencies
Durable Queues - Consumer groups with ack/nack/reject semantics
Security - TLS/mTLS, rate limiting, pluggable auth/authz
Observability - OpenTelemetry metrics, structured logging, webhook notifications

Quick Start

Prefer Docker? See Quick Start (Docker).

Build & Run

# Clone and build
git clone https://github.com/absmach/fluxmq.git
cd fluxmq
make build

# Run single node
./build/fluxmq

# Run with configuration
./build/fluxmq --config config.yaml

Test with MQTT Client

# Subscribe
mosquitto_sub -p 1883 -t "test/#" -v

# Publish
mosquitto_pub -p 1883 -t "test/hello" -m "Hello FluxMQ"

Basic Configuration

server:
  tcp:
    plain:
      addr: ":1883"
  websocket:
    plain:
      addr: ":8083"
      path: "/mqtt"
  http:
    plain:
      addr: ":8080"

broker:
  max_message_size: 1048576
  max_retained_messages: 10000

storage:
  type: badger
  badger_dir: "./data"

log:
  level: info