数据存储
数据存储是 EMQ X Enterprise 专属功能。
- Publish 端发布一条消息;
- Backend 将消息记录数据库中;
- Subscribe 端订阅主题;
- Backend 从数据库中获取该主题的消息;
- 发送消息给 Subscribe 端;
- Subscribe 端确认后 Backend 从数据库中移除该消息;
一对多消息存储
- Backend 将消息记录在数据库中;
- Subscribe1 和 Subscribe2 订阅主题;
- Backend 从数据库中获取该主题的消息;
- 发送消息给 Subscribe1 和 Subscribe2;
- Backend 记录 Subscribe1 和 Subscribe2 已读消息位置,下次获取消息从该位置开始。
客户端代理订阅
支持代理订阅功能,设备客户端上线时,由存储模块直接从数据库,代理加载订阅主题。
配置步骤
EMQ X 中支持不同类型的数据库的持久化,虽然在一些细节的配置上有所不同,但是任何一种类型的持久化配置主要做两步操作:
- 数据源连接配置:这部分主要用于配置数据库的连接信息,包括服务器地址,数据库名称,以及用户名和密码等信息,针对每种不同的数据库,这部分配置可能会有所不同;