增加接受小程序或者app数据流保存

Author: neilyhe

app/src/main/java/com/example/ivdemo/BaseIPCActivity.kt

@@ -222,7 +222,7 @@ abstract class BaseIPCActivity<VB : ViewBinding> : AppCompatActivity(), IvDevice
         this.visitor = visitor
         this.channel = channel
         this.videoResType = videoResType
-        Log.w(TAG, "onNotify()")
+        Log.w(TAG, "onNotify() called with event = $event, visitor = $visitor, channel = $channel, videoResType = $videoResType")
         var msg = ""
         when (event) {
             P2pEventType.IV_AVT_EVENT_P2P_PEER_CONNECT_FAIL, P2pEventType.IV_AVT_EVENT_P2P_PEER_ERROR -> {

app/src/main/java/com/example/ivdemo/TweCallActivity.kt

@@ -126,7 +126,6 @@ class TweCallActivity : BaseIPCActivity<ActivityTweCallBinding>(), IvVoipCallbac
 
     override fun initView() {
         cameraRecorder.init(this)
-        cameraRecorder.isSaveRecord(true)
         with(binding) {
             titleLayout.tvTitle.text = getString(R.string.title_tweCall)
             titleLayout.ivRightBtn.isVisible = true

app/src/main/java/com/example/ivdemo/popup/CustomCommandDialog.kt

@@ -1,6 +1,7 @@
 package com.example.ivdemo.popup
 
 import android.content.Context
+import android.util.Log
 import android.widget.Toast
 import androidx.fragment.app.FragmentManager
 import androidx.lifecycle.lifecycleScope
@@ -43,7 +44,11 @@ class CustomCommandDialog(context: Context, private val visitor: Int) :
     }
 
     fun receiveCommand(msg: String): JSONObject {
-        binding.tvResult.append("接受信令 ==> $msg\n\n")
+        Log.d("IPCActivity","receiveCommand msg:$msg")
+
+        lifecycleScope.launch {
+            binding.tvResult.append("接受信令 ==> $msg\n\n")
+        }
         var replyMsg = binding.tvCommand.text.toString()
         if (replyMsg.isEmpty()) {
             showToast("回复信令内容不能为空，已取默认值success")
@@ -57,7 +62,10 @@ class CustomCommandDialog(context: Context, private val visitor: Int) :
         } catch (e: JSONException) {
             e.printStackTrace()
         }
-        binding.tvResult.append("回复信令 ==> $resJson\n\n")
+        lifecycleScope.launch {
+            binding.tvResult.append("回复信令 ==> $resJson\n\n")
+        }
+        Log.d("IPCActivity","receiveCommand returnJson:$resJson")
         return resJson
     }
 

app/src/main/java/com/tencent/iotvideo/link/SimplePlayer.java

@@ -2,18 +2,31 @@
 
 import android.content.Context;
 import android.os.Build;
+import android.text.TextUtils;
 import android.util.Log;
 import android.view.Surface;
 
 import com.tencent.iotvideo.link.decoder.AudioDecoder;
 import com.tencent.iotvideo.link.decoder.VideoDecoder;
+import com.tencent.iotvideo.link.util.UtilsKt;
 
+import java.io.File;
+import java.io.FileOutputStream;
 import java.io.IOException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 public class SimplePlayer {
     private static final String TAG = "SimplePlayer";
     private static final char[] HEX_ARRAY = "0123456789ABCDEF".toCharArray();
 
+    private String receiveH264FilePath = "/sdcard/wx_video.h264";
+    private String receiveAacFilePath = "/sdcard/wx_audio.aac";
+    private FileOutputStream h264Fos;
+    private FileOutputStream aacFos;
+    private boolean isSaveReceiveRecord = false;
+    private final ExecutorService executor = Executors.newSingleThreadExecutor();
+
     public static String bytesToHex(byte[] bytes, int length) {
         char[] hexChars = new char[length * 2];
         for (int j = 0; j < length; j++) {
@@ -34,6 +47,45 @@ public void setContext(Context context) {
         }
     }
 
+    /**
+     * 保存音视频数据
+     *
+     * @param isSaveReceiveRecord
+     */
+    public void isSaveReceiveRecord(boolean isSaveReceiveRecord) {
+        this.isSaveReceiveRecord = isSaveReceiveRecord;
+        recordSpeakH264(isSaveReceiveRecord);
+        recordSpeakAac(isSaveReceiveRecord);
+    }
+
+    public void recordSpeakH264(boolean isRecord) {
+        if (isRecord) {
+            if (!TextUtils.isEmpty(receiveH264FilePath)) {
+                try {
+                    File file = UtilsKt.getFile(receiveH264FilePath);
+                    h264Fos = new FileOutputStream(file);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                    Log.e(TAG, receiveH264FilePath + "临时缓存文件未找到");
+                }
+            }
+        }
+    }
+
+    public void recordSpeakAac(boolean isRecord) {
+        if (isRecord) {
+            if (!TextUtils.isEmpty(receiveAacFilePath)) {
+                try {
+                    File file = UtilsKt.getFile(receiveAacFilePath);
+                    aacFos = new FileOutputStream(file);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                    Log.e(TAG, receiveAacFilePath + "临时缓存文件未找到");
+                }
+            }
+        }
+    }
+
     public int startVideoPlay(Surface surface, int visitor, int type, int height, int width) {
         Log.d(TAG, "video input from visitor " + visitor + " height " + height + " width " + width + ", model:" + Build.MODEL);
         // type == 0: h.264/avc; type == 1: h.265/hevc
@@ -99,7 +151,9 @@ public int stopAudioPlay(int visitor) {
     public int playVideoStream(int visitor, byte[] data, int len, long pts, long seq) {
 //        Log.d(TAG, "video frame: visitor "+ visitor + " len " + len + " pts " + pts + " seq " + seq);
         if (videoDecoder != null) {
-            return videoDecoder.decoderH264(data, len, pts);
+            int resCode = videoDecoder.decoderH264(data, len, pts);
+            saveH264(data);
+            return resCode;
         }
         return 0;
     }
@@ -111,8 +165,42 @@ public int playAudioStream(int visitor, byte[] data, int len, long pts, long seq
             if (videoDecoder != null) {
                 audioDecoder.setCurrentVideoPts(videoDecoder.getCurrentVideoPts());
             }
-            return audioDecoder.decoderAAC(data, len, pts);
+            int resCode = audioDecoder.decoderAAC(data, len, pts);
+            saveAac(data);
+            return resCode;
         }
         return 0;
     }
+
+    public void saveH264(byte[] datas) {
+        if (isSaveReceiveRecord) {
+            if (executor.isShutdown()) return;
+            executor.submit(() -> {
+                if (h264Fos != null) {
+                    try {
+                        h264Fos.write(datas);
+                        h264Fos.flush();
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                    }
+                }
+            });
+        }
+    }
+
+    public void saveAac(byte[] datas) {
+        if (isSaveReceiveRecord) {
+            if (executor.isShutdown()) return;
+            executor.submit(() -> {
+                if (aacFos != null) {
+                    try {
+                        aacFos.write(datas);
+                        aacFos.flush();
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                    }
+                }
+            });
+        }
+    }
 }