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

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口供電（核心板正面的撥碼開發(fā)撥到5V一端，背面的功耗測(cè)試開關(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í)播放畫面，無(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()開始推流邏輯；

監(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詳見源碼倉(cāng)庫(kù)最新文件

本文件為USB攝像頭RTMP推流功能模塊，核心業(yè)務(wù)邏輯為：

1. USB 攝像頭初始化、幀率配置與H264視頻編碼

2. 通過(guò)HTTP請(qǐng)求獲取RTMP推流地址

3. 連接RTMP服務(wù)器并進(jìn)行視頻推流

]]

-- 引入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("正在斷開")

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)卡還沒有連接成功，一直在這里循環(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("開始連接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)備開始推流")

rtmpc:start()

log.info("推流已啟動(dòng)")

-- 連接失敗/連接斷開

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)斷開rtmp client連接

rtmpc:disconnect()

end

end

end

-- 出現(xiàn)異常

::EXCEPTION_PROC::

-- 清空此task綁定的消息隊(duì)列中的未處理的消息

sys.cleanMsg(RTMP_TASK_NAME)

-- 5. 關(guān)閉推流

log.info("推流結(jié)束，開始釋放資源")

-- 關(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連接已斷開")

rtmpc:destroy()

log.info("RTMP客戶端已銷毀")

end

-- 確保所有狀態(tài)重置

log.info("所有資源已釋放，5秒后重連")

-- 5秒后跳轉(zhuǎn)到循環(huán)體開始位置，自動(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, 字符串類型

-- 當(dāng)evt=DISCONNECTED, data斷開的原因, 整數(shù)類型

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)密碼;

打開main.lua文件中require “rtmp_app”，同時(shí)注釋掉:

require “take_photo_http_post”；

燒錄內(nèi)核固件和相關(guān)demo成功后，自動(dòng)開機(jī)運(yùn)行；

可以看到代碼運(yùn)行結(jié)果如下，日志中如果出現(xiàn)以下類似打印則說(shuō)明RTMP推流成功。

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

目前，合宙音視頻測(cè)試平臺(tá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è)備的推流情況。

審核編輯 黃宇