How do I add custom authentication to Mochi-MQTT?

Use the built-in auth ledger hook for rule-based access control or implement your own hook by extending the OnConnectAuthenticate and OnACLCheck methods. Examples are provided in the auth hook directory and the README shows JSON/YAML loading options.

Is Mochi-MQTT faster than Mosquitto?

Benchmarks in the README show Mochi-MQTT has comparable or better performance in some tests, like higher receive speeds with multiple clients, but actual throughput depends on configuration. It's designed for high performance with trie-based topics and client buffers.

Can I use Mochi-MQTT with Docker?

Yes, there's an official Docker image available. You can run it with volume mounts for configuration files, and the quick start section provides commands for building and running with TCP, Websocket, and dashboard listeners.

What persistence backends does Mochi-MQTT support?

It includes built-in hooks for Redis, Badger, Pebble, and BoltDB, allowing persistent storage for sessions and messages. You can also create custom persistence hooks using the exported storage interfaces, as detailed in the examples.

How to embed Mochi-MQTT in a Go app?

Import the package, create a server instance with mqtt.New, add listeners and hooks like auth.AllowHook, then call Serve. The README provides a minimal code snippet in the 'Importing as a package' section with error handling.

Does Mochi-MQTT support shared subscriptions for load balancing?

Yes, as part of MQTT v5 compliance, it fully supports shared subscriptions, which allow messages to be distributed among multiple subscribers. This is listed in the key features and specification compliance details.

Open-Awesome

mochi mqtt

MITGov2.7.9

A fully compliant, embeddable high-performance MQTT v5 and v3.1.1 broker/server written in Go for IoT and pub/sub applications.

GitHub

1.9k stars332 forks0 contributors

What is mochi mqtt?

Mochi-MQTT is a fully compliant MQTT v5 (and v3.1.1) broker/server written in Go, designed for telemetry and internet-of-things projects. It can be used as a standalone binary or embedded as a library, offering a lightweight and fast solution with a focus on quality and maintainability.

Target Audience

Go developers building IoT or telemetry systems who need a high-performance, embeddable MQTT broker with full protocol compliance and extensive customization options.

Value Proposition

Developers choose Mochi-MQTT for its full MQTT v5 compliance, embeddable library design, and extensive developer control through exported core code, hook-based plugin system, and packet injection capabilities.

Overview

The fully compliant, embeddable high-performance Go MQTT v5 server for IoT, smarthome, and pubsub

Use Cases

Best For

Embedding an MQTT broker directly into a Go application for IoT device management.
Building telemetry systems requiring full MQTT v5 features like user properties, topic aliases, and shared subscriptions.
Developing custom authentication or access control systems for MQTT brokers using rule-based hooks.
Implementing persistent storage for MQTT sessions and messages using built-in Redis, Badger, Pebble, or Bolt hooks.
Creating high-performance MQTT brokers for constrained devices or low-bandwidth networks.
Testing and debugging MQTT client interoperability with a broker that passes Paho test suites.

Not Ideal For

Distributed systems requiring built-in clustering and high-availability out of the box.
Teams needing a fully-featured web administration interface for broker management without custom development.
Projects where strict MQTT v3.1.1 compliance without any v5 protocol behaviors is mandatory.
Organizations seeking a plug-and-play broker with minimal code integration and configuration.

Pros & Cons

Pros

Full MQTTv5 Compliance

Implements the complete MQTT v5.0.0 specification including user properties, topic aliases, and shared subscriptions, with hybrid support for v3.1.1 and v3.0.0, as confirmed by passing Paho interoperability tests.

Developer Control and Extensibility

Exports core broker code and provides a flexible hook-based system for plugins, allowing total customization of authentication, persistence, and packet handling through events like OnPacketRead and OnACLCheck.

High Performance Architecture

Uses a trie-based topic model and client-specific write buffers to handle irregular client behavior, with over a thousand unit tests and benchmarks showing competitive performance against brokers like Mosquitto.

Embeddable in Go Applications

Can be run as a standalone binary or embedded as a library in Go projects, offering a lightweight solution with an inline client for direct publishing and subscribing from embedding code.

Cons

No Native Clustering Support

Clustering is listed on the roadmap but not yet implemented, limiting scalability for distributed deployments without custom development or external solutions.

Complex Configuration for Advanced Use

File-based configuration only supports built-in hooks and listeners, and custom setups require programming with the hook system, increasing initial development time compared to more pre-configured brokers.

Conservative Default Settings

Defaults like maximum message expiry intervals are set to 24 hours to prevent DOS attacks, which may need adjustment for trusted environments, adding setup complexity and potential confusion.

Open Source Alternative To

mochi mqtt is an open-source alternative to the following products:

EMQX

EMQX is an open-source, scalable MQTT broker for IoT and real-time messaging applications, supporting millions of concurrent connections.

Mosquitto

Mosquitto is an open-source message broker that implements the MQTT protocol, commonly used for IoT applications and lightweight machine-to-machine communication.

Frequently Asked Questions

Related Projects

Go-zero

A cloud-native Go microservices framework with cli tool for productivity.

Stars33,395

Forks4,329

Last commit2 days ago

go-kit

A standard library for microservices.

Stars27,416

Forks2,438

Last commit2 years ago

Kratos

Your ultimate Go microservices framework for the cloud-native era.

Stars25,984

Forks4,181