关于java:EMQ-X-数据持久化-存储消息到-Redis

58次阅读

共计 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/upstreamsub_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/upstreamsub_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

正文完
 0