数据存储

    提示

    数据存储是 EMQX Enterprise 专属功能。

    1. Publish 端发布一条消息；
    2. Backend 将消息记录数据库中；
    3. Subscribe 端订阅主题；
    4. Backend 从数据库中获取该主题的消息；
    5. 发送消息给 Subscribe 端；
    6. Subscribe 端确认后 Backend 从数据库中移除该消息；

    一对多消息存储

    1. Backend 将消息记录在数据库中；
    2. Subscribe1 和 Subscribe2 订阅主题；
    3. Backend 从数据库中获取该主题的消息；
    4. 发送消息给 Subscribe1 和 Subscribe2；
    5. Backend 记录 Subscribe1 和 Subscribe2 已读消息位置，下次获取消息从该位置开始。

    支持将设备上下线状态，直接存储到 Redis 或数据库。

    客户端代理订阅

    EMQX 支持 MQTT 消息直接存储 Redis、MySQL、PostgreSQL、MongoDB、Cassandra、DynamoDB、InfluxDB、OpenTSDB 数据库:

    配置步骤

    EMQX 中支持不同类型的数据库的持久化，虽然在一些细节的配置上有所不同，但是任何一种类型的持久化配置主要做两步操作：

    • 数据源连接配置：这部分主要用于配置数据库的连接信息，包括服务器地址，数据库名称，以及用户名和密码等信息，针对每种不同的数据库，这部分配置可能会有所不同；