跳到主要内容

Rust 分布式 MQTT Broker

YedMQ logoYedMQ

基于 Rust 的分布式 MQTT Broker,提供租户隔离、集群能力和灵活扩展能力。

围绕团队真正关心的能力构建面向 IoT 的多租户消息系统:MQTT v3.1.1、集群能力,以及灵活的扩展接口。

MQTT v3.1.1TCP / TLS / WS / WSS按租户隔离Plugin Hooks
项目状态: 源码仓库目前仍是私有状态。YedMQ 仍在持续开发中,暂时还不建议直接用于生产环境。
yedmq@node-01:~

$yedmq cluster status --user admin --password-stdin

Cluster Status

Cluster: YedMQ

Node ID: 1001

Health: healthy

Ready: true

Raft Groups:

topic leader=1001 ready=true

sessionActorMap leader=1001 ready=true

sessionState leader=1001 ready=true payloadReady=true

$ _

协议

MQTT 核心覆盖保留消息、遗嘱消息、持久会话和消息限制。

集群

多节点部署工作流用于横向扩展和可用性规划。

运维

管理端点覆盖插件、客户端、主题、保留数据和系统信息。

能力地图

与当前代码实现一致的能力清单

首页和文档现在优先描述已经实现的能力,而不是提前承诺未来功能。

已实现能力面

MQTT Broker 核心

支持 MQTT v3.1.1、QoS 0/1/2、保留消息、遗嘱消息、持久会话,以及可配置消息大小。

QoS 0/1/2RetainWill
已实现能力面

集群能力

支持多节点部署,适合横向扩展场景和更稳健的运维方式。

BootstrapJoin
已实现能力面

租户隔离

客户端、主题、保留消息和管理操作都按租户隔离,默认租户为 public。

Scoped datapublic
已实现能力面

灵活插件扩展

通过插件把认证、鉴权和自定义消息处理接入你的业务流程。

AuthACLMessage
已实现能力面

REST 运维接口

管理接口覆盖插件、客户端、主题、保留消息、系统信息与集群流程。

OpenAPIOps