HarmonyOS 鸿蒙Next AudioCapturer录音数据处理问题

HarmonyOS 鸿蒙Next AudioCapturer录音数据处理问题

import { audio } from "@kit.AudioKit";
import { Queue } from '@kit.ArkTS';
import { fileIo as fs, ReadOptions } from '@kit.CoreFileKit';

export class GroupCallSendVioceManager {
  private static instance: GroupCallSendVioceManager;

  private constructor() {
    // 私有构造函数，防止外部实例化
  }
  public static getInstance(): GroupCallSendVioceManager {
    if (!GroupCallSendVioceManager.instance) {
      GroupCallSendVioceManager.instance = new GroupCallSendVioceManager();
    }
    return GroupCallSendVioceManager.instance;
  }

  public startGroupCall():void{
    this.startRecorder()
  }

  public stopGroupCall():void{
    this.stopRecorder();
  }

  /**
   * 开始录音采集
   * @param filePath 录音存放路径
   */
  async startRecorder() {
    // 1. 创建音频采集器
    const audioCapturer = await this.getAudioCapturer()

    let path = getContext().filesDir;
    let bufferSize: number = 0;
    let filePath = path + '/MyVoice.pcm';
    this.destFile = fs.openSync(filePath, fs.OpenMode.READ_WRITE | fs.OpenMode.READ_ONLY | fs.OpenMode.CREATE | fs.OpenMode.TRUNC);
    // 2. 订阅(读取音频采集器的数据流，写入到打开的文件中)
    audioCapturer.on('readData', async (buffer) => {
      this.shortQueue.add(buffer)
      if(this.shortQueue.length > 2){

        let array1 = new Int16Array(this.shortQueue.pop());
        let array2 = new Int16Array(this.shortQueue.pop());
        let array3 = new Int16Array(this.shortQueue.pop());


        let mergedArray = new Int16Array(array1.length + array2.length + array3.length);
        mergedArray.set(array1);
        mergedArray.set(array2, array1.length);
        mergedArray.set(array3 , array1.length + array2.length)

        let options: ReadOptions = {
          offset: bufferSize,
          length: mergedArray.buffer.byteLength
        }
        fs.writeSync(this.destFile?.fd, mergedArray.buffer, options);
        bufferSize += mergedArray.buffer.byteLength;
      }

    })
    // 3. 开始
    audioCapturer.start()
  }

  // 结束录音采集
  async stopRecorder(){
    if(this.audioCapturer != null){
      // 获取音频采集器
      const audioCapturer = await this.getAudioCapturer()
      // 1. 停止录音
      await audioCapturer.stop()
      // 2. 释放资源和硬件占用
      audioCapturer.release()
      // 3. 释放变量，对象重新赋值为 null，可以被 垃圾回收机制 自动清理
      this.audioCapturer = null
    }
    fs.close(this.destFile)
  }

  // 音频采集器实例
  private audioCapturer: audio.AudioCapturer | null = null
  // 音频流配置
  private audioStreamInfo: audio.AudioStreamInfo = {
    samplingRate: audio.AudioSamplingRate.SAMPLE_RATE_8000, // 采样率
    channels: audio.AudioChannel.CHANNEL_1, // 通道
    sampleFormat: audio.AudioSampleFormat.SAMPLE_FORMAT_S16LE, // 采样格式
    encodingType: audio.AudioEncodingType.ENCODING_TYPE_RAW // 编码格式
  };
  // 音频采集器配置
  private audioCapturerInfo: audio.AudioCapturerInfo = {
    source: audio.SourceType.SOURCE_TYPE_MIC, //音源类型:Mic音频源
    capturerFlags: 0//音频采集器标志。0代表普通音频采集器，1代表低时延音频采集器。
  };
  //创建/获取音频采集器
  async getAudioCapturer() {
    //如果有的话直接返回，避免占用系统资源
    if (this.audioCapturer) {
      return this.audioCapturer
    }
    //关键API  audio.createAudioCapturer
    this.audioCapturer = await audio.createAudioCapturer({
      streamInfo: this.audioStreamInfo,
      capturerInfo: this.audioCapturerInfo
    })
    return this.audioCapturer
  }
}

如上面，audioCapturer.on('readData', async (buffer) => {}中，buffer转为Int16Array写入.pcm文件，用第三方应用播放.pcm文件，音质会变成电音，buffer直接写入.pcm文件播放声音正常，各位大佬看看什么问题，因为我们需要对.pcm进行编解码，所以buferr传入native层，需要转为int16array