近期有行業(yè)同行咨詢，是否存在基于Air8101的RTMP推流方案，這里明確說(shuō)明：該方案已開(kāi)源，可直接參考使用。

Air8101是支持2.4G WIFI6和藍(lán)牙(BLE 5.4)的 WiFi SoC，最大支持 200W 像素的靜態(tài)圖像拍照，支持1024*720分辨率的10寸屏顯示，同時(shí)兼容DVP/USB攝像頭即插即用，支持多路視頻采集及RTMP推流功能。

本文將以Air8101核心板與AirCAMERA_1030攝像頭配件板為硬件示例，詳細(xì)演示如何基于LuatOS和合宙音視頻平臺(tái)，快速搭建USB攝像頭實(shí)時(shí)推流應(yīng)用，為視頻上云部署提供技術(shù)參考。

一、主要硬件準(zhǔn)備：

• 為確保方案順利部署，請(qǐng)?zhí)崆皽?zhǔn)備以下關(guān)鍵硬件：
• Air8101核心板
• USB攝像頭配件板AirCAMERA_1030
• TYPE-C數(shù)據(jù)線用于供電及固件燒錄調(diào)試
• Win10及其以上PC電腦

接線方式如下：

Air8101核心板通過(guò)Type-C USB口供電（核心板正面的撥碼開(kāi)發(fā)撥到5V一端，背面的功耗測(cè)試開(kāi)關(guān)撥到OFF一端），

AirCAMERA_1030直插在Air8101核心板上。USB HUB（可選，接入多路攝像頭時(shí)使用）

AirCAMERA_1030 配件板 + Air8101 核心板，硬件連接示意圖：

單路攝像頭鏈接方式

四路攝像頭鏈接方式 如圖所示，將四路 USB 攝像頭接入 HUB 中，然后將 HUB 通過(guò) USB 口連接到 Air8101 核心板上;

RTMP 的主要特點(diǎn)為低延遲、協(xié)議兼容性較好，在直播傳輸、安防視頻監(jiān)控、遠(yuǎn)程設(shè)備視頻巡檢等對(duì)實(shí)時(shí)性有要求的物聯(lián)網(wǎng)應(yīng)用場(chǎng)景中較為常用。設(shè)備可通過(guò) RTMP 協(xié)議進(jìn)行推流，實(shí)現(xiàn)音視頻數(shù)據(jù)的實(shí)時(shí)傳輸，終端設(shè)備如手機(jī)、PC 可直接接收并實(shí)時(shí)播放畫(huà)面，無(wú)需等待文件錄制完成后再進(jìn)行上傳。

本示例基于Air8101核心板與AirCAMERA_1030配件板，實(shí)現(xiàn)USB攝像頭的RTMP實(shí)時(shí)推流。

2.1 RTMP業(yè)務(wù)邏輯：

• 訂閱IP_READY信息：確認(rèn)聯(lián)網(wǎng)后執(zhí)行RTMP推流任務(wù)；
• 獲取RTMP推流地址：通過(guò)http.request()請(qǐng)求從服務(wù)器獲取推流地址；
• 初始化攝像頭：excamera.open()初始化USB攝像頭；
• RTMP推流：excamera.rtmp()確保攝像頭狀態(tài)正常，然后rtmpc:start()開(kāi)始推流邏輯；
• 監(jiān)控推流狀態(tài)：循環(huán)監(jiān)控推流過(guò)程，每20秒打印一次內(nèi)存信息。
• 處理異常情況：推流異常時(shí)發(fā)送RECONNECT_RTMP信息，然后根據(jù)重連函數(shù)進(jìn)行重連；
• 釋放資源：推流結(jié)束時(shí)excamera.close()關(guān)閉攝像頭，釋放資源。

核心代碼如下，完整demo詳見(jiàn)源碼倉(cāng)庫(kù)最新文件

-- 引入excamera擴(kuò)展庫(kù) local excamera = require("excamera") local RTMP_TASK_NAME = "rtmp_app_task" -- RTMP任務(wù)名稱 -- HTTP請(qǐng)求獲取RTMP服務(wù)器地址函數(shù) local function rtmp_http_request() local get_device_id = netdrv.mac(socket.LWIP_STA) -- Air8101用STA MAC作為設(shè)備ID log.info("打印設(shè)備的ID號(hào)", get_device_id) local url = "http://video.luatos.com:10030/api-system/deviceVideo/get" .. "/" .. get_device_id log.info("打印的URL", url) local camera_header = { ["Accept-Encoding"] = "identity", ["Host"] = "video.luatos.com:10030", ["Content-Type"] = "application/json" } local post_body = { deviceAccess = "8", -- 8 代表接入方式為RTMP deviceUser = "admin", -- 平臺(tái)錄像機(jī)設(shè)置的設(shè)備用戶（不是登錄用的用戶名） devicePsd = "Air123456" -- 平臺(tái)錄像機(jī)設(shè)置的設(shè)備密碼（不是登錄用的密碼） } -- 發(fā)送POST請(qǐng)求并等待響應(yīng) local code, headers, body = http.request("POST", url, camera_header, json.encode(post_body)).wait() log.info("打印的請(qǐng)求code", code) if code ~= 200 then log.error("HTTP請(qǐng)求失敗") return false, nil end log.info("打印的請(qǐng)求body", body) local json_body = json.decode(body) if not json_body or json_body.code ~= 200 then log.error("請(qǐng)求視頻URL失敗", json_body and json_body.msg or "未知錯(cuò)誤") return false, nil end local rtmp_url = json_body.data.urlList[1] log.info("請(qǐng)求得到的RTMP地址", rtmp_url) if not rtmp_url then log.error("未獲取到RTMP地址") return false, nil end return true, rtmp_url end local g_s_rtmp_state -- RTMP狀態(tài)回調(diào)函數(shù) -- 連接過(guò)程中，如果連接失敗，state狀態(tài)依次為STATE_IDLE->STATE_DISCONNECTING->STATE_IDLE->STATE_ERROR -- 已經(jīng)建立了連接，推流過(guò)程中，如果本地調(diào)用disconnect接口，state狀態(tài)依次為STATE_IDLE->STATE_DISCONNECTING->STATE_IDLE -- 已經(jīng)建立了連接，推流過(guò)程中，如果網(wǎng)絡(luò)或者服務(wù)器出現(xiàn)了異常，或者本地發(fā)送數(shù)據(jù)出現(xiàn)了異常，state狀態(tài)依次為STATE_IDLE->STATE_DISCONNECTING->STATE_IDLE->STATE_ERROR local function rtmp_state_callback(state) -- 打印RTMP狀態(tài)變化基礎(chǔ)日志 log.info("rtmp_state_callback state", state) -- 根據(jù)不同狀態(tài)執(zhí)行對(duì)應(yīng)邏輯 if state == rtmp.STATE_IDLE then log.info("空閑狀態(tài)，可能和推流時(shí)效有關(guān)，需要等待一段時(shí)間，再嘗試重連") if g_s_rtmp_state==rtmp.STATE_DISCONNECTING then sys.sendMsg(RTMP_TASK_NAME, "RTMP_EVENT", "DISCONNECTED") end elseif state == rtmp.STATE_CONNECTING then log.info("正在連接") elseif state == rtmp.STATE_HANDSHAKING then log.info("握手中") elseif state == rtmp.STATE_CONNECTED then log.info("已連接") sys.sendMsg(RTMP_TASK_NAME, "RTMP_EVENT", "CONNECTED") elseif state == rtmp.STATE_PUBLISHING then log.info("推流中") elseif state == rtmp.STATE_DISCONNECTING then log.info("正在斷開(kāi)") elseif state == rtmp.STATE_ERROR then log.info("錯(cuò)誤") end g_s_rtmp_state = state end -- RTMP main task 的任務(wù)處理函數(shù) local function rtmp_task() local camera_opened, msg, rtmpc, success, rtmp_url while true do -- 1. 如果當(dāng)前時(shí)間點(diǎn)設(shè)置的默認(rèn)網(wǎng)卡還沒(méi)有連接成功，一直在這里循環(huán)等待 while not socket.adapter(socket.dft()) do log.warn("rtmp_task", "wait IP_READY", socket.dft()) -- 在此處阻塞等待默認(rèn)網(wǎng)卡連接成功的消息"IP_READY" -- 或者等待1秒超時(shí)退出阻塞等待狀態(tài); -- 注意：此處的1000毫秒超時(shí)不要修改的更長(zhǎng)； -- 因?yàn)楫?dāng)使用exnetif.set_priority_order配置多個(gè)網(wǎng)卡連接外網(wǎng)的優(yōu)先級(jí)時(shí)，會(huì)隱式的修改默認(rèn)使用的網(wǎng)卡 -- 當(dāng)exnetif.set_priority_order的調(diào)用時(shí)序和此處的socket.adapter(socket.dft())判斷時(shí)序有可能不匹配 -- 此處的1秒，能夠保證，即使時(shí)序不匹配，也能1秒鐘退出阻塞狀態(tài)，再去判斷socket.adapter(socket.dft()) sys.waitUntil("IP_READY", 1000) end -- 檢測(cè)到了IP_READY消息 log.info("rtmp_task", "recv IP_READY", socket.dft()) -- 清空此task綁定的消息隊(duì)列中的未處理的消息 sys.cleanMsg(RTMP_TASK_NAME) -- 2. HTTP請(qǐng)求獲取RTMP服務(wù)器地址 success, rtmp_url = rtmp_http_request() if not success then log.error("獲取RTMP地址失敗") goto EXCEPTION_PROC end -- 3. 配置攝像頭 camera_opened = excamera.open({ id = camera.USB, sensor_width = 1280, sensor_height = 720, usb_port = 1 }) if not camera_opened then log.error("攝像頭初始化失敗") goto EXCEPTION_PROC end -- 啟動(dòng)攝像頭 log.info("啟動(dòng)攝像頭...") if not excamera.rtmp() then log.error("無(wú)法啟動(dòng)攝像頭") goto EXCEPTION_PROC end -- 創(chuàng)建RTMP客戶端 rtmpc = rtmp.create(rtmp_url) if not rtmpc then log.error("rtmp.create", "創(chuàng)建RTMP客戶端失敗") goto EXCEPTION_PROC end log.info("rtmp.create", "RTMP客戶端創(chuàng)建成功") -- 設(shè)置RTMP狀態(tài)回調(diào) rtmpc:setCallback(rtmp_state_callback) -- 連接RTMP服務(wù)器 log.info("開(kāi)始連接RTMP服務(wù)器...") success = rtmpc:connect() if not success then log.error("連接RTMP服務(wù)器失敗") goto EXCEPTION_PROC end -- 推流狀態(tài)的處理調(diào)度邏輯 while true do -- 等待消息 msg = sys.waitMsg(RTMP_TASK_NAME, "RTMP_EVENT") if msg then log.info("rtmp_task waitMsg", msg[2], msg[3], msg[4]) -- 連接成功 if msg[2] == "CONNECTED" then -- 直接啟動(dòng)推流，不檢查返回值 log.info("準(zhǔn)備開(kāi)始推流") rtmpc:start() log.info("推流已啟動(dòng)") -- 連接失敗/連接斷開(kāi) elseif msg[2] == "DISCONNECTED" then break -- 需要主動(dòng)關(guān)閉連接 -- 用戶需要主動(dòng)關(guān)閉rtmp連接時(shí)，可以調(diào)用sys.sendMsg(RTMP_TASK_NAME, "RTMP_EVENT", "CLOSE") elseif msg[2] == "CLOSE" then -- 主動(dòng)斷開(kāi)rtmp client連接 rtmpc:disconnect() end end end -- 出現(xiàn)異常 ::EXCEPTION_PROC:: -- 清空此task綁定的消息隊(duì)列中的未處理的消息 sys.cleanMsg(RTMP_TASK_NAME) -- 5. 關(guān)閉推流 log.info("推流結(jié)束，開(kāi)始釋放資源") -- 關(guān)閉攝像頭 if camera_opened then excamera.close() log.info("excamera已關(guān)閉") end -- 關(guān)閉RTMP客戶端 if rtmpc then rtmpc:stop() log.info("RTMP推流已停止") rtmpc:disconnect() log.info("RTMP連接已斷開(kāi)") rtmpc:destroy() log.info("RTMP客戶端已銷(xiāo)毀") end -- 確保所有狀態(tài)重置 log.info("所有資源已釋放，5秒后重連") -- 5秒后跳轉(zhuǎn)到循環(huán)體開(kāi)始位置，自動(dòng)發(fā)起重連 sys.wait(5000) end end local function wifi_sta_func(evt, data) -- evt 可能的值有: "CONNECTED", "DISCONNECTED" -- 當(dāng)evt=CONNECTED, data是連接的AP的ssid, 字符串類(lèi)型 -- 當(dāng)evt=DISCONNECTED, data斷開(kāi)的原因, 整數(shù)類(lèi)型 log.info("收到STA事件", evt, data) if evt == "DISCONNECTED" then sys.sendMsg(RTMP_TASK_NAME, "RTMP_EVENT", "DISCONNECTED") end end -- 內(nèi)存檢查函數(shù) local function memory_check() while true do -- 等待20秒 sys.wait(20000) -- 打印系統(tǒng)內(nèi)存使用信息 log.info("系統(tǒng)內(nèi)存使用情況", rtos.meminfo("sys")) -- 打印Lua虛擬機(jī)內(nèi)存使用信息 log.info("Lua虛擬機(jī)內(nèi)存使用情況", rtos.meminfo("lua")) end end -- wifi的STA相關(guān)事件 sys.subscribe("WLAN_STA_INC", wifi_sta_func) -- 運(yùn)行這個(gè)task的處理函數(shù)rtmp_task sys.taskInitEx(rtmp_task, RTMP_TASK_NAME) -- 啟動(dòng)內(nèi)存檢查任務(wù) sys.taskInit(memory_check)

2.2 RTMP推流功能核心步驟：

• 搭建好硬件環(huán)境；
• 修改rtmp_app.lua中的deviceUser、devicePsd參數(shù)；
• 修改netdrv_wifi.lua 中的Wi-Fi賬號(hào)密碼;
• 打開(kāi)main.lua文件中require “rtmp_app”，同時(shí)注釋掉:
• require “take_photo_http_post”；
• 燒錄內(nèi)核固件和相關(guān)demo成功后，自動(dòng)開(kāi)機(jī)運(yùn)行；
• 可以看到代碼運(yùn)行結(jié)果如下，日志中如果出現(xiàn)以下類(lèi)似打印則說(shuō)明RTMP推流成功。

三、合宙音視頻平臺(tái)查看

目前，合宙音視頻測(cè)試平臺(tái)已開(kāi)放安卓系統(tǒng)移動(dòng)端APP下載和PC端瀏覽器操作。

本文以PC端為例，支持使用共享賬號(hào)，在線查看合宙掛測(cè)設(shè)備，也支持用戶使用合宙IoT賬號(hào)自主添加配置在線設(shè)備。

3.1 賬號(hào)密碼

賬號(hào)密碼與您的合宙IoT平臺(tái)賬號(hào)可通用

3.2 新增設(shè)備

參照下圖按步點(diǎn)擊，注意設(shè)備賬戶密碼需與代碼中日配置一致。

3.3 查看推流視頻

點(diǎn)擊實(shí)時(shí)視頻，查看自己設(shè)備的推流情況。

感興趣的朋友自己動(dòng)手試試吧！今天的內(nèi)容就分享到這里~~~