開(kāi)源地址：https://gitee.com/bltas/earthworm_home

概述：

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

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

硬件：ART-Pi STM32H750

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

RT-Thread版本：RT-Thread V 4.0.3

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

RT-Thread使用情況概述

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

信號(hào)量：用來(lái)同步線程。

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

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

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

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

I2C框架：使用 I2C框架來(lái)驅(qū)動(dòng)MPU6050

ADC device： 用來(lái)采集土壤濕度

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

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

軟件包部分：

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

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

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

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

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

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

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

硬件框架

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

軟件框架說(shuō)明

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

軟件模塊說(shuō)明

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

信號(hào)量：

mqttinit_sem 主要用于wifi的連接及onenet_mqtt_init的同步問(wèn)題。

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

5個(gè)采集線程：

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

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

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

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

read_gyro1_entry： 同上，兩點(diǎn)測(cè)量。

消息隊(duì)列：

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

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

互斥量：

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

消息郵箱：

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

控制線程：

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

上傳線程：

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

狀態(tài)線程：

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

編輯：jq