tlmqtt:基于 Java 的高性能 MQTT Broker 开源项目
项目简介 tlmqtt是一款基于Java开发的轻量级、高并发 MQTT Broker,底层采用Netty异步通信框架与Project Reactor 响应式编程模型,实现了完整的MQTT 3.1.1 协议解析,支持 QoS 0/1/2 消息处理、主题通配符匹配、消息持久化等核心功能。项目模块化设计清晰,提供认证、数据桥接、存储等可扩展组件,适合构建物联网(IoT)、实时通信等场景的消息中间件。 核心特性 1\. 协议与消息处理 完整实现MQTT 3.1.1 协议,支持 CONNECT、PUBLISH、SUBSCRIBE 等核心报文解析 全链路支持QoS 0/1/2 消息投递,包含消息重发机制(默认 5 秒超时) 基于通配符(+、#)的主题过滤与消息转发 支持保留消息(Retain Message)和遗嘱消息(Will Message) 2\. 扩展性与集成能力 认证模块:支持文件配置、MySQL 数据库、HTTP 接口认证,可自定义认证逻辑 数据桥接:内置 Kafka、MySQL 桥接组件,支持通过接口扩展自定义目标系统 存储模块:提供内存存储实现,支持扩展 Redis、数据库等持久化...





