砍材农夫砍材农夫
  • 微信记账小程序
  • java
  • redis
  • mysql
  • 场景类
  • 框架类
  • vuepress搭建
  • hexo搭建
  • 云图
  • llm wiki

    • 基于karpathy
    • gradle
  • 常用工具

    • git
    • gradle
    • Zadig
    • it-tools
    • 开源推荐
    • curl
  • 大前端

    • nodejs
    • npm
    • webpack
    • 微信
    • 正则
    • uniapp
    • app
  • java

    • java基础
    • jdk体系
    • jvm
    • spring
    • spring_cloud
    • spring_boot
    • 分库分表
    • zookeeper
  • python

    • python基础
    • python高级
    • python框架
  • 算法

    • 算法
  • 网关

    • spring_cloud_gateway
    • openresty
  • 高可用

    • 秒杀
    • 分布式
    • 缓存一致
  • MQ

    • MQ
    • rabbitMQ
    • rocketMQ
    • kafka
  • 其它

    • 设计模式
    • 领域驱动(ddd)
  • 关系型数据库

    • mysql5.0
    • mysql8.0
  • 非关系型数据库

    • redis
    • mongoDB
  • 分布式/其他

    • ShardingSphere
    • 区块链
  • 向量数据库

    • M3E
    • OPEN AI
  • Jmeter
  • fiddler
  • wireshark
  • AI入门
  • AI大模型
  • AI插件
  • AI集成框架
  • 相关算法
  • AI训练师
  • 量化交易
  • AIoT
  • gitee
  • github
  • infoq
  • osc
  • 砍材工具
  • 关于
  • 相关运营
  • docker
  • k8s
  • devops
  • nginx
  • 元宇宙
  • 区块链
  • 物联网
  • linux
  • webrtc
  • web3.0
  • gitee
  • github
  • infoq
  • osc
  • 砍材工具
  • 关于
  • 中考
  • 投资
  • 保险
  • 思
  • 微信记账小程序
  • java
  • redis
  • mysql
  • 场景类
  • 框架类
  • vuepress搭建
  • hexo搭建
  • 云图
  • llm wiki

    • 基于karpathy
    • gradle
  • 常用工具

    • git
    • gradle
    • Zadig
    • it-tools
    • 开源推荐
    • curl
  • 大前端

    • nodejs
    • npm
    • webpack
    • 微信
    • 正则
    • uniapp
    • app
  • java

    • java基础
    • jdk体系
    • jvm
    • spring
    • spring_cloud
    • spring_boot
    • 分库分表
    • zookeeper
  • python

    • python基础
    • python高级
    • python框架
  • 算法

    • 算法
  • 网关

    • spring_cloud_gateway
    • openresty
  • 高可用

    • 秒杀
    • 分布式
    • 缓存一致
  • MQ

    • MQ
    • rabbitMQ
    • rocketMQ
    • kafka
  • 其它

    • 设计模式
    • 领域驱动(ddd)
  • 关系型数据库

    • mysql5.0
    • mysql8.0
  • 非关系型数据库

    • redis
    • mongoDB
  • 分布式/其他

    • ShardingSphere
    • 区块链
  • 向量数据库

    • M3E
    • OPEN AI
  • Jmeter
  • fiddler
  • wireshark
  • AI入门
  • AI大模型
  • AI插件
  • AI集成框架
  • 相关算法
  • AI训练师
  • 量化交易
  • AIoT
  • gitee
  • github
  • infoq
  • osc
  • 砍材工具
  • 关于
  • 相关运营
  • docker
  • k8s
  • devops
  • nginx
  • 元宇宙
  • 区块链
  • 物联网
  • linux
  • webrtc
  • web3.0
  • gitee
  • github
  • infoq
  • osc
  • 砍材工具
  • 关于
  • 中考
  • 投资
  • 保险
  • 思
  • 首页
    • 开发板介绍
    • micropython环境搭建
    • esp32开发板
    • 面包板
    • 万能表使用
  • 面包板
    • 点灯
  • esp32
    • 点亮开发板led灯
    • 点亮外接led
    • 点亮外接oled文字
    • 红外传感器
    • 红外传感器+olde
    • esp32+面包板
  • MQTT编程

    • MQTT入门

      • 物联网 MQTT
      • 物联网 MQTT和Socket
      • 物联网 MQTT订阅性能优势
      • 物联网 MQTT简易版Broker
    • HiveMQ

      • hivemq实战入门
    • Protobuf

      • Protobuf入门
      • Protobuf入门+梳理
      • Protobuf实战第一篇
    • emqx

      • emqx入门
    • mica

      • mica入门
    • netty

      • 入门

        • 基于netty构建入门
        • 理解粘包/拆包
        • 编解码器机制与自定义协议
        • 心跳和ack机制
        • mqtt服务demo演示
        • mqtt服务协议支持
        • mqtt服务udp支持
      • 协议规范

        • mqtt协议规范(发布/订阅模式)
        • mqtt协议规范(轻量级二进制协议)
        • mqtt协议规范(三种 QoS 等级)
        • mqtt协议规范(主题通配符订阅)
        • mqtt协议规范(遗嘱与保留消息)
      • 报文结构

        • 控制报文结构(报文分类)
        • 控制报文结构(连接与握手)
        • 控制报文结构(发布与接收)
      • 核心实战

        • 核心实战(握手与认证)
        • 核心实战(心跳保活机制)
        • 核心实战(会话管理)
        • 核心实战(安全)
    • mqtt-模拟器

      • 集成Paho

        • 设备模拟器设计
        • 设备模拟器演示
        • Paho拆解入门
        • Paho拆解核心
        • Paho拆解高性能
        • 其他客户端框架比较
      • NetAssist

        • 设备模拟器设计
    • netty-mqtt-boot

      • 模块化设计
      • 物联网一体化设计
      • 统一接入层
      • 消息路由与流转层
      • 核心服务层
      • 业务应用层
      • 整体项目管理
      • 测试脚手架
      • 兼容支持
    • mqtt-压测

      • mqtt-jmeter

        • 模块化设计
      • ‌emqtt-bench

        • 模块化设计
    • mqtt-规则引擎

      • MQTT规则引擎
      • ice

        • 模块化设计
      • Aviator

        • 模块化设计
      • Drools

        • 模块化设计
  • 物联网实战:Spring Boot MQTT | 客户端框架比对
    • 对比
    • 各框架优缺点&选型说明
      • 1. Eclipse Paho(当前在用)
      • 2. HiveMQ MQTT Client(生产网关最优)
      • 3. Vert.x MQTT Client
      • 4. Mica-MQTT(国产Spring生态首选)
      • 5. EMQX Java Client
    • 异步编程模型简要对比

物联网实战:Spring Boot MQTT | 客户端框架比对

适配场景:异步网关、设备消息转发、高吞吐IoT服务

对比

框架名IO模型异步实现API风格MQTT支持适用场景
Eclipse PahoBIO+自建线程池ActionListener+IMqttToken传统回调3.1.1/MQTT5全入门学习、低并发设备端
HiveMQ ClientNetty NIOCompletableFuture+ReactorBuilder链式3.1.1/MQTT5全高并发网关、工业级IoT
Vert.x MQTTVert.x-NIO(Netty)EventLoop+HandlerVert.x原生3完善/5部分Vert.x生态自研平台
Mica-MQTT(国产)Netty NIO封装异步回调链式+注解3.1.1/MQTT5SpringBoot快速开发
EMQX Java ClientNetty NIOFuture+响应式流Builder配置3.1.1/MQTT5全EMQX Broker集群对接

各框架优缺点&选型说明

1. Eclipse Paho(当前在用)

✅ 优点

  1. MQTT官方标准参考实现,资料最全,协议合规;
  2. 同步MqttClient/异步MqttAsyncClient双API,适合学习同步异步差异;
  3. 跨平台,可用于Android、嵌入式设备。

❌ 缺点

  1. 底层非纯NIO,高并发海量消息时线程膨胀、GC频繁;
  2. 无内置自动重连、消息限流、背压,网关相关逻辑需手动编码;
  3. 回调嵌套多,大量业务易出现回调地狱。

选型:学习MQTT异步首选,生产高吞吐网关不推荐。

2. HiveMQ MQTT Client(生产网关最优)

✅ 优点

  1. 全Netty NIO真正非阻塞,吞吐是Paho 3~5倍;
  2. 阻塞/异步Future/Reactor响应式三套API自由切换;
  3. 内置自动重连、断线缓存、消息流控、背压,无需手动做频率控制;
  4. MQTT5全部特性完整落地。

❌ 缺点:依赖包体积偏大。

选型:设备消息转发网关、百万连接IoT生产首选。

3. Vert.x MQTT Client

✅ 优点:依托Vert.x事件驱动,无锁IO,和Vert.x微服务无缝集成。 ❌ 缺点:脱离Vert.x框架使用成本高、MQTT5支持不全。

选型:Vert.x技术栈项目专用。

4. Mica-MQTT(国产Spring生态首选)

✅ 优点:注解订阅@MqttSubscribe,SpringBoot零配置快速接入,内置重连与监控。 ❌ 缺点:性能略低于HiveMQ。

选型:中小型SpringBoot IoT项目。

5. EMQX Java Client

✅ 优点:EMQX官方SDK,深度适配共享订阅、桥接、EMQX独有扩展协议。 ❌ 缺点:对接其他Broker兼容性一般。

选型:业务Broker固定为EMQX时使用。

异步编程模型简要对比

  1. Paho:自定义MqttActionListener + IMqttToken,老旧回调模型;
  2. HiveMQ:JDK原生CompletableFuture,现代异步写法,支持链式编排;
  3. Mica/Vert.x:封装回调/注解,屏蔽底层异步细节,开发效率高。
最近更新: 2026/6/3 13:26
Contributors: kcnf
Prev
Paho拆解高性能