关于java:场景二将-EMQ-X-指定主题下且满足条件的消息存储到-Reids

该场景须要将 EMQ X 指定主题下且满足条件的音讯存储到 Reids。为了便于后续剖析检索，音讯内容须要进行拆分存储。
该场景下设施端上报信息如下：

上报主题：cmd/state/:id，主题中 id 代表车辆客户端识别码

音讯体：

{
  "id": "NXP-058659730253-963945118132721-22", // 客户端识别码
  "speed": 32.12, // 车辆速度
  "direction": 198.33212, // 行驶方向
  "tachometer": 3211, // 发动机转速，数值大于 8000 时才需存储
  "dynamical": 8.93, // 刹时油耗
  "location": { // GPS 经纬度数据
    "lng": 116.296011,
    "lat": 40.005091
  },
  "ts": 1563268202 // 上报工夫
}

当上报数据发动机转速数值大于 8000 时，存储以后信息以便后续剖析用户车辆应用状况。

关上 EMQ X Dashboard，进入左侧菜单的资源页面，点击新建按钮，键入 Redis 服务器信息进行资源创立【点击测试连贯能够测试配置是否正确】。

进入左侧菜单的规定页面，点击新建按钮，进行规定创立。界面如下：

筛选所需字段

规定引擎应用 SQL 语句解决规定条件，该业务中咱们须要将 payload 中所有字段独自抉择进去，应用 payload.fieldName 格局进行抉择，还须要音讯上下文的 topic、qos、id 信息，以后 SQL 如下：

SELECT
    payload.id AS client_id,
    payload.speed AS speed,
    payload.tachometer AS tachometer,
    payload.ts AS ts,
    id 
FROM
    "#"

确立筛选条件

应用 SQL 语句 WHERE 字句进行条件筛选，该业务中咱们须要定义两个条件：

仅解决 cmd/state/:id 主题，应用主题通配符 =~ 对 topic 进行筛选：topic =~ 'cmd/state/+'
仅解决 tachometer > 8000 的音讯，应用比拟符对 tachometer 进行筛选：payload.tachometer > 8000

组合上一步骤失去 SQL 如下：

SELECT
    payload.id AS client_id,
    payload.speed AS speed,
    payload.tachometer AS tachometer,
    payload.ts AS ts,
    id 
FROM
    "#" 
WHERE
    topic =~ 'cmd/state/+' 
    AND payload.tachometer > 8000

应用 SQL 测试性能进行输入测试

借助 SQL 测试性能，咱们能够实时查看以后 SQL 解决后的数据输入，该性能须要咱们指定 payload 等模仿原始数据。

payload 数据如下，留神更改 tachometer 数值大小，以满足 SQL 条件：

{
  "id": "NXP-058659730253-963945118132721-22",
  "speed": 32.12,
  "direction": 198.33212,
  "tachometer": 9001,
  "dynamical": 8.93,
  "location": {
    "lng": 116.296011,
    "lat": 40.005091
  },
  "ts": 1563268202
}

点击 SQL 测试 切换按钮，更改 topic 与 payload 为场景中的信息，点击测试按钮查看数据输入

测试输入数据为：

{
  "ts": 1563268202,
  "tachometer": 9001,
  "speed": 32.12,
  "id": "5B4499F88C2C0F443000013AD0000",
  "client_id": "NXP-058659730253-963945118132721-22"
}

测试输入与预期相符，咱们能够进行后续步骤。

SQL 条件输入输出无误后，咱们持续增加相应动作，配置写入 SQL 语句，将筛选后果存储到 Redis。

点击响应动作中的增加按钮，抉择 保留数据到 Redis 动作，选取刚刚选定的资源，咱们应用 ${fieldName} 语法填充 SQL 语句，将数据插入到数据库，最初点击新建按钮实现规定创立。

动作的 SQL 配置如下：

HMSET test client_id "${client_id}" speed "${speed}" tachometer "${tachometer}" ts "${ts}" msg_id "${msg_id}"

应用 Redis 的哈希表构造，以 message id 为表明创立哈希表

点击确认后能够看到有一条新规定创立胜利

咱们胜利创立了一条规定，蕴含一个解决动作，动作冀望成果如下：

设施向 cmd/state/:id 主题上报音讯时，当音讯中的 tachometer 数值超过 8000 时将命中 SQL，规定列表中 已命中 数字减少 1；
Redis 将减少一个以以后 message id 命名的哈希表，数值与以后音讯统一。

切换到工具 –> Websocket 页面，应用任意信息客户端连贯到 EMQ X，连贯胜利后在音讯卡片发送如下信息：

主题：cmd/state/NXP-058659730253-963945118132721-22
音讯体：
```
{
  "id": "NXP-058659730253-963945118132721-22",
  "speed": 32.12,
  "direction": 198.33212,
  "tachometer": 8081,
  "dynamical": 8.93,
  "location": {
    "lng": 116.296011,
    "lat": 40.005091
  },
  "ts": 1563268202
}
```
点击发送按钮，查看失去以后规定已命中统计值为 1。

Redis 命令行中查看哈希表

获取单个列命令：hget ${key} ${field} , 例：hget test speed,hget test tachometer

获取所有列命令：HGETALL ${key}, 例：HGETALL test
记录失去数据如下：

至此，咱们通过规定引擎实现了应用规定引擎存储音讯到 Reids 的业务开发。

【参考文档】EMQ 官网链接：EMQ 官网
返回上一级EMQ X 数据长久化存储音讯到 Redis

关于java:场景二将-EMQ-X-指定主题下且满足条件的消息存储到-Reids

场景介绍

DashBoard 配置

创立资源

创立规定

增加响应动作，存储音讯到 Redis

测试

预期后果

应用 Dashboard 中的 Websocket 工具测试