A MQTT message broker based on MQTT v3.1.1
- Completely compatible with mqtt protocol
- Multi-tenancy support
- No painful scale out
- High availability
- Flexible business callback
- Retain message
- QoS 1,0 message
- Will message
- connd: the session layer manages the flow of client state.
- pushd: the business layer implements business callbacks and data persistence
- etcd cluster: service discovery, routing metadata store.
- DB : user state storage, support two types of tikv, redis storage.
- nohup etcd > etcd.log 2>&1 &
To setup etcd , please follow official instruction
- nohup redis-server > redis.log 2>&1 &
To setup redis, please follow official instruction
- GO111MODULE=on sh release.sh
- cd bifrost
- nohup bin/pushd -c conf/pushd.toml > pushd.log 2>&1 &
- nohup bin/connd -c conf/connd.toml > connd.log 2>&1 &
- cd misc/example/ && go build
- ./message_test_a2a
You can refer to directory 1 (misc/linktest) and directory 2 (misc/example)