关于物联网:EMQX-v445-发布新增排他订阅及-MQTT-50-发布属性支持

7次阅读

共计 2139 个字符,预计需要花费 6 分钟才能阅读完成。

近日,EMQX 开源版 v4.3.16、开源版 v4.4.5 与企业版 v4.3.11、企业版 v4.4.5 四个保护版本正式公布。

此次公布实现了与流数据库 HStreamDB 的集成,提供一站式数据接入与实时处理剖析。新增了排他订阅性能和规定引擎音讯重公布时动静 QoS 与保留音讯设置反对,同时反对在音讯公布的 API 中设置 MQTT 5.0 的公布属性(PUBLISH Properties),帮忙用户应答更多场景应用需要。此外还修复了多项已知 BUG。

欢送下载应用:https://www.emqx.com/zh/try?p…

规定引擎新性能

集成 HStreamDB,一站式数据接入、存储与剖析

蕴含版本 企业版 v4.3.11 企业版 v4.4.5

HStreamDB 是一款为物联网数据存储和实时处理而生的流数据库。它应用规范 SQL (及其流式拓展)作为次要接口语言,以实时性作为次要特色,集实时数据采集和捕捉零碎、实时数据存储系统、流计算引擎、上游的数据和利用零碎于一体,旨在简化数据流的运维治理以及实时利用的开发。

规定引擎现已反对将 EMQX 的数据长久化到 HStreamDB,从而实现对这些数据的实时处理剖析与洞察。性能测试中,EMQX 在 32 核 64GB 配置下能够稳固反对 8 万连贯、每秒 8 万 QoS 0、Payload 4KB 的音讯长久化至 HStreamDB,集成应用形式请参照文档。

音讯重公布动作反对保留音讯与动静 QoS

蕴含版本 开源版 v4.3.16 开源版 v4.4.5 企业版 v4.3.11 企业版 v4.4.5

咱们在音讯重公布性能中引入保留音讯和动静 QoS 反对,以满足用户特定的场景下的需要。其中保留音讯需要来源于 EMQX 问答社区,旨在将客户端最新状态通过保留音讯存储到 EMQX 中以便后续解决。

新增排他订阅性能

蕴含版本 开源版 v4.3.16 开源版 v4.4.5 企业版 v4.3.11 企业版 v4.4.5

排他订阅只容许单个订阅者订阅某个主题,应用排他订阅时,能够轻松实现「某些数据同时只能被一个订阅者解决」这类业务。

排他订阅的应用与共享订阅十分相似,应用特定的主题前缀 $exclusive 表明这是一个排他订阅,某个客户端订阅胜利后,新的客户端将无奈再次订阅雷同主题。

排他订阅默认敞开,须要在此配置项中开启:

mqtt.exclusive_subscription = true

排他订阅失效示例:

// 胜利
clientA.subscribe('$exclusive/t/1')

// 失败,该主题已有订阅者
clientB.subscribe('$exclusive/t/1')

// 胜利,不带前缀的一般主题依然能够胜利订阅
clientC.subscribe('t/1')

// 须要携带前缀以勾销订阅
clientA.unsubscribe('$exclusive/t/1')
// 胜利
clientB.subscribe('$exclusive/t/1')

音讯公布 API 反对设置 MQTT 5.0 公布属性(PUBLISH Properties)

蕴含版本 开源版 v4.4.5 企业版 v4.4.5

MQTT 5.0 反对在音讯公布时设置额定的属性如音讯过期间隔、主题别名和用户属性等,新版本中用户能够在音讯公布 API 中应用此个性,以满足更多业务需要。

以下是蕴含公布属性的音讯公布示例:

curl -i --basic -u admin:public -X POST "http://localhost:8081/api/v4/mqtt/publish" -d \
'{"topic":"t/1","payload":"Hello World","qos":1,"retain":false,"clientid":"emqx_c","properties": {"user_properties": {"id": 10010,"name":"emqx","foo":"bar"},"content_type":"text/plain","message_expiry_interval": 3600
  }
}'

更多功能优化

  • 反对通过 CLI 一键更新集群 License
  • Dashboard 和治理 API 的 HTTPS 监听器能够应用受密码保护的私钥文件,提供了 key_password 配置项
  • 反对在主题重写规定中应用占位符 %u%c
  • 优化规定引擎资源创立时的 UI,例如折叠局部不罕用的选项等
  • 为 ExHook 底层的 gRPC 连贯凋谢了 KeepAlive、TCP_NODELAY、SO_RCVBUF 和 SO_SNDBUF 共 4 个与 TCP 相干的配置项

BUG 修复

各版本 BUG 修复详情请查看:

  • 开源版 v4.3.16:https://www.emqx.com/zh/chang…
  • 开源版 v4.4.5:https://www.emqx.com/zh/changelogs/broker/4.4.5
  • 企业版 v4.3.11:https://www.emqx.com/zh/chang…
  • 企业版 v4.4.5:https://www.emqx.com/zh/chang…

版权申明:本文为 EMQ 原创,转载请注明出处。

原文链接:https://www.emqx.com/zh/blog/emqx-update-integrated-streaming-database

正文完
 0