mqtt-broker

module

v0.0.9-beta10 Latest Latest Go to latest Published: Nov 10, 2018 License: MPL-2.0

Details

Experiments around a gossip-based MQTT Broker. Inspired (a lot) by https://emitter.io/.

The broker is released as a docker image.

docker run -p 1883:1883 --rm quay.io/vxlabs/mqtt-broker:v0.0.1 -t 1883

You can start a single instance of the broker by running

go run ./cmd/broker/main.go  -t 1883

(go run can be replaced by the appropriate docker run command)

The broker should start and listen on 0.0.0.0:1883 (tcp). You can connect to it using an MQTT client:

mosquitto_sub -t 'test' -d -q 1 &
mosquitto_pub -t 'test' -d -q 1 -m 'hello'

Once one node is running, you can start other nodes and tell them to join the first node by running

go run ./cmd/broker/main.go  -t 1884 -j <first broker address>
go run ./cmd/broker/main.go  -t 1885 -j <first broker address>

You can find the join address to give in the first broker log messages.

Path	Synopsis
broker Package broker is a generated protocol buffer package.	Package broker is a generated protocol buffer package.
listener
listener/transport
peer
rpc Package rpc is a generated protocol buffer package.	Package rpc is a generated protocol buffer package.
rpc/client
cmd
broker
cli
events
identity
sessions Package sessions is a generated protocol buffer package.	Package sessions is a generated protocol buffer package.
state Package state is a generated protocol buffer package.	Package state is a generated protocol buffer package.
subscriptions Package subscriptions is a generated protocol buffer package.	Package subscriptions is a generated protocol buffer package.
topics Package topics is a generated protocol buffer package.	Package topics is a generated protocol buffer package.