GitHub 链接

• 完全支持 MQTT v3.1/v3.1.1/v5.0
• 支持 TLS/WebSocket/WebSocket-TLS
• 支持 Proxy Protocol V2
• 使用 io_uring(glommio) 来实现高性能低延迟的网络 IO
• 用 Hook trait 方便扩展服务器功能
• 认真测试过

Benchmark:

# Environment
CPU    : Intel® Xeon® E5-2678 v3 × 48
Memory : 32GB DDR4/2133
System : Arch Linux

# Players
FlashMQ : v1.6.9
  Akasa : v0.1.0
   EMQX : v5.2.1
VerneMQ : v1.13.0

# Connections (clean_session=false)
FlashMQ : 250k connections, 0.9GB memory
  Akasa : 250k connections,   5GB memory
   EMQX : 250k connections,   5GB memory
VerneMQ :  50k connections,  20GB memory

# Message/s
FlashMQ : 40k coonections, 600k message/s, 1.0GB memory, CPU  550%
  Akasa : 35k connections, 500k message/s, 2.3GB memory, CPU 1050%
   EMQX : 20k connections, 300k message/s, 3.2GB memory, CPU 3000%
VerneMQ : 25k connections, 370k message/s, 6.0GB memory, CPU 2600%