利用libmp3lame实现在Android上录音MP3文件示例

之前项目需要实现MP3的录音，于是使用上了Lame这个库。这次做一个demo，使用AndroidStudio+Cmake+NDK进行开发。利用Android SDK提供的AndroidRecorder进行录音，得到PCM数据，并使用jni调用Lame这个C库将PCM数据转换为MP3文件。并使用MediaPlayer对录音的MP3文件进行播放。另外此次的按键是仿微信的语音按键，按下录音，松开结束，若中途上滑松开即取消

效果如下：

项目地址: LameMp3ForAndroid_jb51.rar

一、主要类的介绍

• Mp3Recorder—— 是负责调用AudioRecorder进行录音的类
• SimpleLame——是负责将MP3Recorder录制出的PCM数据转换成MP3文件
• DataEncodeThread——是负责执行PCM转MP3的线程
• LameMp3Manager——是对Mp3Recorder的多一次封装，增加了取消后删除之前录制的数据的逻辑
• MediaPlayerUtil——是对系统的MediaPlayer进行简单的封装，使其只需要三步就可以播放音频文件
• MediaRecorderButton ——是一个仿微信录音按键的控件，按下录制，松开结束，录制时上滑则取消录制

二、录制的流程

1. Mp3Recorder调用startRecording()开始录制并初始化DataEncoderThread线程，并定期将录制的PCM数据，传入DataEncoderThread中。
2. 在DataEncoderThread里，SimpleLame将Mp3Recorder传入的PCM数据转换成MP3格式并写入文件，其中SimpleLame通过jni对Lame库进行调用
3. Mp3Recorder调用stopRecording()停止录制，并通知DataEncoderThread线程录制结束，DataEncoderThread将剩余的数据转换完毕。

三、主要的实现代码

Mp3Recorder

public class Mp3Recorder {
  static {
    System.loadLibrary("lamemp3");
  }
  //默认采样率
  private static final int DEFAULT_SAMPLING_RATE = 44100;
  //转换周期，录音每满160帧，进行一次转换
  private static final int FRAME_COUNT = 160;
  //输出MP3的码率
  private static final int BIT_RATE = 32;
  //根据资料假定的最大值。 实测时有时超过此值。
  private static final int MAX_VOLUME = 2000;
  private AudioRecord audioRecord = null;
  private int bufferSize;
  private File mp3File;
  private int mVolume;
  private short[] mPCMBuffer;
  private FileOutputStream os = null;
  private DataEncodeThread encodeThread;
  private int samplingRate;
  private int channelConfig;
  private PCMFormat audioFormat;
  private boolean isRecording = false;
  private ExecutorService executor = Executors.newFixedThreadPool(1);
  private OnFinishListener finishListener;

  public interface OnFinishListener {
    void onFinish(String mp3SavePath);
  }

  public Mp3Recorder(int samplingRate, int channelConfig, PCMFormat audioFormat) {
    this.samplingRate = samplingRate;
    this.channelConfig = channelConfig;
    this.audioFormat = audioFormat;
  }

  public Mp3Recorder() {
    this(DEFAULT_SAMPLING_RATE, AudioFormat.CHANNEL_IN_MONO, PCMFormat.PCM_16BIT);
  }


  public void startRecording(File mp3Save) throws IOException {
    if (isRecording) return;
    this.mp3File = mp3Save;
    if (audioRecord == null) {
      initAudioRecorder();
    }
    audioRecord.startRecording();
    Runnable runnable = new Runnable() {
      @Override
      public void run() {
        isRecording = true;
        //循环的从AudioRecord获取录音的PCM数据
        while (isRecording) {
          int readSize = audioRecord.read(mPCMBuffer, 0, bufferSize);
          if (readSize > 0) {
            //待转换的PCM数据放到转换线程中
            encodeThread.addChangeBuffer(mPCMBuffer,readSize);
            calculateRealVolume(mPCMBuffer, readSize);
          }
        }
        // 录音完毕，释放AudioRecord的资源
        try {
          audioRecord.stop();
          audioRecord.release();
          audioRecord = null;
          // 录音完毕，通知转换线程停止，并等待直到其转换完毕
          Message msg = Message.obtain(encodeThread.getHandler(), DataEncodeThread.PROCESS_STOP);
          msg.sendToTarget();
          encodeThread.join();
          //转换完毕后回调监听
          if(finishListener != null) finishListener.onFinish(mp3File.getPath());
        } catch (InterruptedException e) {
          e.printStackTrace();
        } finally {
          if (os != null) {
            try {
              os.close();
            } catch (IOException e) {
              e.printStackTrace();
            }
          }
        }
      }
    };
    executor.execute(runnable);
  }

  public void stopRecording() throws IOException {
    isRecording = false;
  }

  //计算音量大小
  private void calculateRealVolume(short[] buffer, int readSize) {
    double sum = 0;
    for (int i = 0; i < readSize; i++) {
      sum += buffer[i] * buffer[i];
    }
    if (readSize > 0) {
      double amplitude = sum / readSize;
      mVolume = (int) Math.sqrt(amplitude);
    }
  }

  public int getVolume(){
    if (mVolume >= MAX_VOLUME) {
      return MAX_VOLUME;
    }
    return mVolume;
  }

  public int getMaxVolume(){
    return MAX_VOLUME;
  }

  public void setFinishListener(OnFinishListener listener){
    this.finishListener = listener;
  }

  private void initAudioRecorder() throws IOException {
    int bytesPerFrame = audioFormat.getBytesPerFrame();
    //计算缓冲区的大小，使其是设置周期帧数的整数倍，方便循环
    int frameSize = AudioRecord.getMinBufferSize(samplingRate, channelConfig, audioFormat.getAudioFormat()) / bytesPerFrame;
    if (frameSize % FRAME_COUNT != 0) {
      frameSize = frameSize + (FRAME_COUNT - frameSize % FRAME_COUNT);
    }
    bufferSize = frameSize * bytesPerFrame;

    audioRecord = new AudioRecord(MediaRecorder.AudioSource.MIC, samplingRate, channelConfig, audioFormat.getAudioFormat(), bufferSize);
    mPCMBuffer = new short[bufferSize];
    SimpleLame.init(samplingRate, 1, samplingRate, BIT_RATE);
    os = new FileOutputStream(mp3File);
    // 创建转码的线程
    encodeThread = new DataEncodeThread(os, bufferSize);
    encodeThread.start();
    //给AudioRecord设置刷新监听，待录音帧数每次达到FRAME_COUNT，就通知转换线程转换一次数据
    audioRecord.setRecordPositionUpdateListener(encodeThread, encodeThread.getHandler());
    audioRecord.setPositionNotificationPeriod(FRAME_COUNT);
  }
}

DataEncodeThread

public class DataEncodeThread extends Thread implements AudioRecord.OnRecordPositionUpdateListener {

  public static final int PROCESS_STOP = 1;
  private StopHandler handler;
  private byte[] mp3Buffer;
  //用于存取待转换的PCM数据
  private List<ChangeBuffer> mChangeBuffers = Collections.synchronizedList(new LinkedList<ChangeBuffer>());
  private FileOutputStream os;
  private CountDownLatch handlerInitLatch = new CountDownLatch(1);

  private static class StopHandler extends Handler {
    WeakReference<DataEncodeThread> encodeThread;

    public StopHandler(DataEncodeThread encodeThread) {
      this.encodeThread = new WeakReference<>(encodeThread);
    }

    @Override
    public void handleMessage(Message msg) {
      if (msg.what == PROCESS_STOP) {
        DataEncodeThread threadRef = encodeThread.get();
        //录音停止后，将剩余的PCM数据转换完毕
        for (;threadRef.processData() > 0;);
        removeCallbacksAndMessages(null);
        threadRef.flushAndRelease();
        getLooper().quit();
      }
      super.handleMessage(msg);
    }
  }

  public DataEncodeThread(FileOutputStream os, int bufferSize) {
    this.os = os;
    mp3Buffer = new byte[(int) (7200 + (bufferSize * 2 * 1.25))];
  }

  @Override
  public void run() {
    Looper.prepare();
    handler = new StopHandler(this);
    handlerInitLatch.countDown();
    Looper.loop();
  }

  public Handler getHandler() {
    try {
      handlerInitLatch.await();
    } catch (InterruptedException e) {
      e.printStackTrace();
      Log.e(TAG, "Error when waiting handle to init");
    }
    return handler;
  }

  @Override
  public void onMarkerReached(AudioRecord recorder) {
    // Do nothing
  }

  @Override
  public void onPeriodicNotification(AudioRecord recorder) {
    //由AudioRecord进行回调，满足帧数，通知数据转换
    processData();
  }

  //从缓存区ChangeBuffers里获取待转换的PCM数据，转换为MP3数据,并写入文件
  private int processData() {
    if(mChangeBuffers != null && mChangeBuffers.size() > 0) {
      ChangeBuffer changeBuffer = mChangeBuffers.remove(0);
      short[] buffer = changeBuffer.getData();
      int readSize = changeBuffer.getReadSize();
      Log.d(TAG, "Read size: " + readSize);
      if (readSize > 0) {
        int encodedSize = SimpleLame.encode(buffer, buffer, readSize, mp3Buffer);
        if (encodedSize < 0) {
          Log.e(TAG, "Lame encoded size: " + encodedSize);
        }
        try {
          os.write(mp3Buffer, 0, encodedSize);
        } catch (IOException e) {
          e.printStackTrace();
          Log.e(TAG, "Unable to write to file");
        }
        return readSize;
      }
    }
    return 0;
  }

  private void flushAndRelease() {
    final int flushResult = SimpleLame.flush(mp3Buffer);

    if (flushResult > 0) {
      try {
        os.write(mp3Buffer, 0, flushResult);
      } catch (final IOException e) {
        e.printStackTrace();
      }
    }
  }

  public void addChangeBuffer(short[] rawData, int readSize){
    mChangeBuffers.add(new ChangeBuffer(rawData, readSize));
  }

  private class ChangeBuffer{
    private short[] rawData;
    private int readSize;
    public ChangeBuffer(short[] rawData, int readSize){
      this.rawData = rawData.clone();
      this.readSize = readSize;
    }
    public short[] getData(){
      return rawData;
    }
    public int getReadSize(){
      return readSize;
    }
  }
}

SimpleLame 主要的逻辑是通过jni调用Lame库

public class SimpleLame {

  public native static void close();

  public native static int encode(short[] buffer_l, short[] buffer_r, int samples, byte[] mp3buf);

  public native static int flush(byte[] mp3buf);

  public native static void init(int inSampleRate, int outChannel, int outSampleRate, int outBitrate, int quality);

  public static void init(int inSampleRate, int outChannel, int outSampleRate, int outBitrate) {
    init(inSampleRate, outChannel, outSampleRate, outBitrate, 7);
  }
}

#include <cwchar>
#include "SimpleLame.h"
#include "lamemp3/lame.h"

static lame_global_flags *glf = NULL;

void Java_com_clam314_lame_SimpleLame_close(JNIEnv *env, jclass type){
  lame_close(glf);
  glf = NULL;
}

jint Java_com_clam314_lame_SimpleLame_encode(JNIEnv *env, jclass type, jshortArray buffer_l_,
                    jshortArray buffer_r_, jint samples, jbyteArray mp3buf_) {
  jshort *buffer_l = env->GetShortArrayElements(buffer_l_, NULL);
  jshort *buffer_r = env->GetShortArrayElements(buffer_r_, NULL);
  jbyte *mp3buf = env->GetByteArrayElements(mp3buf_, NULL);

  const jsize mp3buf_size = env->GetArrayLength(mp3buf_);

  int result =lame_encode_buffer(glf, buffer_l, buffer_r, samples, (u_char*)mp3buf, mp3buf_size);

  env->ReleaseShortArrayElements(buffer_l_, buffer_l, 0);
  env->ReleaseShortArrayElements(buffer_r_, buffer_r, 0);
  env->ReleaseByteArrayElements(mp3buf_, mp3buf, 0);

  return result;
}

jint Java_com_clam314_lame_SimpleLame_flush(JNIEnv *env, jclass type, jbyteArray mp3buf_) {
  jbyte *mp3buf = env->GetByteArrayElements(mp3buf_, NULL);

  const jsize mp3buf_size = env->GetArrayLength(mp3buf_);

  int result = lame_encode_flush(glf, (u_char*)mp3buf, mp3buf_size);

  env->ReleaseByteArrayElements(mp3buf_, mp3buf, 0);

  return result;
}

void Java_com_clam314_lame_SimpleLame_init__IIIII(JNIEnv *env, jclass type, jint inSampleRate, jint outChannel,
                       jint outSampleRate, jint outBitrate, jint quality) {
  if(glf != NULL){
    lame_close(glf);
    glf = NULL;
  }
  glf = lame_init();
  lame_set_in_samplerate(glf, inSampleRate);
  lame_set_num_channels(glf, outChannel);
  lame_set_out_samplerate(glf, outSampleRate);
  lame_set_brate(glf, outBitrate);
  lame_set_quality(glf, quality);
  lame_init_params(glf);
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# android  # 录音  # mp3  # android录音mp3格式  # libmp3lame  # Android实现录音方法（仿微信语音、麦克风录音、发送语音、解决5.0以上BUG）  # Android音频录制MediaRecorder之简易的录音软件实现代码  # Android简单的利用MediaRecorder进行录音的实例代码  # Android应用开发：电话监听和录音代码示例  # Android App调用MediaRecorder实现录音功能的实例  # Android实现录音功能实现实例（MediaRecorder）  # Android开发四大组件之实现电话拦截和电话录音  # Android 实现电话来去自动录音的功能  # Android使用MediaRecorder实现录音及播放  # Android仿微信录音功能  # 使其  # 帧数  # 按下  # 转换成  # 转换为  # 回调  # 是一个  # 上了  # 做一个  # 只需要  # 三步  # 中途  # 大家多多  # 就可以  # 增加了  # 采样率  # 整数倍  # 完毕后  # String  # onFinish 

相关文章： 如何用PHP工具快速搭建高效网站？  小视频制作网站有哪些,有什么看国内小视频的网站，求推荐？  潍坊网站制作公司有哪些,潍坊哪家招聘网站好？  建站之星手机一键生成：多端自适应+小程序开发快速建站指南  建站之星官网登录失败？如何快速解决？  大连 网站制作,大连天途有线官网？  道歉网站制作流程,世纪佳缘致歉小吴事件，相亲网站身份信息伪造该如何稽查？  赚钱网站制作软件,建一个网站怎样才能赚钱?是如何盈利的？  上海网站制作网站建设公司,建筑电工证网上查询系统入口？  建站主机是否等同于虚拟主机？  攀枝花网站建设,攀枝花营业执照网上怎么年审？  北京网站制作网页,网站升级改版需要多久？  如何在香港服务器上快速搭建免备案网站？  如何在阿里云ECS服务器部署织梦CMS网站？  如何在阿里云虚拟主机上快速搭建个人网站？  c++23 std::expected怎么用 c++优雅处理函数错误返回【详解】  制作旅游网站html,怎样注册旅游网站？  建站之星后台管理系统如何操作？  平台云上自主建站：模板化设计与智能工具打造高效网站  建站之星代理平台如何选择最佳方案？  建站之星备案流程有哪些注意事项？  专业商城网站制作公司有哪些,pi商城官网是哪个？  建站之星如何配置系统实现高效建站？  建站之星下载版如何获取与安装？  如何在服务器上三步完成建站并提升流量？  定制建站哪家更专业可靠？推荐榜单揭晓  建站为何优先选择香港服务器？  建站之星后台密码遗忘如何找回？  成都品牌网站制作公司,成都营业执照年报网上怎么办理？  官网自助建站平台指南：在线制作、快速建站与模板选择全解析  ,交易猫的商品怎么发布到网站上去？  5种Android数据存储方式汇总  seo网站制作优化,网站SEO优化步骤有哪些？  如何配置IIS站点权限与局域网访问？  如何快速生成橙子建站落地页链接？  测试制作网站有哪些,测试性取向的权威测试或者网站？  建站之星代理如何优化在线客服效率？  高配服务器限时抢购：企业级配置与回收服务一站式优惠方案  建站VPS能否同时实现高效与安全翻墙？  西安专业网站制作公司有哪些,陕西省建行官方网站？  网页设计网站制作软件,microsoft office哪个可以创建网页？  如何用美橙互联一键搭建多站合一网站？  电视网站制作tvbox接口,云海电视怎样自定义添加电视源？  如何选择靠谱的建站公司加盟品牌？  ,南京靠谱的征婚网站？  营销式网站制作方案,销售哪个网站招聘效果最好？  网站制作和推广的区别,想自己建立一个网站做推广，有什么快捷方法马上做好一个网站？  代刷网站制作软件,别人代刷火车票靠谱吗？  宝塔建站后网页无法访问如何解决？  建站主机与服务器功能差异如何区分？