Преглед изворни кода

change: rtmp,开启lua状态回调

Wendal Chen пре 3 месеци
родитељ
комит
962a767049
2 измењених фајлова са 11 додато и 6 уклоњено
  1. 1 1
      components/rtmp/binding/luat_lib_rtmp.c
  2. 10 5
      olddemo/camera/rtmp_usb/main.lua

+ 1 - 1
components/rtmp/binding/luat_lib_rtmp.c

@@ -168,7 +168,7 @@ static void l_state_callback(rtmp_ctx_t *ctx, rtmp_state_t oldstate, rtmp_state_
     msg.arg1 = (int)newstate;
     msg.arg2 = (int)oldstate;
     LLOGD("RTMP状态(%d)回调消息入队 %p %p", (int)newstate, &msg, ctx->user_data);
-    // luat_msgbus_put(&msg, 0);
+    luat_msgbus_put(&msg, 0);
 }
 
 /**

+ 10 - 5
olddemo/camera/rtmp_usb/main.lua

@@ -18,6 +18,10 @@ sys.taskInit(function()
     sys.waitUntil("IP_READY")
 
     camera.config(0, camera.CONF_UVC_FPS, 15)
+    -- camera.config(0, camera.CONF_H264_QP_INIT, 12)
+    -- camera.config(0, camera.CONF_H264_IMB_BITS, 120)
+    camera.config(0, camera.CONF_H264_PMB_BITS, 20)
+    camera.config(0, camera.CONF_H264_PFRAME_NUMS, 23)
     socket.sntp()
     sys.wait(200)
     result = camera.init(usb_camera_table)
@@ -25,16 +29,17 @@ sys.taskInit(function()
     camera.start(camera_id)
 
     -- local rtmpc = rtmp.create("rtmp://192.168.1.10:1935/live/abc")
-    -- local rtmpc = rtmp.create("rtmp://180.152.6.34:1935/stream1live/1ca786f5_23e5_4d89_8b1d_2eec6932775a_0001")
+    local rtmpc = rtmp.create("rtmp://180.152.6.34:1935/stream1live/1ca786f5_23e5_4d89_8b1d_2eec6932775a_0001")
     -- local rtmpc = rtmp.create("rtmp://47.94.236.172/live/1ca786f5") -- 替换为你的推流地址
-    local rtmpc = rtmp.create("rtmp://180.152.6.34:1936/live/guangzhou")
+    -- local rtmpc = rtmp.create("rtmp://180.152.6.34:1936/live/guangzhou")
     rtmpc:setCallback(function(state, ...)
+        log.info("rtmp状态变化", state, ...)
         if state == rtmp.STATE_CONNECTED then
-            log.info("rtmp", "已连接到推流服务器")
+            log.info("rtmp状态变化", "已连接到推流服务器")
         elseif state == rtmp.STATE_PUBLISHING then
-            log.info("rtmp", "已开始推流")
+            log.info("rtmp状态变化", "已开始推流")
         elseif state == rtmp.STATE_ERROR then
-            log.info("rtmp", "出错:", ...)
+            log.info("rtmp状态变化", "出错:", ...)
         end
     end)
     log.info("开始连接到推流服务器...")