MQTT Broker

About

Golang MQTT Broker, Version 3.1.1, and Compatible for eclipse paho client

RUNNING

$ git clone https://github.com/chowyu08/broker.git
$ cd broker
$ go run main.go

Configure file

{
	"port": "1883",
	"host": "0.0.0.0",
	"cluster": {
		"host": "0.0.0.0",
		"port": "1993",
		"routers": ["192.168.10.11:1993","192.168.10.12:1993"]
	},
	"wsPort": "1888",
	"wsPath": "/ws",
	"wsTLS": true,
	"tlsPort": "8883",
	"tlsHost": "0.0.0.0",
	"tlsInfo": {
		"verify": true,
		"caFile": "tls/ca/cacert.pem",
		"certFile": "tls/server/cert.pem",
		"keyFile": "tls/server/key.pem"
	},
	"acl":true,
	"aclConf":"conf/acl.conf"
}

Features and Future

• Supports QOS 0 1 and 2

• Websocket Support

• TLS/SSL Support

• Cluster Support

• Supports retained messages

• Supports will messages

• Queue subscribe

• $SYS topics

• Flexible and Dynamic ACL

QUEUE SUBSCRIBE

Prefix	Examples
$queue/	mosquitto_sub -t ‘$queue/topic’

Online and Offline notify

TOPIC	Info	Description
$SYS/brokers/clients/connected/{clientid}	{"ipaddress":"127.0.01","username":"admin","clientID":"0001"}	Publish when client connected
$SYS/brokers/clients/disconnected/{clientid}	{"username":"admin","clientID":"001"}	Publish when client disconnected

ACL Configure

The ACL rules define:

Allow | type | value | pubsub | Topics

ACL Config

## type clientid , username, ipaddr
##pub 1 ,  sub 2,  pubsub 3
## %c is clientid , %u is username
allow      ip          127.0.0.1   2     $SYS/#
allow      clientid    0001        3     #
allow      username    admin       3     #
allow      username    joy         3     /test,hello/world 
allow      clientid    *           1     toCloud/%c
allow      username    *           1     toCloud/%u
deny       clientid    *           3     #

#allow local sub $SYS topic
allow      ip          127.0.0.1   2    $SYS/#

#allow client who's id with 0001 or username with admin pub sub all topic
allow      clientid    0001        3        #
allow      username    admin       3        #

#allow client with the username joy can pub sub topic '/test' and 'hello/world'
allow      username    joy         3     /test,hello/world 

#allow all client pub the topic toCloud/{clientid/username}
allow      clientid    *         1         toCloud/%c
allow      username    *         1         toCloud/%u

#deny all client pub sub all topic
deny       clientid    *         3           #

Client match acl rule one by one

          ---------              ---------              ---------
Client -> | Rule1 | --nomatch--> | Rule2 | --nomatch--> | Rule3 | --> 
          ---------              ---------              ---------
              |                      |                      |
            match                  match                  match
             \|/                    \|/                    \|/
        allow | deny           allow | deny           allow | deny

Performance

• High throughput

• High concurrency

• Low memory and CPU

License

• Apache License Version 2.0