rust-iot

Compare original and translation side by side

🇺🇸

Original

English

🇨🇳

Translation

Chinese

IoT Development

IoT 开发

Domain Constraints

领域约束

Domain Rule	Design Constraint	Rust Implication
Unreliable network	Offline-first	Local buffering
Power constraints	Efficient code	Sleep modes, minimal alloc
Resource limits	Small footprint	no_std where needed
Security	Encrypted comms	TLS, signed firmware
Reliability	Self-recovery	Watchdog, error handling
OTA updates	Safe upgrades	Rollback capability

领域规则	设计约束	Rust 相关实现
不可靠网络	离线优先	本地缓冲
电源限制	高效代码	睡眠模式、最小化内存分配
资源受限	小内存占用	必要时使用no_std
安全性	加密通信	TLS、签名固件
可靠性	自我恢复	看门狗、错误处理
OTA更新	安全升级	回滚能力

Critical Rules

关键规则

Network can fail at any time — design offline-first with local queue and retry with backoff.
Minimize power consumption — use sleep modes and efficient algorithms for battery life.
All communication encrypted — physical access is possible, use TLS and signed messages.

网络随时可能故障 —— 采用离线优先设计，搭配本地队列和退避重试机制。
最小化功耗 —— 使用睡眠模式和高效算法以延长电池寿命。
所有通信均加密 —— 设备可能被物理访问，需使用TLS和签名消息。

Environment Comparison

环境对比

Environment	Stack	Crates
Linux gateway	tokio + std	rumqttc, reqwest
MCU device	embassy + no_std	embedded-hal
Hybrid	Split workloads	Both

环境	技术栈	依赖库（Crates）
Linux网关	tokio + std	rumqttc, reqwest
MCU设备	embassy + no_std	embedded-hal
混合环境	拆分工作负载	以上两者

Key Crates

核心依赖库（Key Crates）

Purpose	Crate
MQTT (std)	rumqttc, paho-mqtt
Embedded	embedded-hal, embassy
Async (std)	tokio
Async (no_std)	embassy
Logging (no_std)	defmt
Logging (std)	tracing

用途	Crate
MQTT（std环境）	rumqttc, paho-mqtt
嵌入式开发	embedded-hal, embassy
异步（std环境）	tokio
异步（no_std环境）	embassy
日志（no_std环境）	defmt
日志（std环境）	tracing

Design Patterns

设计模式

Pattern	Purpose	Implementation
Pub/Sub	Device comms	MQTT topics
Edge compute	Local processing	Filter before upload
OTA updates	Firmware upgrade	Signed + rollback
Power mgmt	Battery life	Sleep + wake events
Store & forward	Network reliability	Local queue

模式	用途	实现方式
发布/订阅（Pub/Sub）	设备通信	MQTT主题
边缘计算	本地数据处理	上传前过滤数据
OTA更新	固件升级	签名固件 + 回滚机制
电源管理	延长电池寿命	睡眠 + 唤醒事件
存储转发	网络可靠性保障	本地队列

MQTT Client Pattern

MQTT客户端实现示例

rust

use rumqttc::{AsyncClient, MqttOptions, QoS};

async fn run_mqtt() -> anyhow::Result<()> {
    let mut options = MqttOptions::new("device-1", "broker.example.com", 1883);
    options.set_keep_alive(Duration::from_secs(30));

    let (client, mut eventloop) = AsyncClient::new(options, 10);

    // Subscribe to commands
    client.subscribe("devices/device-1/commands", QoS::AtLeastOnce).await?;

    // Publish telemetry
    tokio::spawn(async move {
        loop {
            let data = read_sensor().await;
            client.publish("devices/device-1/telemetry", QoS::AtLeastOnce, false, data).await.ok();
            tokio::time::sleep(Duration::from_secs(60)).await;
        }
    });

    // Process events with reconnection
    loop {
        match eventloop.poll().await {
            Ok(event) => handle_event(event).await,
            Err(e) => {
                tracing::error!("MQTT error: {}", e);
                tokio::time::sleep(Duration::from_secs(5)).await;
            }
        }
    }
}

rust

use rumqttc::{AsyncClient, MqttOptions, QoS};

async fn run_mqtt() -> anyhow::Result<()> {
    let mut options = MqttOptions::new("device-1", "broker.example.com", 1883);
    options.set_keep_alive(Duration::from_secs(30));

    let (client, mut eventloop) = AsyncClient::new(options, 10);

    // Subscribe to commands
    client.subscribe("devices/device-1/commands", QoS::AtLeastOnce).await?;

    // Publish telemetry
    tokio::spawn(async move {
        loop {
            let data = read_sensor().await;
            client.publish("devices/device-1/telemetry", QoS::AtLeastOnce, false, data).await.ok();
            tokio::time::sleep(Duration::from_secs(60)).await;
        }
    });

    // Process events with reconnection
    loop {
        match eventloop.poll().await {
            Ok(event) => handle_event(event).await,
            Err(e) => {
                tracing::error!("MQTT error: {}", e);
                tokio::time::sleep(Duration::from_secs(5)).await;
            }
        }
    }
}

Common Mistakes

常见错误

Mistake	Domain Violation	Fix
No retry logic	Lost data	Exponential backoff
Always-on radio	Battery drain	Sleep between sends
Unencrypted MQTT	Security risk	TLS
No local buffer	Network outage = data loss	Persist locally

错误	违反的领域规则	修复方案
无重试逻辑	数据丢失	指数退避重试
无线模块始终开启	电池耗尽	发送间隔期间睡眠
未加密的MQTT通信	安全风险	使用TLS
无本地缓冲	网络中断导致数据丢失	本地持久化数据