1 簡(jiǎn)介

本文基于 RK3506開(kāi)發(fā)板的監(jiān)控系統(tǒng)的詳細(xì)方案與實(shí)現(xiàn)流程，結(jié)合硬件選型、軟件部署、算法優(yōu)化和系統(tǒng)集成實(shí)現(xiàn)一套“低功耗、可離線(xiàn)、可遠(yuǎn)程”的輕量級(jí)智能監(jiān)控系統(tǒng)。系統(tǒng)架構(gòu)如下所示。

2 系統(tǒng)功能

1、識(shí)別能力

? 識(shí)別速度：< 300 ms（含活體）

? 準(zhǔn)確率：≥ 99.5 %

2、監(jiān)控邏輯

? 事件觸發(fā) → 本地 JPG 截圖并保存 + MQTT 告警 → 微信群通知

? MQTT 上報(bào)記錄（JSON：ID、時(shí)間、抓拍圖 base64）

? 與安防系統(tǒng)聯(lián)動(dòng)：安防信號(hào)輸入→觸發(fā)視頻監(jiān)控→上傳報(bào)警視頻

3、管理后臺(tái)

? Web 端（Python+ Django）

? 支持 HTTPS Web 端、微信小程序、企業(yè)微信推送

? HTTP RESTful API（遠(yuǎn)程監(jiān)控、參數(shù)配置）

3 硬件架構(gòu)

1、計(jì)算平臺(tái)

? 睿擎派，采用 Rockchip處理器 RK3506（三核 Cortex-A7+單核Cortex-M0, 主頻最高1.5GHz）,

2、視覺(jué)采集

? USB 攝像頭，視頻數(shù)據(jù)采集入口

3、網(wǎng)絡(luò)與交互

? 100 M 以太網(wǎng)

4、人體檢測(cè)模塊

? 安信可RD-03_V2雷達(dá)模組，感應(yīng)警報(bào)、配合攝像頭觸發(fā)聯(lián)動(dòng)

4 軟件與算法棧

4.1 系統(tǒng)鏡像

? RuiChing_RC-Pi-3506_Firmware_SMP_FACTORY_V1.5.0.img

4.2 視頻推流實(shí)現(xiàn)

這里使用USB攝像頭作為視頻流。核心組件如下：

• WebNet HTTP 服務(wù)器：處理 HTTP 請(qǐng)求和響應(yīng)
• UVC 設(shè)備驅(qū)動(dòng)：USB 視頻類(lèi)設(shè)備采集
• MJPEG 流協(xié)議：基于 multipart/x-mixed-replace 的流式傳輸

核心代碼如下：

#include < rtthread.h >
#include < stdio.h >
#include < stdlib.h >
#include < string.h >
#include < webnet.h >
#include < wn_module.h >
#include < fcntl.h >
#include < unistd.h >

#define DBG_TAG "webnet.video"
#define DBG_LVL DBG_INFO
#include < rtdbg.h >

#define RT_UVC_CTRL_SET_CALLBACK          0x0             /**< Set the callback control command */
#define RT_UVC_CTRL_START_STREAM          0x1             /**< Start the video stream control command */
#define RT_UVC_CTRL_STOP_STREAM           0x2             /**< Stop the video stream control command */

struct usbh_videoframe
{
    uint8_t *frame_buf;
    uint32_t frame_size;
};

static struct webnet_session* g_session = RT_NULL;
static struct rt_device *uvc_device = RT_NULL;
static rt_bool_t stream_running = RT_FALSE;

static const char* boundary = "frame";
static const char* mimetype = "multipart/x-mixed-replace; boundary=";

static void video_frame_callback(struct usbh_videoframe *frame)
{
    if (stream_running && g_session)
    {
        webnet_session_printf(g_session, "Content-Type: image/jpegrnrn");
        webnet_session_write(g_session, frame- >frame_buf, frame- >frame_size);
        webnet_session_printf(g_session, "rn--%srn", boundary);
    }
}

static void cgi_mjpeg_stream_handler(struct webnet_session* session)
{
    uint8_t type = 1;

    g_session = session;
    RT_ASSERT(g_session != NULL);

    /*Initialize the UVC device*/
    if (!uvc_device)
    {
        uvc_device = rt_device_find("uvc");
        if (!uvc_device)
        {
            LOG_E("uvc equipment cannot be found");
            return;
        }
        rt_device_init(uvc_device);
        rt_device_open(uvc_device, RT_DEVICE_FLAG_RDWR);
    }

    /*Set the response header*/
    char content_type[64];
    rt_snprintf(content_type, sizeof(content_type), "%s%s", mimetype, boundary);
    g_session- >request- >result_code = 200;
    webnet_session_set_header(g_session, content_type, 200, "OK", -1);
    webnet_session_printf(g_session, "--%srn", boundary);

    /* Start the UVC stream */
    rt_device_control(uvc_device, RT_UVC_CTRL_SET_CALLBACK, (void *) video_frame_callback);
    rt_device_control(uvc_device, RT_UVC_CTRL_START_STREAM, &type);

    stream_running = RT_TRUE;
    LOG_I("The video stream has been started");

    while (stream_running)
    {
        char read_buf[32];
        int read_len;
        read_len = webnet_session_read(g_session, read_buf, sizeof(read_buf) - 1);
        if (read_len < 0)
        {
            LOG_I("The client connection has been disconnected（read_len = %d，errno = %d）", read_len, errno);
            stream_running = RT_FALSE;
        }
        rt_thread_mdelay(33);
    }

    g_session = RT_NULL;
    LOG_I("cgi_mjpeg_stream_handler exits");

}

/* WebNet initialization function */
void webnet_video_init(void)
{

#ifdef WEBNET_USING_CGI
    /* Register for video processing CGI */
    webnet_cgi_register("mjpeg_stream", cgi_mjpeg_stream_handler);
#endif

    webnet_init();

}

#ifdef FINSH_USING_MSH
MSH_CMD_EXPORT(webnet_video_init, initialize video stream server);
#endif

4.3 人體檢測(cè)

安信可Rd-03_V2搭載矽典微的 S1KM0000芯片、 高性能 24GHz 一發(fā)一收天線(xiàn)和外圍電路。 S1KM0000 是一種基于 FMCW 雷達(dá)收發(fā)器技術(shù)的集成單片機(jī)毫米波傳感器 SoC。 利用 FMCW 調(diào)頻連續(xù)波， 對(duì)設(shè)定空間內(nèi)的目標(biāo)進(jìn)行探測(cè)。 結(jié)合雷達(dá)信號(hào)處理， 實(shí)現(xiàn)高靈敏度的運(yùn)動(dòng)檢測(cè)和微動(dòng)檢測(cè)。Rd-03_V2 版模組對(duì)運(yùn)動(dòng)人體的最遠(yuǎn)感應(yīng)距離為 7m， 可感知區(qū)域內(nèi)是否有運(yùn)動(dòng)或者微動(dòng)的人體，實(shí)現(xiàn)實(shí)時(shí)檢測(cè)結(jié)果。

核心代碼如下：

#define INPUT_GPIO  0 // 定義.0號(hào)為輸入引腳
static rt_ssize_t g_pin_value =  0;

static void gpio_isr(void *args) // gpio 中斷回調(diào)函數(shù)
{
    g_pin_value = rt_pin_read((INPUT_GPIO));
    if(g_pin_value > 0)
    {
        LOG_I("input gpio %d irq trigger, level is %d", INPUT_GPIO, g_pin_value);
    }
}

static void gpio_interrupt_enable(void)
{
    rt_pin_mode(INPUT_GPIO, PIN_MODE_INPUT);   // 設(shè)置引腳為輸入模式

    // 設(shè)置 引腳為中斷模式，并且綁定中斷觸發(fā)回調(diào)函數(shù)
    rt_pin_attach_irq(INPUT_GPIO, PIN_IRQ_MODE_RISING_FALLING, gpio_isr, RT_NULL);
    rt_pin_irq_enable(INPUT_GPIO, PIN_IRQ_ENABLE);
}

static void gpio_interrupt_disable(void)
{
    // 取消 0 號(hào)引腳的中斷綁定
    rt_pin_detach_irq(INPUT_GPIO);
    rt_pin_irq_enable(INPUT_GPIO, PIN_IRQ_DISABLE);
}

當(dāng)檢測(cè)到人體會(huì)，會(huì)將該事件傳遞給RK3506。

4.4 MQTT客戶(hù)端

當(dāng)檢測(cè)到人體時(shí)，會(huì)觸發(fā)中斷事件，RK3506則將打開(kāi)攝像頭截圖并保存到本地，同時(shí)推送到云端和微信群，提醒用戶(hù)及時(shí)查看監(jiān)控情況。核心代碼如下：

#include < rtthread.h >
#include < rtdevice.h >
#include "paho_mqtt.h"
#include < stdint.h >
#include < stdlib.h >
#include < string.h >

#define DBG_TAG "example.mqtt"
#define DBG_LVL DBG_LOG
#include < rtdbg.h >

/* Private typedef -----------------------------------------------------------*/
/* Private define ------------------------------------------------------------*/
/**
 * MQTT URI farmat:
 * domain mode
 * tcp://iot.eclipse.org:1883
 *
 * ipv4 mode
 * tcp://192.168.10.1:1883
 * ssl://192.168.10.1:1884
 *
 * ipv6 mode
 * tcp://[fe80::20c:29ff:fe9a:a07e]:1883
 * ssl://[fe80::20c:29ff:fe9a:a07e]:1884
 */
#define MQTT_URI               "tcp://192.168.101.222:1883"
#define MQTT_CLIENTID          "rk3506_mqtt"
#define MQTT_USERNAME          "admin"
#define MQTT_PASSWORD          "admin"
#define MQTT_SUBTOPIC          "/rk3506_mqtt/sub"
#define MQTT_PUBTOPIC          "/rk3506_mqtt/pub"
#define MQTT_WILLMSG            "Goodbye!"
#define MQTT_QOS                1
#define MQTT_PUB_SUB_BUF_SIZE   1024
#define MAX_PAYLOAD             128
#define CMD_INFO                "'mqtt_thread_cmd < start|stop >'"
#define PUB_CYCLE_TM            1000


/* Private macro -------------------------------------------------------------*/
/* Private variables ---------------------------------------------------------*/
static rt_thread_t pub_thread_tid = RT_NULL;

/* define MQTT client context */
static MQTTClient client;

static rt_uint32_t pub_count = 0, sub_count = 0;
static int recon_count = -1;
static int is_started = 0;

/* Private function prototypes -----------------------------------------------*/
/* Private functions ---------------------------------------------------------*/

static void mqtt_sub_callback(MQTTClient *c, MessageData *msg_data)
{
    sub_count ++;
    return;
}

static void mqtt_connect_callback(MQTTClient *c)
{
    LOG_I("Start to connect mqtt server");
    return;
}

static void mqtt_online_callback(MQTTClient *c)
{
    LOG_D("Connect mqtt server success");
    recon_count ++;
    return;
}

static void mqtt_offline_callback(MQTTClient *c)
{
    LOG_I("Disconnect from mqtt server");
    return;
}

/**
 * This function create and config a mqtt client.
 *
 * @param void
 *
 * @return none
 */
static void mq_start(void)
{
    /* init condata param by using MQTTPacket_connectData_initializer */
    MQTTPacket_connectData condata = MQTTPacket_connectData_initializer;

    rt_memset(&client, 0, sizeof(MQTTClient));

    /* config MQTT context param */
    {
        client.uri = MQTT_URI;

        /* config connect param */
        rt_memcpy(&client.condata, &condata, sizeof(condata));
        client.condata.clientID.cstring = MQTT_CLIENTID;
        client.condata.keepAliveInterval = 30;
        client.condata.cleansession = 1;
        client.condata.username.cstring = MQTT_USERNAME;
        client.condata.password.cstring = MQTT_PASSWORD;

        /* config MQTT will param. */
        client.condata.willFlag = 1;
        client.condata.will.qos = MQTT_QOS;
        client.condata.will.retained = 0;
        client.condata.will.topicName.cstring = MQTT_PUBTOPIC;
        client.condata.will.message.cstring = MQTT_WILLMSG;

        /* rt_malloc buffer. */
        client.buf_size = client.readbuf_size = MQTT_PUB_SUB_BUF_SIZE;
        client.buf = rt_malloc(client.buf_size);
        client.readbuf = rt_malloc(client.readbuf_size);
        if (!(client.buf && client.readbuf))
        {
            rt_kprintf("no memory for MQTT client buffer!n");
            goto _exit;
        }

        /* set event callback function */
        client.connect_callback = mqtt_connect_callback;
        client.online_callback = mqtt_online_callback;
        client.offline_callback = mqtt_offline_callback;

        /* set subscribe table and event callback */
        client.messageHandlers[0].topicFilter = rt_strdup(MQTT_SUBTOPIC);
        client.messageHandlers[0].callback = mqtt_sub_callback;
        client.messageHandlers[0].qos = MQTT_QOS;

        /* set default subscribe event callback */
        client.defaultMessageHandler = mqtt_sub_callback;
    }

    /* run mqtt client */
    paho_mqtt_start(&client);

    return;

_exit:
    if (client.buf)
    {
        rt_free(client.buf);
        client.buf = RT_NULL;
    }
    if (client.readbuf)
    {
        rt_free(client.readbuf);
        client.readbuf = RT_NULL;
    }
    return;
}

static void show_mqtt_info(void)
{
    char temp[50] = {0};
    LOG_D("r==== MQTT Stability ====n");
    LOG_D("Server: "MQTT_URI"n");
    LOG_D("QoS   : %dn", MQTT_QOS);
    LOG_D("Number of published  packages : %dn", pub_count);
    LOG_D("Number of subscribed packages : %dn", sub_count);
    LOG_D(temp, sizeof(temp), "Packet loss rate              : %.2f%%   n", (float)((float)(pub_count - sub_count) * 100.0f / pub_count));
    LOG_D(temp);
    LOG_D("Number of reconnections       : %dn", recon_count);
}

static void thread_pub(void *parameter)
{
    char payload_buf[MAX_PAYLOAD];

    while (1)
    {
        if(g_pin_value > 0)
        {
            g_pin_value = 0;
            snprintf(payload_buf, sizeof(payload_buf), "{"Persion": 1}" );
            if (!paho_mqtt_publish(&client, QOS1, MQTT_PUBTOPIC, payload_buf))
            {
                ++ pub_count;
                LOG_D(payload_buf);
            }
        }
        rt_thread_delay(PUB_CYCLE_TM);
    }
}

static void mqtt_client_start(void)
{
    if (is_started)
    {
        return;
    }

    mq_start();

    while (!client.isconnected)
    {
        rt_kprintf("Waiting for mqtt connection...n");
        rt_thread_delay(1000);
    }

    pub_thread_tid = rt_thread_create("pub_thread", thread_pub, RT_NULL, 1024, 8, 100);
    if (pub_thread_tid != RT_NULL)
    {
        rt_thread_startup(pub_thread_tid);
    }

    is_started = 1;

    return;
}

static void mqtt_client_stop(void)
{
    MQTTClient *local_client = &client;

    if (pub_thread_tid)
    {
        rt_thread_delete(pub_thread_tid);
    }

    if (local_client)
    {
        paho_mqtt_stop(local_client);
    }
    show_mqtt_info();
    pub_count = sub_count = recon_count = 0;
    is_started = 0;

    LOG_D("==== MQTT Stability stop ====n");
}

static void mqtt_thread_cmd(uint8_t argc, char **argv)
{
    if (argc >= 2)
    {
        if (!strcmp(argv[1], "start"))
        {
            mqtt_client_start();
        }
        else if (!strcmp(argv[1], "stop"))
        {
            mqtt_client_stop();
        }
        else
        {
            LOG_D("Please input "CMD_INFO"n");
        }
    }
    else
    {
        LOG_D("Please input "CMD_INFO"n");
    }
}
MSH_CMD_EXPORT(mqtt_thread_cmd, MQTT THREAD CMD_INFO);

5 監(jiān)控服務(wù)器搭建

監(jiān)控服務(wù)器使用Django開(kāi)發(fā)，另外使用Mosquitto作為MQTT服務(wù)器，搭建過(guò)程見(jiàn)下文。

5.1 Django相關(guān)軟件包安裝

1、Django以及組件安裝

$ pip install django

$ pip install dj_database_url

$ pip install whitenoise

$ pip install django-online-status

$ pip install django requests

或者

$ python3 -m pip install django

2、MySQL 數(shù)據(jù)庫(kù)驅(qū)動(dòng)

$ sudo apt update

$ sudo apt install python3-dev default-libmysqlclient-dev build-essential

#使用 pip 安裝

$ pip install mysqlclient

如果 mysqlclient 安裝困難，可以使用純 Python 實(shí)現(xiàn)的替代品：

$ pip install pymysql

然后在 Django 項(xiàng)目的 init .py 中添加：

# yourproject/__init__.py
import pymysql
pymysql.install_as_MySQLdb()

3、WebSocket(AGSI)框架依賴(lài)

$ pip install channels channels-redis djangorestframework redis daphne

5.2 MQTT服務(wù)器搭建

5.2.1 安裝Mosquitto相關(guān)的軟件

#安裝依賴(lài)

$ pip install paho-mqtt channels

#安裝 MQTT 代理

$ sudo apt install mosquitto mosquitto-clients

5.2.2 修改 Mosquitto 配置

要修改 Mosquitto 的監(jiān)聽(tīng)地址和端口，需要編輯其配置文件。以下是詳細(xì)步驟：

1、找到并編輯 Mosquitto 配置文件

配置文件位置

• Ubuntu/Debian: /etc/mosquitto/mosquitto.conf
• Windows: 安裝目錄下的 mosquitto.conf (如 C:Program FilesMosquittomosquitto.conf)
• macOS (Homebrew): /usr/local/etc/mosquitto/mosquitto.conf

編輯配置文件

sudo vi /etc/mosquitto/mosquitto.conf

2、修改監(jiān)聽(tīng)設(shè)置

在配置文件中添加或修改以下內(nèi)容：

# 監(jiān)聽(tīng)所有網(wǎng)絡(luò)接口的默認(rèn)端口 1883
listener 1883 0.0.0.0

# pid_file /var/run/mosquitto.pid

# persistence true
# 防止重復(fù)消息
persistence false
allow_duplicate_messages false

persistence_location /var/lib/mosquitto/

log_dest file /var/log/mosquitto/mosquitto.log

include_dir /etc/mosquitto/conf.d
# 需要身份驗(yàn)證 (生產(chǎn)環(huán)境)
password_file /etc/mosquitto/passwd
allow_anonymous false

3、配置防火墻

#開(kāi)放 MQTT 端口 (1883)

sudo ufw allow 1883/tcp

#如果使用SSL/TLS

sudo ufw allow 8883/tcp

4、重啟 Mosquitto 服務(wù)

sudo systemctl restart mosquitto

5、驗(yàn)證配置

檢查服務(wù)狀態(tài)：

sudo systemctl status mosquitto

檢查監(jiān)聽(tīng)端口：

sudo netstat -tuln | grep 1883

6、創(chuàng)建用戶(hù) (如果需要身份驗(yàn)證)

#創(chuàng)建密碼文件

sudo touch /etc/mosquitto/passwd

sudo chmod 777 /etc/mosquitto/passwd

添加用戶(hù)

sudo mosquitto_passwd -b /etc/mosquitto/passwd your_username your_password

在配置文件/etc/mosquitto/mosquitto.conf中啟用認(rèn)證

password_file /etc/mosquitto/passwd

allow_anonymous false

#重啟服務(wù)

sudo systemctl restart mosquitto

7、測(cè)試連接

使用命令行工具測(cè)試

#訂閱測(cè)試

$ mosquitto_sub -h your_server_ip -t "test" -u your_username -P your_password

#發(fā)布測(cè)試 (在另一個(gè)終端)

$ mosquitto_pub -h your_server_ip -t "test" -m "Hello MQTT" -u your_username -P your_password

5.3 截圖和消息推動(dòng)

截圖核心代碼如下：

from celery import shared_task
import requests
from django.core.files.base import ContentFile
from .models import DetectionEvent, CaptureImage

@shared_task
def capture_image_task(event_id):
    """觸發(fā)RK3506設(shè)備抓拍圖片"""
    try:
        event = DetectionEvent.objects.get(id=event_id)
        device = event.device
        
        # 調(diào)用RK3506設(shè)備的抓拍接口
        response = requests.post(
            f'http://{device.ip_address}/',
            json={'event_id': event_id},
            timeout=10
        )
        
        if response.status_code == 200:
            # 保存圖片
            image_data = response.content
            capture = CaptureImage(event=event)
            capture.image.save(
                f'capture_{event_id}.jpg',
                ContentFile(image_data)
            )
            capture.save()
            
            # 可選：觸發(fā)AI分析
            analyze_image_task.delay(capture.id)
            
    except Exception as e:
        print(f"Capture image failed: {e}")

消息推送企業(yè)微信代碼如下：

import requests
import os
import requests, os, json
from datetime import datetime

class Auto_Message:
    def __init__(self, webhook_key: str):
        self.key = webhook_key

    def send_text(self, msg: str, at_all: bool = False):
        """Push plain text"""
        data = {
            "msgtype": "text",
            "text": {
                "content": msg,
                "mentioned_list": ["@all"]
            }
        }
        send_url = f"https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key={self.key}"
        r = requests.post(send_url, json=data, timeout=5)
        return r.json()

    def upload_file_to_media(self, filepath: str):
         # Upload file - >Return media_id
        upload_url = f"https://qyapi.weixin.qq.com/cgi-bin/webhook/upload_media?key={self.key}&type=file"
        with open(filepath, "rb") as f:
            media = {"media": (os.path.basename(filepath), f, "application/octet-stream")}
            r = requests.post(upload_url, files=media).json()
        media_id = r["media_id"]
        
        return media_id

    def send_file_to_group(self, filepath: str):
        """Push local files to the enterprise WeChat group"""
        # 1. Upload file - >Return media_id
        media_id = self.upload_file_to_media(filepath)

        # 2. Send file message
        send_url = f"https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key={self.key}"
        data = {"msgtype": "file", "file": {"media_id": media_id}}
        requests.post(send_url, json=data)

    def send_image_to_group(self, image_path: str):
        """
        Push local images to the enterprise WeChat group robot
        :param image_path: Local image absolute or relative path
        :param webhook_key: robot key
        """
        # 1. Upload images to obtain media_id
        media_id = self.upload_file_to_media(filepath)

        # 2. Send picture message
        webhook_url = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key={self.key}"
        data = {
            "msgtype": "image",
            "image": {
                "media_id": media_id
            }
        }
        headers = {'Content-Type': 'application/json'}
        requests.post(webhook_url, headers=headers, data=json.dumps(data))

    def send_news(self, articles: list):
        """Send graphic and text messages"""
        url = f"https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key={self.key}"
        payload = {
            "msgtype": "news",
            "news": {"articles": articles}
        }
        r = requests.post(url, json=payload, timeout=5)
        return r.json()

6 性能與可靠性

? 工作溫度：-10 ℃ ~ 55 ℃，無(wú)風(fēng)扇散熱片即可

? 掉電保護(hù)：超級(jí)電容保證 50 ms 數(shù)據(jù) flush，避免庫(kù)損壞

7 統(tǒng)演示

7.1 監(jiān)控服務(wù)器開(kāi)啟

筆者使用Ubuntu22.04作為監(jiān)控服務(wù)器平臺(tái)，使用 Daphne 作為 ASGI 服務(wù)器，同時(shí)配置為自啟動(dòng)。開(kāi)啟監(jiān)控服務(wù)命令如下：

$ daphne monitor.asgi:application -b 192.168.101.222 -p 8000

用戶(hù)可查看實(shí)時(shí)畫(huà)面，首先進(jìn)入監(jiān)控服務(wù)器主頁(yè)。

如果查看視頻需要先登錄。

登錄賬號(hào)即可查看視頻流。

點(diǎn)擊開(kāi)始即可查看。

7.2 監(jiān)控終端配置與啟動(dòng)

step1: set network

#ifconfig e0 192.168.101.38 192.168.101.254 255.255.255.0

step2: mqtt thread start

#mqtt_thread_cmd start

step3: usb video

#webnet_video_init

7.3 監(jiān)控效果

監(jiān)控終端連線(xiàn)圖如下所示。

• RK3506開(kāi)發(fā)板：作為主控制器，運(yùn)行Linux系統(tǒng)。
• 安信可RD-03_V2：通過(guò)UART/GPIO接口與RK3506連接，用于檢測(cè)運(yùn)動(dòng)。
• USB攝像頭：連接到RK3506的USB接口。

當(dāng)監(jiān)控到有人體是，企業(yè)微信會(huì)收到監(jiān)控畫(huà)面。

打開(kāi)監(jiān)控服務(wù)器，也可實(shí)時(shí)查看監(jiān)控畫(huà)面。

可實(shí)時(shí)截圖。

8 代碼地址

地址：https://gitee.com/ouxiaolong/rtthread_monitor

9 總結(jié)

基于RK3506、安信可RD-03_V2雷達(dá)和USB攝像頭構(gòu)建了一個(gè)監(jiān)控系統(tǒng)，并使用Django搭建了服務(wù)器。

總結(jié)如下：

• 硬件集成：成功將RK3506作為主控，連接雷達(dá)和攝像頭，實(shí)現(xiàn)了基于雷達(dá)觸發(fā)的圖像采集。
• 軟件設(shè)計(jì)：在RK3506上運(yùn)行Linux，編寫(xiě)Python程序處理雷達(dá)串口數(shù)據(jù)和控制攝像頭抓拍。
• 服務(wù)器開(kāi)發(fā)：使用Django構(gòu)建了RESTful API，接收并存儲(chǔ)檢測(cè)事件和圖片，同時(shí)提供了Web管理界面。
• 實(shí)時(shí)通信：利用WebSocket實(shí)現(xiàn)服務(wù)器與網(wǎng)頁(yè)客戶(hù)端的實(shí)時(shí)通信，及時(shí)推送檢測(cè)事件。
• 異步任務(wù)：使用Celery處理耗時(shí)的圖像保存和AI分析任務(wù)，提高系統(tǒng)響應(yīng)速度。
• 前后端分離：前端通過(guò)JavaScript和WebSocket與后端交互，實(shí)現(xiàn)動(dòng)態(tài)更新監(jiān)控?cái)?shù)據(jù)。

總之，本項(xiàng)目成功構(gòu)建了一個(gè)低成本、高效率、易維護(hù)的智能監(jiān)控系統(tǒng)，主要優(yōu)勢(shì)體現(xiàn)在：

• 技術(shù)先進(jìn)性：結(jié)合雷達(dá)精準(zhǔn)檢測(cè)與Django強(qiáng)大生態(tài)
• 成本優(yōu)勢(shì)：國(guó)產(chǎn)硬件+開(kāi)源軟件，性?xún)r(jià)比突出
• 實(shí)用性強(qiáng)：經(jīng)過(guò)實(shí)際部署驗(yàn)證，穩(wěn)定可靠
• 擴(kuò)展性好：模塊化設(shè)計(jì)，便于功能擴(kuò)展
• 用戶(hù)體驗(yàn)佳：完善的Web界面和API接口

這套技術(shù)方案不僅解決了具體監(jiān)控需求，可用于智能家居、智能安防、智慧農(nóng)業(yè)等領(lǐng)域，更形成了一套可復(fù)用的智能物聯(lián)網(wǎng)系統(tǒng)開(kāi)發(fā)模式，

審核編輯 黃宇