MCPcopy Index your code
hub / github.com/dromara/mica-mqtt

github.com/dromara/mica-mqtt @2.6.7

Chat with this repo
repository ↗ · DeepWiki ↗ · release 2.6.7 ↗ · + Follow
2,855 symbols 8,758 edges 404 files 1,076 documented · 38%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

🌐 Dromara mica mqtt 组件

Java CI JAVA 8 Mica Maven release Mica Maven SNAPSHOT GitHub

star star GitHub Repo stars


📖简体中文 | 📖English

Dromara mica-mqtt 低延迟高性能mqtt 物联网组件。更多使用方式详见: mica-mqtt-example 模块。

✨✨✨最佳实践✨✨✨ BladeX 物联网平台(「mica-mqtt加强版」+「EMQX+Kafka插件」双架构)

🍱 使用场景

  • 物联网(云端 mqtt broker)
  • 物联网(边缘端消息通信)
  • 群组类 IM
  • 消息推送
  • 简单易用的 mqtt 客户端

🚀 优势

  • ✓ 轻如蝉翼 - 核心依赖仅 500KB
  • ✓ 新手友好 - 5 分钟极速上手
  • ✓ 自由操控 - 手动档设计,扩展随心
  • ✓ 潜力无限 - 小而强大,未来可期

✨ 功能

  • [x] 支持 MQTT v3.1、v3.1.1 以及 v5.0 协议。
  • [x] 支持 websocket mqtt 子协议(支持 mqtt.js)。
  • [x] 支持 http rest api,http api 文档详见
  • [x] 支持 MQTT client 客户端,支持 Android 最低要求 API 26(Android 8.0)。
  • [x] 支持 MQTT server 服务端,支持 Android 最低要求 API 26(Android 8.0)。
  • [x] 支持 MQTT client、server 共享订阅支持。
  • [x] 支持 MQTT 遗嘱消息。
  • [x] 支持 MQTT 保留消息。
  • [x] 支持自定义消息(mq)处理转发实现集群。
  • [x] MQTT 客户端 阿里云 mqtt华为云 mqtt 连接 demo 示例。
  • [x] 支持 GraalVM 编译成本机可执行程序。
  • [x] 支持 Spring boot、Solon 和 JFinal 项目快速接入。
  • [x] Spring boot、Solon client 插件支持保留 session。
  • [x] 支持对接 Prometheus + Grafana 实现监控。
  • [x] 基于 redis stream 实现集群,详见 mica-mqtt-broker 模块
  • [x] mica mqtt 控制台

🌱 待办

  • [ ] 优化处理 mqtt 服务端 session,以及简化 mqtt v5.0 使用。
  • [ ] 基于 easy-rule + druid sql 解析,实现规则引擎。

🚨 默认端口

端口号 协议 说明
1883 tcp mqtt tcp 端口
8883 tcp ssl mqtt tcp ssl 端口
8083 websocket websocket mqtt 子协议端口
8084 websocket ssl websocket ssl mqtt 子协议端口
18083 http http、大模型 MCP 接口端口

演示地址:mqtt.dreamlu.net 端口同上,账号:mica 密码:mica

📦️ 依赖

Spring boot 项目

客户端:

<dependency>
  <groupId>org.dromara.mica-mqtt</groupId>
  <artifactId>mica-mqtt-client-spring-boot-starter</artifactId>
  <version>${mica-mqtt.version}</version>
</dependency>

配置详见mica-mqtt-client-spring-boot-starter 使用文档

服务端:

<dependency>
  <groupId>org.dromara.mica-mqtt</groupId>
  <artifactId>mica-mqtt-server-spring-boot-starter</artifactId>
  <version>${mica-mqtt.version}</version>
</dependency>

配置详见mica-mqtt-server-spring-boot-starter 使用文档

Solon 项目

客户端:

<dependency>
  <groupId>org.dromara.mica-mqtt</groupId>
  <artifactId>mica-mqtt-client-solon-plugin</artifactId>
  <version>${mica-mqtt.version}</version>
</dependency>

配置详见mica-mqtt-client-solon-plugin 使用文档

服务端:

<dependency>
  <groupId>org.dromara.mica-mqtt</groupId>
  <artifactId>mica-mqtt-server-solon-plugin</artifactId>
  <version>${mica-mqtt.version}</version>
</dependency>

配置详见mica-mqtt-server-solon-plugin 使用文档

JFinal 项目

客户端:

<dependency>
  <groupId>org.dromara.mica-mqtt</groupId>
  <artifactId>mica-mqtt-client-jfinal-plugin</artifactId>
  <version>${mica-mqtt.version}</version>
</dependency>

配置详见mica-mqtt-client-jfinal-plugin 使用文档

服务端:

<dependency>
  <groupId>org.dromara.mica-mqtt</groupId>
  <artifactId>mica-mqtt-server-jfinal-plugin</artifactId>
  <version>${mica-mqtt.version}</version>
</dependency>

配置详见mica-mqtt-server-jfinal-plugin 使用文档

其他项目

客户端:

<dependency>
  <groupId>org.dromara.mica-mqtt</groupId>
  <artifactId>mica-mqtt-client</artifactId>
  <version>${mica-mqtt.version}</version>
</dependency>

配置详见mica-mqtt-client 使用文档

服务端:

<dependency>
  <groupId>org.dromara.mica-mqtt</groupId>
  <artifactId>mica-mqtt-server</artifactId>
  <version>${mica-mqtt.version}</version>
</dependency>

配置详见mica-mqtt-server 使用文档

📝 文档

🍻 开源推荐

📱 微信

如梦技术

JAVA架构日记,精彩内容每日推荐!

Extension points exported contracts — how you extend this code

IMqttFunctionMessageListener (Interface)
mqtt 函数监听器 @author L.cm [15 implementers]
mica-mqtt-server/src/main/java/org/dromara/mica/mqtt/core/server/func/IMqttFunctionMessageListener.java
ClusterMessage (Interface)
Cluster message contract for inter-node communication within an MQTT broker cluster. This interface defines the seri [30 …
mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/cluster/message/ClusterMessage.java
ParamValueFunction (Interface)
参数值函数 @author L.cm [6 implementers]
mica-mqtt-common/src/main/java/org/dromara/mica/mqtt/core/function/ParamValueFunction.java
MqttReasonCode (Interface)
Common interface for MQTT messages reason codes enums @author vertx-mqtt [9 implementers]
mica-mqtt-codec/src/main/java/org/dromara/mica/mqtt/codec/codes/MqttReasonCode.java
IMqttClientMessageListener (Interface)
mqtt 消息处理 @author L.cm [7 implementers]
mica-mqtt-client/src/main/java/org/dromara/mica/mqtt/core/client/IMqttClientMessageListener.java
MqttClientPropertiesCustomizer (Interface)
mqtt client properties customizer @author L.cm [1 implementers]
starter/mica-mqtt-client-solon-plugin/src/main/java/org/dromara/mica/mqtt/client/solon/config/MqttClientPropertiesCustomizer.java
MqttClientPropertiesCustomizer (Interface)
mqtt client properties customizer @author L.cm [1 implementers]
starter/mica-mqtt-client-spring-boot-starter/src/main/java/org/dromara/mica/mqtt/spring/client/config/MqttClientPropertiesCustomizer.java
MqttServerPropertiesCustomizer (Interface)
mqtt server properties customizer @author L.cm [1 implementers]
starter/mica-mqtt-server-solon-plugin/src/main/java/org/dromara/mica/mqtt/server/solon/config/MqttServerPropertiesCustomizer.java

Core symbols most depended-on inside this repo

Shape

Method 2,423
Class 364
Interface 44
Enum 24

Languages

Java100%

Modules by API surface

mica-mqtt-client/src/main/java/org/dromara/mica/mqtt/core/client/MqttClientCreator.java91 symbols
mica-mqtt-server/src/main/java/org/dromara/mica/mqtt/core/server/MqttServerCreator.java74 symbols
mica-mqtt-common/src/test/java/org/dromara/mica/mqtt/core/common/TopicTemplateTest.java47 symbols
mica-mqtt-server/src/main/java/org/dromara/mica/mqtt/core/server/model/Message.java38 symbols
mica-mqtt-codec/src/main/java/org/dromara/mica/mqtt/codec/message/properties/MqttConnAckProperties.java38 symbols
mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/cluster/core/ClusterMqttSessionManager.java37 symbols
mica-mqtt-server/src/main/java/org/dromara/mica/mqtt/core/server/model/ClientInfo.java36 symbols
mica-mqtt-server/src/main/java/org/dromara/mica/mqtt/core/server/pipeline/PublishContext.java35 symbols
mica-mqtt-codec/src/main/java/org/dromara/mica/mqtt/codec/MqttDecoder.java32 symbols
mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/cluster/metrics/ClusterMetrics.java29 symbols
mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/cluster/config/MqttClusterConfig.java28 symbols
mica-mqtt-common/src/test/java/org/dromara/mica/mqtt/core/util/TopicUtilTest.java26 symbols

For agents

$ claude mcp add mica-mqtt \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

Ask about this repo answers extend the page