EMQX client connection and message save to MySQL
emqx 客户端连接状态和消息持久化到MySQL 插件
1、clone emqx-rel 项目
git clone https://github.com/emqx/emqx-rel.git
2.rebar.config 添加依赖
{deps,
[ {buildrun_emqx_backend_mysql, {git, "https://github.com/goBuildRun/buildrun-emqx-backend-mysql.git", {branch, "master"}}}
, ....
....
]
}
3.rebar.config 中 relx 段落添加
{relx,
[...
, ...
, {release, {emqx, git_describe},
[
{buildrun_emqx_backend_mysql, load},
]
}
]
}
4.编译
make
File: etc/buildrun_emqx_backend_mysql.conf
# mysql 服务器
mysql.server = 127.0.0.1:3306
# 连接池数量
mysql.pool_size = 8
# mysql 用户名
mysql.username = buildrun
# mysql密码
mysql.password = buildrun
# 数据库名
mysql.database = mqtt
# 超时时间(秒)
mysql.query_timeout = 10s
mqtt_client.sql, mqtt_msg.sql到你的数据库中
./bin/emqx_ctl plugins load buildrun_emqx_backend_mysql
或者编辑
data/loaded_plugins
添加 {buildrun_emqx_backend_mysql, true}.
注意:这种方式适用emqx未启动之前
此插件会把public发布的消息保存到mysql中,但并不是全部。
需要在发布消息的参数中 retain 值设置为 true。 这样这条消息才会被保存在mysql中
eg:
{
"topic": "buildruntopic",
"payload": "hello,Buidrun",
"qos": 1,
"retain": true,
"client_id": "mqttjs_8b3b4182ae"
}
有什么问题和功能需求都可以给我提issue,欢迎关注。
Apache License Version 2.0