Promise改寫獲取螢石雲直播地址接口示例
改寫原因
通常情況下,螢石雲的直播地址都是在服務端進行獲取,然後存儲到數據庫中,但是螢石雲官方默認同一個ip最多隻能使用5個appKey
,否則會爆出appKey數量超出安全限制
的錯誤提示。
因此改為前端進行api的調用,來分散ip和appKey之間的綁定(這一點對開發者而言其實意義並不是很大,應為開發者的ip是固定的,測試過程中遲早也會超出數量限制)。
技術選擇
需求明確之後,有兩種方案可供選擇。
- ajax回調
- Promise異步編程解決方案
整個直播鏈接的獲取流程大致如下:
可想而知,如果單純用ajax進行回調,無疑會陷入回調地獄中,於是果斷選擇瞭Promise進行改寫(進步源於折騰)。
源碼
let serial, channelNo; /** * 向服務器查詢攝像頭直播鏈接 * * @param cameraId 攝像頭id * @param perspective 是否允許查看其他用戶的攝像頭 * * 服務器首先查詢數據庫直播鏈接緩存 * ------如果數據庫有緩存,則服務器將直接返回cameraBean的信息 * ------如果沒有緩存,則查找當前用戶的accessToken * ------------如果數據庫保存有accessToken,則返回accessToken * ------------數據庫沒有保存accessToken,則返回appKey/appSecret,由瀏覽器進行下一步accessToken的獲取 */ function step1(cameraId, perspective) { return new Promise(function (resolve, reject) { $.ajax({ type: "GET", url: "/cameraManage/getCameraAddress?id=" + cameraId + "&perspective=" + perspective, success: function (data) { if (data.state == 'success') { resolve(data.data); } else { layer.msg(data.msg); console.log(data.msg); } }, error: function (e) { layer.msg("網絡異常請稍後再試"); console.log("error"); } }); } ) } /** * 接收step1返回的結果,判斷結果類型 * ------如果是camera對象或者是accessToken,則直接攜帶該數據進入step3 * ------如果是appKey/appSecret,則調用開放平臺接口,查詢accessToken,並上傳至服務器保存,進行step3 */ function step2(data) { serial = data.serial; channelNo = data.channelNo; return new Promise(function (resolve, reject) { if (data.camera || data.accessToken) {//服務器直接返回瞭攝像頭直播信息或accessToken resolve(data); } else if (data.appKey && data.appSecret) {//服務器返回瞭appKey && appSecret $.ajax({ type: "POST", url: "https://open.ys7.com/api/lapp/token/get", data: { appKey: data.appKey, appSecret: data.appSecret }, dataType: "json", success: function (data) { let tokenData = data.data; if (data.code == "200" && tokenData) { resolve(tokenData); uploadAccessToken(tokenData.accessToken, tokenData.expireTime, 1); } }, error: function (e) { layer.msg("網絡異常請稍後再試"); console.log(e); } }); } }); } /** * 接收step2返回的數據,camera或accessToken * ------如果是camera對象,則直接返回 * ------如果是accessToken,則調用開放平臺接口,查詢直播鏈接,並上傳至服務器保存 */ function step3(data) { if (data.camera) { // console.log("上一步直接返回瞭camera"); return data.camera; } return new Promise((resolve, reject) => { $.ajax({ type: "POST", url: "https://open.ys7.com/api/lapp/live/video/list", data: { accessToken: data.accessToken, }, dataType: "json", success: function (data) { let addressData = data.data; if (data.code != '200' || !addressData) { layer.msg("直播鏈接獲取失敗"); console.log("直播鏈接獲取失敗"); return; } for (let i = 0; i < addressData.length; i++) { if (addressData[i].deviceSerial == serial && addressData[i].channelNo == channelNo) { let argObject = { serial: addressData[i].deviceSerial, channelNo: addressData[i].channelNo, flv: addressData[i].flvAddress, flvHd: addressData[i].hdFlvAddress, hls: addressData[i].liveAddress, hlsHd: addressData[i].hdAddress, rtmp: addressData[i].rtmp, rtmpHd: addressData[i].rtmpHd }; // console.log("獲取瞭直播鏈接"); // console.log(argObject); resolve(argObject); uploadYs7CameraAddress(argObject); break; } } }, error: function (e) { layer.msg("網絡異常請稍後再試"); console.log(e); } }); }); } /** * 獲取攝像頭直播鏈接調用接口 * @param cameraId 攝像頭id * @param perspective 是否允許當前用戶查看其他用戶的攝像頭 */ function getCameraAddress(cameraId, perspective) { return step1(cameraId, perspective).then(step2).then(step3); } /** * 將accessToken上傳至服務器保存 */ function uploadAccessToken(accessToken, expireTime, cameraType) { $.ajax({ type: "POST", url: "/cameraManage/uploadAccessToken", data: { accessToken: accessToken, expireTime: expireTime, cameraType: cameraType }, dataType: "json", }); } /** * 將得到的攝像頭鏈接上傳至服務器保存 */ function uploadYs7CameraAddress(args) { args.id = 0; $.ajax({ type: "POST", url: "/cameraManage/uploadYs7CameraAddress", data: args, dataType: "json", }); }
之後前端調用攝像頭的接口隻需要編寫如下代碼就可以瞭
getCameraAddress(cameraId, 0).then(data => { if (data == null || data == undefined) { //未綁定攝像頭的錯誤提示 ... return; } //獲得鏈接之後的正常操作流程 ... });
以上就是Promise改寫獲取螢石雲直播地址接口示例的詳細內容,更多關於Promise獲取直播地址接口的資料請關註WalkonNet其它相關文章!