功能 | fluxmq

📄️ Dashboard

FluxMQ提供一个后台控制台，用户可通过页面直接看到当前系统的一些运行指标。

在MQTT中，有两个关键的角色：发布者（Publisher）和订阅者（Subscriber）。它们通过MQTT服务器（也称为代理或代理服务器）进行通信。下面简要介绍MQTT的发布订阅模型：

共享订阅是一种机制，允许将订阅组的消息分发均匀地分发给订阅组成员。在共享订阅中，订阅同一主题的客户机依次接收此主题下的消息。同一消息不会发送给多个订阅客户端，从而实现多个订阅客户端之间的负载均衡。

客户端可以通过设置MQTT连接的"clean session"标志来指定是使用持久会话还是非持久会话。如果"clean session"标志被设置为1，表示使用非持久会话，服务器不会保留客户端的状态。如果"clean session"标志被设置为0，表示使用持久会话，服务器会保留客户端的状态。

MQTT的延迟消息是指在特定时间或延迟之后发送的消息。在标准的MQTT协议中，并没有直接支持延迟消息的机制。消息的发布和传递通常是实时的，消息一旦被发布，就会立即传递给所有的订阅者。

5 个项目

3 个项目

连接管理是FluxMQ平台的基础功能模块，负责设备连接认证，连接管理，连接权限控制等；FluxMQ提供一个后台web控制台，用户可通过页面直接进行客户端的管理和控制。

主题列表展示不同节点订阅主题，如果在相同节点，不同连接订阅同一主题，列表将进行去重处理；

5 个项目

代理订阅是指服务端支持设置主题规则，设备连接后无需要发送订阅报文，FluxMQ会自动建立设备与代理主体的订阅关系，设备从而收到改订阅主题的报文

FluxMQ支持脚本来处理数据流，可以将MQTT传输的Payload转换成任意格式，再流转到后续的规则引擎中，但是脚本中的方法尽量保持轻量、高效，避免出现阻塞Pipeline的情况。导致系统性能下降