開源地址：https://gitee.com/bltas/earthworm_home

概述：

小型蚯蚓養(yǎng)殖監(jiān)控系統(tǒng)主要探索在家庭等局限場地下，蚯蚓的正常養(yǎng)殖，從而得到蚯蚓糞和蚯蚓液。系統(tǒng)基于ART-PI & RT-Studio 開發(fā)，使用了dht11，ds18b20，土壤濕度，mpu6050監(jiān)測養(yǎng)殖環(huán)境中的空氣溫濕度，土壤溫濕度和蚯蚓的抖動密度。外置的風(fēng)扇和水泵對上述環(huán)境變量進行控制。連接onenet后可以及時在后臺遠(yuǎn)程觀測環(huán)境變量并加以控制。

開發(fā)環(huán)境

硬件：ART-Pi STM32H750

擴展板：DS18B20防水?dāng)?shù)字溫度傳感器，DHT11溫濕度傳感器，2pcs MPU6050 傳感器，土壤濕度傳感器

RT-Thread版本：RT-Thread V 4.0.3

開發(fā)工具及版本：RT-studio2.0.0

RT-Thread使用情況概述

調(diào)度器：創(chuàng)建多個線程來實現(xiàn)不同的工作。

信號量：用來同步線程。

互斥量：多個相關(guān)采集線程能同時獲得系統(tǒng)資源，不被其他線程搶占

消息隊列：用來實現(xiàn)采集線程，控制線程和OneNet upload線程的同步。

消息郵箱：onenet_mqtt 接受控制命令后和控制線程的同步

組件部分：I2c框架， Sensor框架

I2C框架：使用 I2C框架來驅(qū)動MPU6050

ADC device： 用來采集土壤濕度

PWM device： 用來控制風(fēng)扇，水泵。

Sensor框架：MPU6050，DHT11，DS18b20均為基于sensor框架的包，為上層提供統(tǒng)一的操作接口，提高上層代碼的可重用性；簡化底層驅(qū)動開發(fā)的難度。

軟件包部分：

Webclient：提供設(shè)備與 HTTP Server 的通訊的基本功能。

pahomqtt：本軟件包是在 Eclipse paho-mqtt 源碼包的基礎(chǔ)上設(shè)計的一套 MQTT 客戶端程序。

Onenet：是 RT-Thread 針對 OneNET 平臺連接做的的適配，通過這個軟件包，可以讓設(shè)備在 RT-Thread 上非常方便的連接 OneNet 平臺，完成數(shù)據(jù)的發(fā)送、接收、設(shè)備的注冊和控制等功能。

cJSON： C語言實現(xiàn)的極簡的解析 JSON 格式的軟件包。

DHT11： GPIO模擬單總線協(xié)議，讀取傳感器溫濕度，注冊在sensor框架

Ds18b20： GPIO模擬單總線協(xié)議，讀取傳感器溫度，注冊在sensor框架

MPU6050： 本軟件包是為 InvenSense 公司的六軸系列傳感器提供的通用傳感器驅(qū)動包，可選I2C或SPI通信協(xié)議。通過 Sensor 框架，開發(fā)者可以快速的將此傳感器驅(qū)動起來。

硬件框架

ART-Pi 外掛多個傳感器作為采集輸入設(shè)備， 水泵和風(fēng)扇作為控制設(shè)備。ART-Pi本身作為Onenet的一個終端設(shè)備來上傳數(shù)據(jù)接收和接收命令。

軟件框架說明

多個采集線程實時讀取環(huán)境中的溫濕度，發(fā)送到stream消息隊列;Onenet上傳線程接收消息并上傳到相應(yīng)stream。當(dāng)云端下發(fā)命令，觸發(fā)Onenet_cmd_rsp_cb， 在里面發(fā)送接收的控制命令到命令緩存郵箱，控制線程查詢郵箱，發(fā)現(xiàn)郵件后使用rt_mq_urgent發(fā)送緊急控制stream，及時同步云端控制設(shè)備的狀態(tài)。

軟件模塊說明

共創(chuàng)建了2個信號量，1個消息隊列，1個互斥量，7個線程

信號量：

mqttinit_sem 主要用于wifi的連接及onenet_mqtt_init的同步問題。

sensor_msg_sem_empty 主要限制采集線程占用的消息資源個數(shù)

5個采集線程：

adc1_5_entry：周期性讀取土壤濕度傳感器的值，并把讀取到的值發(fā)送到消息隊列sensor_msg_mq

read_dhtll_entry：周期性讀取DHT11溫濕度傳感器的值，并把讀取到的值發(fā)送到消息隊列sensor_msg_mq

read_ds18b20_entry：周期性讀取ds1b20 土壤溫度傳感器的值，并把讀取到的值發(fā)送到消息隊列sensor_msg_mq

read_gyro0_entry： 周期性讀取MPU6050_0六軸傳感器的Y軸角速度，作為蚯蚓活動強度（間接反映蚯蚓密度和活性情況），并把讀取到的值發(fā)送到消息隊列

read_gyro1_entry： 同上，兩點測量。

消息隊列：

sensor_msg_mq： 為了同步采集線程，控制線程和云端的同步。由于Onenet數(shù)據(jù)刷新有要求，更新數(shù)據(jù)快了也沒用，這里設(shè)置為1s. 生產(chǎn)者過多，消費速率過慢，最終都會過剩。只分配5個消息給到采集線程。

另外，雖然我們開辟了8個消息，但是我們使用了sensor_msg_sem_empty 信號量來限制采集線程只能使用5個，留下的3個用來快速同步控制流，及時刷新云端控制設(shè)備的狀態(tài)。

互斥量：

sensor_msg_mutex： 由于DHT11同時讀取了溫度和濕度兩個環(huán)境變量，對應(yīng)云端兩個stream，需要發(fā)送兩次消息，為確保兩個stream的同步，先獲取互斥量，在未全部發(fā)送完成之前不釋放互斥量。

消息郵箱：

sensor_msg_mailbox：云端發(fā)送命令間隔沒有明確的限制，存在連續(xù)操作，需要緩存一下，這里設(shè)置了16個郵件。在Onenet_cmd_rsp_cb里把接收的命令直接發(fā)送到郵箱，控制線程接收郵件并處理。

控制線程：

center_control_entry：從sensor_msg_mailbox郵箱里接收郵件，解析命令，控制設(shè)備，并同步設(shè)備狀態(tài)到云端。

上傳線程：

onenet_upload_entry： 長等待方式從隊列里接收消息，然后根據(jù)消息里的stream_id發(fā)數(shù)據(jù)到 onenet云端不同的數(shù)據(jù)流

狀態(tài)線程：

Main：led 2s閃爍，指示當(dāng)前系統(tǒng)的運行狀態(tài)。

編輯：jq