Golang MQTT-Server

This repo is a implementation of the MQTT Protocol for the Go Programming Language.

What is MQTT?

MQTT stands for MQ Telemetry Transport. It is a publish/subscribe, extremely
simple and lightweight messaging protocol, designed for constrained devices
and low-bandwidth, high-latency or unreliable networks. The design principles
are to minimise network bandwidth and device resource requirements whilst also
attempting to ensure reliability and some degree of assurance of delivery.
These principles also turn out to make the protocol ideal of the emerging
“machine-to-machine” (M2M) or “Internet of Things” world of connected devices,
and for mobile applications where bandwidth and battery power are at a premium.

→ See MQTT FAQ

Install Go

Go is an open source programming language that makes it easy to build simple,
reliable, and efficient software.

You can download Go at golang.org/dl. There are executables for Microsoft Windows, Apple macOS and Linux, as well as the Go source code. There are also Golang releases for Docker!

Run the MQTT-Server

First of all, grab this repository by running the following line. The go get command will clone this repo into the $GOPATH directory.

go get github.com/j-forster/mqtt

Now build and install the server with:

go install github.com/j-forster/mqtt/server

This will compile the server code and move the executable to $GOPATH/bin/.

To start the server:

$GOPATH/bin/server

The default MQTT (TCP) port is :1883. You can now connect with any MQTT client.

Benchmark

To run the benchmark tests, use:

npm run test -- -g bench -p 1883 -c 100 -l 10

Parameter	Description
-g	Tests to run. bench means 'benchmark tests'
-p	Server Port. Default: 1883
-c	Total number of packages to send. Default: 100
-l	Number of packages to send concurrently. Default: 10

Results

Benchmark results depend on your system and configration!

The following results have been recorded with a Windows 10 x64 machine.

Go MQTT-Server:

[Bench] Network: single publisher -> single subscriber
[Bench] Sending 10000 packages, 10 concurrent ..
[Bench] Time delta: 642.22588 ms
[Bench] Msg/Sec: 15570.845572277469 Msg/s

Eclipse Mosquitto MQTT Broker:

[Bench] Network: single publisher -> single subscriber
[Bench] Sending 10000 packages, 10 concurrent ..
[Bench] Time delta: 645.351073 ms
[Bench] Msg/Sec: 15495.441812025932 Msg/s