EMQX 多版本发布：规则引擎支持重置运行数据、新增连接确认与鉴权完成事件

包含版本：开源版 v4.4.3 、企业版 v4.4.3

规则的使用统计指标反馈了业务负载情况，用户可以在排除规则故障、升级服务器规格之后重置统计规则执行数量与执行速度等指标，以便查看调整后的运行效果。

-- 连接确认事件
SELECT * FROM "$events/client_connack"

-- 鉴权完成事件
SELECT * FROM "$events/client_check_acl_complete"

包含版本：开源版 v4.3.14、开源版 v4.4.3、 企业版 v4.3.9 、企业版 v4.4.3

在流量成本较高或传输大量可压缩数据的情况下，可以对消息进行压缩/解压缩处理，以节省流量开销并获得更快的传输时间，支持 zip、gzip 压缩算法，以下是示例 SQL 语句：

SELECT 
  zip(payload) as p,
  unzip(p) as c,
  gzip(payload) as p2,
  gunzip(p2) as c2
FROM "t/#"

实际测试中，大量具有重复键值的 JSON 文本可以获得极高的压缩率，对于此类场景，计算能力充足的条件下可以使用压缩算法大大缩短传输时间。

值得一提的是我们注意到一种新的二进制数据格式 CBOR（RFC 7049：https://datatracker.ietf.org/doc/html/rfc7049）由于拥有良好压缩性和扩展性强非常适用于物联网传输，有人将其比喻为「二进制版本的 JSON」。

我们计划在后续版本的规则引擎中提供此格式的编解码能力，以探索更快、更高效的物联网的数据传输可能性。

包含版本：企业版 v4.3.9、企业版 v4.4.3

此前通过规则引擎向 MongoDB 写入数据时，时间类型的数据只能以字符或整型的方式存储，本次更新我们新增 mongo_date 以支持此功能。

包含版本：企业版 v4.3.9、企业版 v4.4.3

此前的 企业版 v4.3.8 中我们提供了 Pulsar Proxy （https://pulsar.apache.org/docs/en/administration-proxy/）的支持，本次更新我们新增 Pulsar 资源 TLS 连接，为规则引擎数据集成提供更好的安全性。

包含版本：企业版 v4.3.9、企业版 v4.4.3

编解码是规则引擎中的 UDF（用户自定义函数）能够扩展规则 SQL 函数，本次更新我们提供了 gRPC 通道，相比 HTTP 能够以更低的开销完成相同的需求，在 16 核 32GB 的服务器上，能够稳定实现 20K/s 的调用处理。

包含版本：开源版 v4.3.14，开源版 v4.4.3，企业版 v4.3.9，企业版 v4.4.3

ExHook 允许用户使用其它编程语言（例如：Python、Java 等）直接向 EMQX 挂载钩子，以接收并处理 EMQX 系统的事件，达到扩展和定制 EMQX 的目的，类似于使用其他编程语言开发 EMQX 的插件。

在实际使用中，根据场景不同一部分用户需要使用 ExHook 接管现有 EMQX 插件，另一部分用户希望将 ExHook 置于插件之后作为插件能力的补充，ExHook 挂载钩子的顺序就成为实现这一目标的关键。

尽管可以通过插件的启动顺序（ExHook 本身也是一个插件）设置 ExHook 相对插件的位置，但此操作比较繁琐且 EMQX 重启后会丢失顺序，因此我们迫切需要一个能够固定插件优先级的方式。

本次更新 EMQX 允许指定 ExHook 的优先级，以便更好的与插件和规则引擎配合使用。

## plugin/emqx_exook.conf
exhook.hook_priority = 0

包含版本：开源版 v4.3.14，开源版 v4.4.3，开源版 v4.3.9，开源版 v4.4.3

我们在 ExHook 回调接口字段中添加了集群名称，多个 EMQX 集群共用一个 ExHook gRPC 服务时，用户可以根据集群名称将请求路由到不同的业务逻辑。

包含版本：开源版 v4.3.14，开源版 v4.4.3，企业版 v4.3.9，企业版 v4.4.3

local 策略允许在集群环境下优先给消息流入的节点上的共享订阅者派发消息，这可能会对负载均衡带来一些影响，但是在某些场景下会提升共享消息调度的效率，尤其是在将 MQTT Bridge 配置为共享订阅时。

此外，EMQX 现在既可以配置全局的共享订阅分发策略，也可以为每个共享订阅组配置独立的分发策略，你可以在 emqx.conf
文件中找到以下配置项：

broker.shared_subscription_strategy = random
broker.your_group.shared_subscription_strategy = local