EMQX 持久化插件使用教程

1、项目介绍

emqx_persistence_plugin 是一个用于将 EMQX 消息持久化到 MySQL 数据库的插件。该插件适用于 EMQX v4.3.10 及以上版本，由社区开发，非官方出品。通过该插件，用户可以将特定主题的消息持久化到 MySQL 数据库中，同时记录客户端的上下线信息。

2、项目快速启动

2.1 环境准备

• 确保已安装 EMQX v4.3.10 或更高版本。
• 安装 MySQL 数据库，并确保数据库服务正常运行。

2.2 下载与安装

1. 克隆项目到本地：

   git clone https://github.com/luxingwen/emqx_persistence_plugin.git
   

2. 将项目移动到 EMQX 源码目录下的 apps 目录中。

3. 修改 rebar.config 文件，在 relx_plugin_apps(ReleaseType) 函数中添加该插件。

4. 构建项目：

   make
   

2.3 配置

1. 配置持久化数据源：

   vi emqx_persistence_plugin/etc/emqx_persistence_plugin.conf
   

2. 配置 MySQL 连接信息：

   vi emqx_persistence_plugin/etc/mysql.conf
   

2.4 启动 EMQX

启动 EMQX 并加载插件：

emqx start

3、应用案例和最佳实践

3.1 应用案例

假设有一个智能家居系统，使用 EMQX 作为消息中间件。通过 emqx_persistence_plugin，可以将智能家居设备的状态信息（如温度、湿度等）持久化到 MySQL 数据库中，以便后续分析和查询。

3.2 最佳实践

• 数据分区：根据业务需求，将不同类型的数据存储在不同的数据库表中，避免单表数据过大。
• 定期备份：定期备份 MySQL 数据库，防止数据丢失。
• 性能优化：根据实际业务场景，调整 MySQL 的配置参数，如缓存大小、连接数等，以提高性能。

4、典型生态项目

• EMQX：作为消息中间件，EMQX 提供了强大的消息路由和处理能力。
• MySQL：作为持久化存储，MySQL 提供了稳定的数据存储和查询能力。
• Grafana：结合 Grafana，可以实时监控和展示持久化的数据，帮助用户更好地理解系统状态。

通过以上步骤，您可以快速上手并使用 emqx_persistence_plugin 插件，将 EMQX 消息持久化到 MySQL 数据库中。