添加AcousticEchoCanceler回声消除 AutomaticGainControl自动增益控制。

Change-Id: I0cdaae676e2419e58967106118c904dbc8d8f057

Author: SundoggyNew

sdk/video-link-android/src/main/java/com/tencent/iot/video/link/util/audio/AudioRecordUtil.java

@@ -4,6 +4,8 @@
 import android.media.AudioFormat;
 import android.media.AudioRecord;
 import android.media.MediaRecorder;
+import android.media.audiofx.AcousticEchoCanceler;
+import android.media.audiofx.AutomaticGainControl;
 import android.text.TextUtils;
 import android.util.Log;
 
@@ -27,6 +29,8 @@ public class AudioRecordUtil implements EncoderListener, FLVListener {
     private volatile boolean recorderState = true; //录制状态
     private byte[] buffer;
     private AudioRecord audioRecord;
+    private AcousticEchoCanceler canceler;
+    private AutomaticGainControl control;
     private volatile PCMEncoder pcmEncoder;
     private volatile FLVPacker flvPacker;
     private Context context;
@@ -37,6 +41,8 @@ public class AudioRecordUtil implements EncoderListener, FLVListener {
     private int bitDepth;
     private int channelCount; //声道数
     private int pitch = 0; //变调【-12~12】
+    private boolean enableAEC = false;
+    private boolean enableAGC = false;
 
     private boolean isRecord = false;
     private final ExecutorService executor = Executors.newSingleThreadExecutor();
@@ -61,6 +67,21 @@ public AudioRecordUtil(Context ctx, String id, int sampleRate, int channel, int
         this.pitch = pitch;
         init(sampleRate, channel, bitDepth);
     }
+    public AudioRecordUtil(Context ctx, String id, int sampleRate, int channel, int bitDepth, boolean enableAEC, boolean enableAGC) {
+        context = ctx;
+        deviceId = id;
+        this.enableAEC = enableAEC;
+        this.enableAGC = enableAGC;
+        init(sampleRate, channel, bitDepth);
+    }
+    public AudioRecordUtil(Context ctx, String id, int sampleRate, int channel, int bitDepth, int pitch, boolean enableAEC, boolean enableAGC) {
+        context = ctx;
+        deviceId = id;
+        this.pitch = pitch;
+        this.enableAEC = enableAEC;
+        this.enableAGC = enableAGC;
+        init(sampleRate, channel, bitDepth);
+    }
 
     private void init(int sampleRate, int channel, int bitDepth) {
         recordMinBufferSize = AudioRecord.getMinBufferSize(sampleRate, channel, bitDepth);
@@ -111,9 +132,20 @@ public void start() {
 
     private void reset() {
         buffer = new byte[recordMinBufferSize];
-        audioRecord = new AudioRecord(MediaRecorder.AudioSource.MIC, sampleRate, channel, bitDepth, recordMinBufferSize);
+        if (enableAEC) {
+            audioRecord = new AudioRecord(MediaRecorder.AudioSource.VOICE_COMMUNICATION, sampleRate, channel, bitDepth, recordMinBufferSize);
+        } else {
+            audioRecord = new AudioRecord(MediaRecorder.AudioSource.MIC, sampleRate, channel, bitDepth, recordMinBufferSize);
+        }
         pcmEncoder = new PCMEncoder(sampleRate, channelCount, this, PCMEncoder.AAC_FORMAT);
         flvPacker = new FLVPacker(this, true, false);
+        int audioSessionId = audioRecord.getAudioSessionId();
+        if (enableAEC) {
+            Log.e(TAG, "=====initAEC result: " + initAEC(audioSessionId));
+        }
+        if (enableAGC) {
+            Log.e(TAG, "=====initAGC result: " + initAGC(audioSessionId));
+        }
     }
 
     /**
@@ -136,6 +168,16 @@ public void stop() {
         pcmEncoder = null;
         flvPacker.release();
         flvPacker = null;
+        if (canceler != null) {
+            canceler.setEnabled(false);
+            canceler.release();
+            canceler = null;
+        }
+        if (control != null) {
+            control.setEnabled(false);
+            control.release();
+            control = null;
+        }
     }
 
     public void release() {
@@ -183,4 +225,37 @@ public void run() {
             }
         }
     }
+
+    public boolean isDevicesSupportAEC() {
+        return AcousticEchoCanceler.isAvailable();
+    }
+    private boolean initAEC(int audioSession) {
+        boolean isDevicesSupportAEC = isDevicesSupportAEC();
+        Log.e(TAG, "isDevicesSupportAEC: "+isDevicesSupportAEC);
+        if (!isDevicesSupportAEC) {
+            return false;
+        }
+        if (canceler != null) {
+            return false;
+        }
+        canceler = AcousticEchoCanceler.create(audioSession);
+        canceler.setEnabled(true);
+        return canceler.getEnabled();
+    }
+    public boolean isDevicesSupportAGC() {
+        return AutomaticGainControl.isAvailable();
+    }
+    private boolean initAGC(int audioSession) {
+        boolean isDevicesSupportAGC = isDevicesSupportAGC();
+        Log.e(TAG, "isDevicesSupportAGC: "+isDevicesSupportAGC);
+        if (!isDevicesSupportAGC) {
+            return false;
+        }
+        if (control != null) {
+            return false;
+        }
+        control = AutomaticGainControl.create(audioSession);
+        control.setEnabled(true);
+        return control.getEnabled();
+    }
 }