关于物联网:从零开始上手-MQTT-over-QUIC快速体验下一代物联网标准协议

57次阅读

共计 6559 个字符，预计需要花费 17 分钟才能阅读完成。

前言

QUIC(RFC9000) 是下一代互联网协议 HTTP/3 的底层传输协定，与 TCP/TLS 协定相比，它 在缩小连贯开销与音讯提早的同时，为古代挪动互联网提供了无效灵便的传输层。

EMQX 5.0 是首个将 QUIC 引入 MQTT 的开创性产品。在长期的客户服务和技术摸索中，咱们留神到 QUIC 的个性可能和一些物联网场景完满符合，于是尝试将 MQTT 的传输层替换成 QUIC，由此诞生了 MQTT over QUIC。

正如 MQTT over QUIC：物联网音讯传输还有更多可能 一文所述，在网络不稳固、连贯多变的物联网场景下，QUIC 低连贯开销和多路径反对的个性就显示出了其当先的劣势。测试数据也表明，基于 QUIC 0 RTT/1 RTT 重连 / 新建能力，MQTT over QUIC 可能在弱网与不固定的网络通路中无效晋升用户体验。

EMQ 正以世界出名开源和凋谢规范机构 OASIS 的 Foundational Sponsor 身份踊跃推动 MQTT over QUIC 的标准化落地。事实上，目前曾经有一部分客户开始尝试将这一新个性投入使用并取得了良好的反馈。为了更多用户能体验到 MQTT over QUIC 为物联网音讯传输带来的晋升，咱们将通过本文领导您如何从零开始上手应用 MQTT over QUIC。

启用 MQTT over QUIC

MQTT over QUIC 个性随 EMQX 5.0 公布。因为是试验性功能，在 CentOS 6、macOS 以及 Windows 零碎下并未蕴含 QUIC 编译，请自行从源码编译并在编译前指定环境变量 BUILD_WITH_QUIC=1，其余操作系统和平台则能够失常应用。

MQTT over QUIC 默认不可用，请通过以下配置手动开启。

  1. 关上配置文件 etc/emqx.conf，勾销 listeners.quic.default 配置组的正文（如果没有此配置组请手动增加）：

    # etc/emqx.conf
listeners.quic.default {
  enabled = true
  bind = "0.0.0.0:14567"
  max_connections = 1024000
  keyfile = "etc/certs/key.pem"
  certfile = "etc/certs/cert.pem"
}
  2. 该配置示意启用 QUIC 监听器并绑定 UDP 14567 端口，保留胜利后请重启 EMQX 以利用配置。

  3. 执行 emqx_ctl listeners 命令，可在后果中看到 MQTT over QUIC 监听器已启用：

    > emqx_ctl listeners
quic:default
  listen_on       : :14567
  acceptors       : 16
  proxy_protocol  : undefined
  running         : true
ssl:default
  listen_on       : 0.0.0.0:8883
  acceptors       : 16
  proxy_protocol  : false
  running         : true
  current_conn    : 0
  max_conns       : 512000

您也能够应用 Docker，通过环境变量选取 UDP 14567 作为 QUIC 端口疾速体验：

docker run -d --name emqx \
  -p 1883:1883 -p 8083:8083 \
  -p 8084:8084 -p 8883:8883 \
  -p 18083:18083 \
  -p 14567:14567/udp \
  -e EMQX_LISTENERS__QUIC__DEFAULT__keyfile="etc/certs/key.pem" \
  -e EMQX_LISTENERS__QUIC__DEFAULT__certfile="etc/certs/cert.pem" \
  -e EMQX_LISTENERS__QUIC__DEFAULT__ENABLED=true \
emqx/emqx:5.0.10

MQTT over QUIC 客户端与工具

相比于 MQTT 而言，目前 MQTT over QUIC 依然短少残缺的客户端库和工具链反对。

咱们针对 MQTT over QUIC 的实用场景，打算提供 C、Java、Python、Golang 等多个语言的客户端库并依照优先级一一反对，确保嵌入式硬件等这类符合场景的业务可能率先将 QUIC 利用起来。

已有的客户端 SDK

  • NanoSDK：由 NanoMQ 团队公布的 C 语言的 MQTT SDK，除 MQTT over QUIC 外还反对 WebSocket、nanomsg/SP 等多协定
  • NanoSDK-Python：NanoSDK 的 Python 语言 binding
  • NanoSDK-Java：NanoSDK 的 Java JNA binding
  • emqtt：Erlang 语言的 MQTT 客户端库，反对 QUIC

除了客户端库之外，EMQ 还在边缘计算产品 NanoMQ 中提供了 MQTT over QUIC 桥接反对，在特定的利用中您能够借助 NanoMQ 实现边缘数据通过 QUIC 桥接上云，无需过多开发集成即可利用 MQTT over QUIC 的个性。

问题与解决

在开发中，思考到 QUIC 基于 UDP 协定，目前许多运营商依然对 UDP 包有非凡的路由策略，这往往导致 QUIC 连贯无奈胜利建设或始终被丢包。

因而 MQTT over QUIC 客户端设计反对了 fallback 能力：API 层可能应用对立的操作编写业务，传输层则依据网络状况实时切换，当 QUIC 不可用时主动切换为 TCP/TLS 1.2，确保各类网络环境下业务都能失常运行。

通过 NanoSDK 实现 MQTT over QUIC 连贯

NanoSDK 基于 MsQuic 我的项目率先实现了第一个 C 语言的 MQTT over QUIC SDK，能无缝兼容 EMQX 5.0。外部采纳全异步 IO 设计，将 QUIC Stream 和 MQTT 连贯映射绑定，并内置实现了 0RTT 疾速握手重连性能，反对多核工作并行。

NanoSDK 应用示例

API 方面放弃了之前的应用习惯，一行代码即可基于 QUIC 创立 MQTT 客户端：

## Create MQTT over Quic client with NanoSDK
nng_mqtt_quic_client_open(&socket, url);

音讯示例代码请参考：NanoSDK

编译后能够通过以下命令连贯 EMQX 5.0 的 14567 端口进行测试。

quic_client sub/pub mqtt-quic://54.75.171.11:14567 topic msg

NanoSDK 也提供 Java 和 Python 的 binding。

通过 NanoMQ 桥接实现 MQTT 3.1.1/5.0 与 MQTT over QUIC 的转换兼容

NanoMQ 是一款超轻量、高性能且跨平台的边缘 MQTT 音讯引擎，兼具多协定音讯总线性能，反对 MQTT over QUIC 桥接性能。它可能将传统 MQTT 客户端的数据转换成 QUIC 数据包并发给云端的 EMQX，从而为无奈集成或找到适合 MQTT over QUIC SDK 的端侧设施和难以批改固件的嵌入式设施提供在 IoT 场景利用 QUIC 协定劣势的捷径，升高应用门槛。

在须要与云端 MQTT 服务进行数据同步的各种物联网场景中，通过 NanoMQ 的多协定接入能力，您能够将其作为边缘音讯总线和对立的数据空间，对立汇聚诸如 HTTP、MQTT 3.1.1/5.0、WebSocket、nanomsg/nng 和 ZeroMQ 等罕用的 broker/brokerless 音讯协定，再由 NanoMQ 外部弱小的 Actor 音讯解决模型转化成规范的 MQTT 音讯后，通过 QUIC 传输层上云传输。

借此充分利用 MQTT over QUIC 0RTT 疾速重连和被动地址切换等性能来克服网际漫游、弱网传输和 TCP 队头阻塞等各类常见的物联网连贯问题。您还能够通过 NanoMQ 的规定引擎对数据做重定向、本地缓存或长久化。

依附 EMQX+NanoMQ 的云边一体化的音讯架构，用户可能疾速且低成本的在泛物联网场景中实现跨时空地区的数据采集和同步需要。

值得一提的是，NanoMQ 反对 QUIC 连贯失败时主动切换至规范 MQTT over TCP 桥接的能力，这可能确保您的应用不受网络环境限度。

NanoMQ 桥接示例

下载安装 NanoMQ：

git clone https://github.com/emqx/nanomq.git
cd nanomq ; git submodule update --init --recursive

mkdir build && cd build
cmake -G Ninja -DNNG_ENABLE_QUIC=ON ..
sudo ninja install

开启 QUIC 桥接性能的 NanoMQ 编译装置实现后，能够在配置文件 /etc/nanomq.conf 中配置 MQTT over QUIC 桥接性能和对应的主题，应用 mqtt-quic 作为 URL 前缀即是采纳 QUIC 作为 MQTT 的传输层：

## Bridge address: host:port .
##
## Value: String
## Example: ## Example: mqtt-tcp://broker.emqx.io:1883（这是规范 MQTT over TCP）bridge.mqtt.emqx.address=mqtt-quic://54.75.171.11:14567

MQTT over QUIC CLI 工具

NanoMQ 还提供了 nanomq_cli，其中蕴含有 MQTT over QUIC 的客户端工具供用户测试 EMQX 5.0 的 MQTT over QUIC 性能：

nanomq_cli quic --help
Usage: quic conn <url>
       quic sub  <url> <qos> <topic>
       quic pub  <url> <qos> <topic> <data>

## subscribe example
nanomq_cli quic sub mqtt-quic://54.75.171.11:14567 2 msg

综上所述，您能够间接将 NanoSDK 集成到我的项目中，亦能够搭配 NanoMQ 应用，实现设施侧到云端的 QUIC 接入。

将 emqtt-bench 用于 QUIC 性能测试

emqtt-bench 是一个 MQTT 性能基准测试工具，其同样提供了 QUIC 反对，咱们用它实现了 MQTT over QUIC vs TCP/TLS 的性能比照测试。用户能够利用其做利用的 Benchmark，或在理论环境中验证 MQTT over QUIC 的性能与收益。

编译 emqtt-bench

编译要求有 Erlang 环境，以 macOS 为例装置 Erlang 和 Coreutils：

brew install coreutils 
brew install erlang@24

通过源码编译 emqtt-bench

git clone https://github.com/emqx/emqtt-bench.git 
cd emqtt-bench 
CMAKE_BUILD_TYPE=Debug BUILD_WITH_QUIC=1 make

编译胜利有以下提醒：

...
===> Warnings generating release:
*WARNING* Missing application sasl. Can not upgrade with this release
===> Release successfully assembled: _build/emqtt_bench/rel/emqtt_bench
===> Building release tarball emqtt_bench-0.3+build.193.ref249f7f8.tar.gz...
===> Tarball successfully created: _build/emqtt_bench/rel/emqtt_bench/emqtt_bench-0.3+build.193.ref249f7f8.tar.gz

可能会遇到如下谬误，疏忽即可：

/Users/patilso/emqtt-bench/scripts/rename-package.sh: line 9: gsed: command not found 
/Users/patilso/emqtt-bench/scripts/rename-package.sh: line 9: gsed: command not found 
/Users/patilso/emqtt-bench/scripts/rename-package.sh: line 9: gsed: command not found 
/Users/patilso/emqtt-bench/scripts/rename-package.sh: line 9: gsed: command not found

测试 QUIC

进入编译输入目录：

cd _build/emqtt_bench/rel/emqtt_bench/bin

通过指定 --quic 选项以应用 QUIC 协定发动连贯并进行订阅，此处应用 10 个客户端订阅 t/1 主题：

./emqtt_bench sub -p 14567 --quic -t t/1 -c 10

新开另一个窗口，同样应用 QUIC 协定连贯并进行公布测试：

./emqtt_bench pub -p 14567 --quic -t t/1 -c 1

此时将进入 1 pub 10 sub 的性能测试：

查看本地 UDP 14567 端口应用状况：

$ lsof -nP -iUDP | grep 14567

com.docke 29372 emqx   76u  IPv6 0xea2092701c033ba9      0t0  UDP *:14567
beam.smp  50496 emqx   39u  IPv6 0xea2092701c014eb9      0t0  UDP [::1]:52335->[::1]:14567
beam.smp  50496 emqx   40u  IPv6 0xea2092701c017689      0t0  UDP [::1]:56709->[::1]:14567
beam.smp  50496 emqx   41u  IPv6 0xea2092701c0151c9      0t0  UDP [::1]:52175->[::1]:14567
beam.smp  50496 emqx   42u  IPv6 0xea2092701c0157e9      0t0  UDP [::1]:54050->[::1]:14567
beam.smp  50496 emqx   43u  IPv6 0xea2092701c015af9      0t0  UDP [::1]:58548->[::1]:14567
beam.smp  50496 emqx   44u  IPv6 0xea2092701c013639      0t0  UDP [::1]:52819->[::1]:14567
beam.smp  50496 emqx   45u  IPv6 0xea2092701c016119      0t0  UDP [::1]:57351->[::1]:14567
beam.smp  50496 emqx   46u  IPv6 0xea2092701c017999      0t0  UDP [::1]:52353->[::1]:14567
beam.smp  50496 emqx   47u  IPv6 0xea2092701c017ca9      0t0  UDP [::1]:57640->[::1]:14567
beam.smp  50496 emqx   48u  IPv6 0xea2092701c014ba9      0t0  UDP [::1]:55992->[::1]:14567
beam.smp  51015 emqx   39u  IPv6 0xea2092701c017069      0t0  UDP [::1]:64686->[::1]:14567

如果你对 emqtt-bench 感兴趣，能够查看更多命令行帮忙：

./emqtt_bench pub –help 

./emqtt_bench conn –help 

./emqtt_bench --help

结语

以上就是 MQTT over QUIC 的初步体验，可见从 API 和治理层面，客户端库以及 EMQX 可能做到与 MQTT 统一的体验，仅替换传输层以充分利用 QUIC 个性，这极大不便了开发者的应用以及 MQTT over QUIC 的遍及。

随着对 MQTT over QUIC 在理论场景中的深刻应用，用户也将能感触到其所具备的更高级的拥塞管制、连贯平滑迁徙、端到端加密、缩小握手提早等劣势个性。在后续的推送中，咱们也将对这些个性背地的技术原理以及最佳实际进行具体解读，敬请关注。

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

原文链接：https://www.emqx.com/zh/blog/getting-started-with-mqtt-over-quic-from-scratch

正文完
物联网
发表至： 物联网
2022-11-28
 0
关于物联网:智慧光伏数字孪生三维可视化运维系统解决方案
关于物联网:标准物模型设备无缝对接IOT界的福音
关于物联网:展锐新一代4G芯片平台T616和T606来了
关于物联网:LoraWan的第一个网关与设备