博客

本文主要介绍使用 Kotlin 语言在 Android 平台上使用 MQTT，实现安卓客户端与 MQTT 服务器的连接、主题订阅、收发消息等功能。

Kuiper 0.4.1 版本支持通过 Docker 环境变量来修改 EdgeX MQTT 消息总线的配置，支持插件多实例，以及 http_pull 源支持。

该文章描述了如何在 EdgeX 中使用 EMQX Kuiper 规则引擎，并根据分析结果来实现对物联网设备的控制。

在 EdgeX Geneva 版本中, EMQX Kuiper - 基于 SQL 的轻量级流式数据处理软件与 EdgeX 进行了集成。本教程将介绍如何使用 Kuiper 处理来自于 EdgeX 的数据。

在此项目中我们将实现 ESP8266 连接到 EMQX Cloud 运营和维护的免费公共 MQTT 服务器，并使用 Arduino IDE 来对 ESP8266 进行编程。

该版本新增： MQTT 5.0 更多属性、单击已订阅的 Topic 项实现消息过滤、点击 Topic 名称后快速复制 Topic 信息、启用严格的证书验证选项。

Kuiper 0.4.0 对比较复杂的插件支持的能力上得到了增强；支持了对所有 sink 的模版支持功能，实现对复杂数据输出的定制能力。

EMQX Broker v4.1-beta.1 正式发布，此版本重点增加了对 Python 与 Java 的扩展支持，以及支持 MQTT 增强认证。

Kuiper 插件基于 Go 语言的插件机制，用户可以构建松散耦合的插件程序，在运行时动态加载和绑定。

EMQX 的主题重写功能支持根据用户配置的规则在 MQTT 客户端订阅主题、发布消息、取消订阅的时候将 A 主题重写为 B 主题。

本版本中 Kuiper & EdgeX 集成已经基本完成，近期将把 Kuiper 的 Docker 镜像包含在 EdgeX 的 nightly Docker composer 文件中。Kuiper 0.3.1 将正式与 EdgeX Geneva 版本一起发布。

EMQX Broker 的 MQTT 保留消息功能是由 emqx_retainer 插件实现，该插件默认开启，通过修改 emqx_retainer 插件的配置，可以调整 EMQX Broker 储存保留消息的位置，限制接收保留消息数量和 Payload 最大长度，以及调整保留消息的过期时间。