共计 4116 个字符,预计需要花费 11 分钟才能阅读完成。
Redis
简介
Redis 是齐全开源的,恪守 BSD 协定,是一个高性能的 key-value 数据库。
Redis 与其余 key – value 缓存产品有以下三个特点:
- Redis 反对数据的长久化,能够将内存中的数据保留在磁盘中,重启的时候能够再次加载进行应用。
- Redis 不仅仅反对简略的 key-value 类型的数据,同时还提供 list,set,zset,hash 等数据结构的存储。
- Redis 反对数据的备份,即 master-slave 模式的数据备份。
能够参考 centos8.0 装置 redis
能够参考 centos8.0 平台用 redis-cli 对 redis5 监控和治理
来装置 Redis,通过 redis-server 命令来启动 Redis 服务器。
如果装置的 Redis 不与 EMQ X 在同一服务器上,请指定正确的 Redis 服务器的地址与端口。通过 RPM 形式装置的 EMQ X,Redis 相干的配置文件位于 /etc/emqx/plugins/emqx_backend_redis.conf
如下所示:
常用命令
- 查看 redis 状态:
systemctl status redis
- 启动 redis:
systemctl start redis
- 重启 redis:
systemctl restart redis.service
- 查看 redis 装置目录:
ps -ef|grep redis
ps -ef|grep redis
失去过程号 29895
而后:ls -l /proc/29895/cwd
启动插件
命令:emqx_ctl plugins load emqx_backend_redis
或者到 EMQ X Dashboard 治理控制台,在 插件 -> 全副-> emqx_backend_redis 中启动插件
场景一:客户端在线状态存储
客户端高低线时,更新在线状态、高低线工夫、节点客户端列表至 Redis 数据库。
配置项
关上配置文件[配置文件目录/etc/emqx/plugins/emqx_backend_redis.conf
],配置 Backend 规定:
## 上线
backend.redis.hook.client.connected.1 = {"action": { "function": "on_client_connected"}, "pool": "pool1"}
## 下线
backend.redis.hook.client.disconnected.1 = {"action": {"function": "on_client_disconnected"}, "pool": "pool1"}
应用示例
浏览器关上 http://ip:18083
EMQ X Dashboard 治理控制台,在 工具 -> Websocket 中新建一个客户端连贯,指定 clientid 为 sub_client
执行命令:redis-cli -h 127.0.0.1 -p 6379
或者 /usr/local/soft/redis5/bin/redis-cli
关上 redis-cli
命令行窗口,执行命令 keys *
,后果如下所示,读者能够看到在 Redis 中存储了两个 key:
如果 redis 设置了明码, 应用命令:auth passward
受权
常用命令
- 连贯列表命令:
HGETALL mqtt:node:emqx@127.0.0.1
字段阐明:
## 节点下在线设施信息
127.0.0.1:6379> HGETALL mqtt:node:emqx@127.0.0.1
1) "sub_client1" # clientid
2) "1542272836" # 上线工夫工夫戳
- 连贯详细信息命令:
HGETALL mqtt:client:sub_client
字段阐明:
## 客户端在线状态
127.0.0.1:6379> HGETALL mqtt:client:sub_client
1) "state"
2) "0" # 0 离线 1 在线
3) "online_at"
4) "1542272854" # 上线工夫戳
5) "offline_at"
6) "undefined" # 离线工夫戳
客户端代理订阅
配置项
关上配置文件[配置文件目录/etc/emqx/plugins/emqx_backend_redis.conf
],配置 Backend 规定:
应用示例
当 sub_client
设施上线时,须要为其订阅 sub_client/upstream
与 sub_client/downlink
两个 QoS 1 的主题:
## redis key 为 mqtt:sub:{client_id}
## HSET key {topic} {qos}
127.0.0.1:6379> HSET mqtt:sub:sub_client sub_client/upstream 1
(integer) 1
127.0.0.1:6379> HSET mqtt:sub:sub_client sub_client/downlink 1
(integer) 1
回到 Dashboard 中,查看订阅列表,可见以后客户端主动订阅了 sub_client/upstream
与 sub_client/downlink
两个 QoS 1 的主题:
切换回治理控制台 WebSocket 页面,向 sub_client/downlink
主题公布音讯,可在音讯订阅列表收到公布的音讯。
长久化公布音讯
配置项
关上配置文件[配置文件目录/etc/emqx/plugins/emqx_backend_redis.conf
],配置 Backend 规定,反对应用 topic
参数进行音讯过滤,此处应用 #
通配符存储任意主题音讯:
应用示例
在 EMQ X 治理控制台 WebSocket 页面中,应用 clientid sub_client
建设连贯,向主题 upstream_topic
公布多条音讯。针对每条音讯,EMQ X 将长久化音讯列表、音讯详情两条记录。
常用命令
- 查看音讯列表命令:
ZRANGE mqtt:msg:upstream_topic 0 -1
## 获取 upstream_topic 主题汇合中所有 message id
127.0.0.1:6379> ZRANGE mqtt:msg:upstream_topic 0 -1
1) "Mjk2MTY1NzU0MDI1MTM4MDM4NTkwNzgzNTc2OTE4NTg5NDI"
2) "Mjk2MTY1NzUxNzExODcwNTgzODIyMzAzMDA0NTg0MTgxNzI"
3) "Mjk2MTY1NzUzMDcxOTgyNDEyOTgzNjgxNjU5NTIwMjg2NzF"
127.0.0.1:6379>
- 查看音讯详情命令:
HGETALL mqtt:msg:{key}
## 获取 message id 为 Mjk2MTY1NzU0MDI1MTM4MDM4NTkwNzgzNTc2OTE4NTg5NDI 的音讯详情
127.0.0.1:6379> HGETALL mqtt:msg:Mjk2MTY1NzU0MDI1MTM4MDM4NTkwNzgzNTc2OTE4NTg5NDI
1) "id"
2) "Mjk2MTY1NzU0MDI1MTM4MDM4NTkwNzgzNTc2OTE4NTg5NDI"
3) "from"
4) "sub_client"
5) "qos"
6) "1"
7) "topic"
8) "upstream_topic"
9) "payload"
10) "{\"msg\": \"\xe6\x88\x91\xe6\xad\xa3\xe5\x9c\xa8\xe5\xad\xa6\xe4\xb9\xa0EMQ-Redis\xe6\x8c\x81\xe4\xb9\x85\xe5\x8c\x96\xe5\x8f\x91\xe5\xb8\x83\xe6\xb6\x88\xe6\x81\xaf002\"}"
11) "ts"
12) "1605517769649"
13) "retain"
14) "false"
获取离线音讯
配置项
关上配置文件[配置文件目录/etc/emqx/plugins/emqx_backend_redis.conf
],配置 Backend 规定:
应用示例
MQTT 离线音讯需满足以下条件:
1. 以 clean_session = false 连贯
2. 订阅 QoS > 0
3. 公布 QoS > 0
在 EMQ X 治理控制台中新建一个客户端 sub_client_another
建设如下配置建设连贯往 topic:sub_client/upstream
公布音讯:
再断开 sub_client_another
的连贯,从新上线sub_client
, 能够 看到仍能收到音讯:
长久化 Retain 音讯
关上配置文件 [配置文件目录/etc/emqx/plugins/emqx_backend_redis.conf
],配置 Backend 规定:
在 Dashboard 中公布 Retain 音讯:
常用命令
- 音讯列表命令:
ZRANGE mqtt:retain:upstream_topic 0 -1
或者GETRANGE mqtt:retain:upstream_topic 0 -1
【依据 redis 存储的数据类型来获取 value 值】
- 音讯详情命令:
HGETALL mqtt:msg:Mjk2MTY3MzA0ODEyNzgzNDMyNzI0NjM4ODU5NTQ4NDI2MjJ
## 获取 message id 为 Mjk2MTY3MzA0ODEyNzgzNDMyNzI0NjM4ODU5NTQ4NDI2MjJ 的音讯详情
127.0.0.1:6379> HGETALL mqtt:msg:2VFt0kuNrOktefX6m4nP
1) "id"
2) "Mjk2MTY3MzA0ODEyNzgzNDMyNzI0NjM4ODU5NTQ4NDI2MjJ"
3) "from"
4) "sub_client"
5) "qos"
6) "2"
7) "topic"
8) "upstream_topic"
9) "payload"
10) "{\"msg\": \"now i am studing\"}"
11) "ts"
12) "1605526176485"
13) "retain"
14) "true"
至此 EMQ X 数据长久化 存储音讯到 Redis【场景一】模仿结束!
【参考文档】EMQ 官网链接:EMQ 官网 下一级
[场景二:将 EMQ X 指定主题下且满足条件的音讯存储到 Reids]:将 EMQ X 指定主题下且满足条件的音讯存储到 Reids