Built-in MQTT Broker
Netty-based MQTT Broker included in FastBee open-source edition — no external MQTT server needed.
Features
- Protocol: MQTT 3.1.1
- Connections: TCP (1883) + WebSocket (8083)
- QoS: QoS 0, QoS 1
- Retain Messages: Supported
- Last Will: Supported
- Session: Persistent and clean sessions
- Auth: Product ID + device key
Architecture
Key Modules
| Module | Description |
|---|---|
| MqttConnect | CONNECT handling & auth |
| MqttPublish | PUBLISH processing |
| MqttSubscribe | Subscription management |
| ClientManager | Client connection tracking |
| SessionManager | Session state |
| RetainMsgManager | Retained messages |
Auth Flow
- Client sends CONNECT (ClientID=device#, Username=productID, Password=authKey)
- Broker validates via AuthService
- Session created, registered in ClientManager
- CONNACK sent to client
Performance
- Supports thousands of concurrent connections per node
- Tunable via
NettyConfig(IO threads, buffer sizes) - Redis-based message decoupling between Broker and business layer