数据存储

    数据存储是 EMQ X 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 已读消息位置,下次获取消息从该位置开始。

    客户端代理订阅

    支持代理订阅功能,设备客户端上线时,由存储模块直接从数据库,代理加载订阅主题。

    配置步骤

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

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