本插件是一个EMQX社区版的持久化数据的增强插件,社区出品,非官方。当前支持EMQX4.0以上版本。
配置文件分为两部分:
- 持久化的数据源:你要持久化的数据源,一般不要动
- Mysql连接配置:MySql客户端配置,IP端口,SSL等
参考这里:https://docs.emqx.io/broker/latest/cn/advanced/plugins.html
- 对
$PERSISTENCE/
开头的Topic,发送的任何消息被持久化到Mysql; - 客户端上下线记录持久化到Mysql;
Topic满足该规则可被直接发送给某个客户端,而不需要订阅任何Topic。例如直接给ClientId为test1
的客户端发送消息,直接在Topic后面加上即可:$P2P/test1
。
- client_id 不可空
$P2P/
不可订阅- ClientId中不可带非法字符:
/ * # +
以 $WITH_CLIENTID/
开头的Topic,消息Payload会被添加发送方的ClientId,ClientId会被加到Payload最前面以一个 #
分割。
例如A客户端 c1
给 $WITH_CLIENTID/test
发送了一个消息:ok
,如果有客户端订阅,受到的消息为 c1#ok
。
- QQ群:475512169
- 博客:https://openlab.ezlinker.cn