## 基于边缘架构的可编程MQTT服务 网聚云联 王文庭 ## 极客时间App — 数字人才的专属学习空间  ## 极客时间 极客时间是数字人才的专属学习空间，有近 200+ 体系课和 1400+ 技术视频。为学员提供系统化、场景化、工具化和游戏化的学习服务 简介 ## HPMQ (Hyperconverged Programmable MQTT)  HPMQ是基于Rust语言开发的下一代可编程边缘分布式MQTT软件，主要有以下几个核心特性： • Geo–Distributed • 可编程性 Safari四大浏览器都开始实验性的支持 - 它在浏览器以外也有很广泛的运用，特别是在边缘计算领域。 - 支持多语言开发，比如Go，Python, rust, Javascript等 ## Serverless in MQTT Broker 1. 所需求运行资源小( $ \sim $ 64Kb for code and $ \sim $ 10Kb RAM) 2. 异构设备兼容性强(x86, ARM, RISC-V

## MQTT MQTT is a lightweight connectivity protocol. It is designed to run in environments where device and networks are constrained. Out of the box Apache ActiveMQ Artemis supports version MQTT 3.1 implementations on the server so you can use respective clients for these protocols: 1. AMQP 2. OpenWire 3. MQTT 4. STOMP 5. HornetQ (for use with HornetQ clients). 6. CORE (Artemis CORE protocol) JMS semantics [--no-amqp-acceptor] [--no-autocreate] [--no-autotune] [--no-fsync] [--no-hornetq-acceptor] [--no-mqtt-acceptor] [--no-stomp-acceptor] [--no-web] [--paging] [--password [ [--ping ]

based on the MQTT protocol [http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html], and supports four access methods: TCP, SSL, WS, and WSS; - The official module baetyl-remote-mqtt is used to bridge two MQTT Servers for message synchronization and supports configuration of multiple message route rules. ; - The official module baetyl-function-manager provides computing power based on MQTT message OTA. • baetyl-hub: Provides an MQTT-based message routing service. - baetyl-remote-mqtt: Provides a bridge services for synchronizing messages between Hub and remote MQTT services. - baetyl-function-manager:

baetyl-function-manager Configuration 40 6.6 baetyl-function-python Configuration 41 6.7 baetyl-remote-mqtt Configuration ..... 41 6.8 baetyl-timer Configuration ..... 43 7 Device connect to Baetyl with between Baetyl-Hub and Baidu IoTHub via Baetyl-Remote-MQTT module ..... 69 10.1 Workflow ..... 69 10.2 Message Synchronize via Baetyl-Remote-MQTT module ..... 70 11 How to write a python script .... 108 17 FAQ ..... 111 18 Download ..... 115 18.1 Golang download ..... 115 18.2 MQTT download ..... 115 Baetyl, extend cloud computing, data and service seamlessly to edge devices.

Settings 1.10.2 Protocols and Interoperability 1.11 AMQP 1.12 Broker Connections 1.12.1 MQTT 1.13 STOMP 1.14 OpenWire 1.15 Core 1.16 Mapping JMS Concepts to the Core API 1.17 Using pattern used for MQTT shared subscription queues has changed. Previously the subscription queue was named according to the subscription name provided in the MQTT SUBSCRIBE packet. However, MQTT allows the same topic name so that all subscription queue names will be unique. Before upgrading please ensure all MQTT shared subscriptions are empty. When the subscribers reconnect they will get a new subscription queue

Baidu IoTHub via Remote Service 71 10.1 Workflow 71 10.2 Message Synchronize via baetyl-remote-mqtt service 72 11 Image capturing and AI model inference with Video infer Service 81 11.1 Workflow 17.2 Start/Stop Convention 118 17.3 SDK 118 18 FAQ 121 19 Resources Download 125 19.1 MQTT download 125 20 Pre-release 0.1.6(2019-09-23) 127 20.1 New features 127 20.2 Bugfixes 127 20 publishing functions based on the MQTT protocol, and supports four access methods: TCP, SSL, WS, and WSS; • The official module baetyl-remote-mqtt is used to bridge two MQTT Servers for message synchronization

o baetyl-function-manager Configuration • baetyl-function-python Configuration • baetyl-remote-mqtt Configuration • baetyl-timer Configuration • Device connect to Baetyl with Hub service o Workflow Synchronize between Baetyl-Hub and Baidu IoTHub via Baetyl-Remote-MQTT module o Workflow ☐ Message Synchronize via Baetyl-Remote-MQTT module ## Development • How to write a python script for Python Start/Stop Convention ○ SDK Troubleshooting • FAQ Resources • Download • Golang download • MQTT download ## What is Baetyl Baetyl [https://baetyl.io] is an open edge computing framework of Linux

25 7.10. Web Sockets ..... 26 7.11. Flow Control ..... 27 8. MQTT ..... 28 8.1. MQTT Quality of Service ..... 28 8.2. MQTT Retain Messages ..... 29 8.3. Will Messages ..... 29 8.4. Debug 512 87.30. Interceptor AMQP ..... 512 87.31. Interceptor Client ..... 512 87.32. Interceptor MQTT ..... 512 87.33. JAAS ..... 513 87.34. JMS Auto Closable ..... 513 87.35. JMS Completion Listener implementations on the server so you can use respective clients for these protocols: • AMQP • OpenWire • MQTT • STOMP • HornetQ (for use with HornetQ clients). • Core (Artemis CORE protocol) JMS semantics

25 7.10. Web Sockets ..... 26 7.11. Flow Control ..... 27 8. MQTT ..... 28 8.1. MQTT Quality of Service ..... 28 8.2. MQTT Retain Messages ..... 29 8.3. Will Messages ..... 29 8.4. Debug 514 87.30. Interceptor AMQP ..... 514 87.31. Interceptor Client ..... 514 87.32. Interceptor MQTT ..... 514 87.33. JAAS ..... 515 87.34. JMS Auto Closable ..... 515 87.35. JMS Completion Listener implementations on the server so you can use respective clients for these protocols: • AMQP • OpenWire • MQTT • STOMP • HornetQ (for use with HornetQ clients). • Core (Artemis CORE protocol) JMS semantics

25 7.10. Web Sockets ..... 26 7.11. Flow Control ..... 27 8. MQTT ..... 28 8.1. MQTT Quality of Service ..... 28 8.2. MQTT Retain Messages ..... 29 8.3. Will Messages ..... 29 8.4. Debug 514 87.30. Interceptor AMQP ..... 514 87.31. Interceptor Client ..... 514 87.32. Interceptor MQTT ..... 514 87.33. JAAS ..... 515 87.34. JMS Auto Closable ..... 515 87.35. JMS Completion Listener able to interact with Apache ActiveMQ Artemis. Please see AMQP for more details. ##### 5.1.2. MQTT MQTT is a lightweight connectivity protocol. It is designed to run in environments where device and