This repo is a implementation of the MQTT Protocol for the Go Programming Language.
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
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
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/mqttNow build and install the server with:
go install github.com/j-forster/mqtt/serverThis will compile the server code and move the executable to $GOPATH/bin/.
To start the server:
$GOPATH/bin/serverThe default MQTT (TCP) port is :1883. You can now connect with any MQTT
client.
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 |
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