改造了推流的流程

This commit is contained in:
董宏宇
2021-02-07 17:47:09 +08:00
parent 7a600e3a15
commit e9acfe1c34
9 changed files with 156 additions and 261 deletions

View File

@@ -2,12 +2,9 @@ package com.mogo.cloud;
import android.os.Bundle;
import com.mogo.cloud.live.manager.CameraFrameManager;
import com.mogo.cloud.live.manager.ILiveStreamManager;
import com.mogo.cloud.live.manager.LiveStreamManagerImpl;
import com.mogo.cloud.live.server.PushService;
import com.mogo.cloud.passport.MoGoAiCloudClientConfig;
import com.mogo.cloud.util.Devices;
/**
@@ -16,20 +13,22 @@ import com.mogo.cloud.util.Devices;
public class LivePushActivity extends BaseLiveActivity {
public static final String TAG = "PushActivity";
private boolean isLive = false;
ILiveStreamManager liveStreamManager;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
// 初始化直播流管理
ILiveStreamManager liveStreamManager = LiveStreamManagerImpl.getInstance(this, MoGoAiCloudClientConfig.getInstance().getSn());
liveStreamManager = LiveStreamManagerImpl.getInstance(this, MoGoAiCloudClientConfig.getInstance().getSn());
liveStreamManager.uploadCamStatus(1, 1);
}
@Override
public void onVideoFrame(byte[] bytes, int bytesLength) {
//Log.i(TAG, "onVideoFrame byte length: " + bytesLength);
CameraFrameManager.getInstance().notifyYUVData(bytes, 1280, 720, 3);
if (liveStreamManager != null) {
liveStreamManager.notifyYUVData(bytes, 1280, 720, 3);
}
}
@Override
@@ -40,6 +39,8 @@ public class LivePushActivity extends BaseLiveActivity {
@Override
protected void onDestroy() {
super.onDestroy();
PushService.startService(this, PushService.ACTION_STOP_RTMP_PUSH, null);
if (liveStreamManager != null) {
liveStreamManager.stopLiveStream();
}
}
}