之前项目需要实现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 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel如何处理CORS跨域问题_Laravel项目CORS配置与解决方案  佛山企业网站制作公司有哪些,沟通100网上服务官网？  laravel怎么为API路由添加签名中间件保护_laravel API路由签名中间件保护方法  Laravel怎么上传文件_Laravel图片上传及存储配置  C++用Dijkstra(迪杰斯特拉)算法求最短路径  Gemini手机端怎么发图片_Gemini手机端发图方法【步骤】  Laravel如何构建RESTful API_Laravel标准化API接口开发指南  Laravel怎么实现支付功能_Laravel集成支付宝微信支付  非常酷的网站设计制作软件,酷培ai教育官方网站？  php打包exe后无法访问网络共享_共享权限设置方法【教程】  Midjourney怎么调整光影效果_Midjourney光影调整方法【指南】  如何用已有域名快速搭建网站？  Laravel N+1查询问题如何解决_Eloquent预加载(Eager Loading)优化数据库查询  电商网站制作价格怎么算,网上拍卖流程以及规则？  深圳网站制作设计招聘,关于服装设计的流行趋势，哪里的资料比较全面？  Laravel Octane如何提升性能_使用Laravel Octane加速你的应用  html如何与html链接_实现多个HTML页面互相链接【互相】  uc浏览器二维码扫描入口_uc浏览器扫码功能使用地址  如何用美橙互联一键搭建多站合一网站？  奇安信“盘古石”团队突破 iOS 26.1 提权  Windows10如何更改计算机工作组_Win10系统属性修改Workgroup  在线教育网站制作平台,山西立德教育官网？  极客网站有哪些,DoNews、36氪、爱范儿、虎嗅、雷锋网、极客公园这些互联网媒体网站有什么差异？  香港服务器网站搭建教程-电商部署、配置优化与安全稳定指南  如何用wdcp快速搭建高效网站？  Laravel如何生成PDF或Excel文件_Laravel文档导出工具与使用教程  Laravel的契約(Contracts)是什么_深入理解Laravel Contracts与依赖倒置  Laravel如何设置定时任务（Cron Job）_Laravel调度器与任务计划配置  Laravel如何使用Collections进行数据处理？（实用方法示例）  西安专业网站制作公司有哪些,陕西省建行官方网站？  ,网页ppt怎么弄成自己的ppt？  Laravel如何与Inertia.js和Vue/React构建现代单页应用  如何用狗爹虚拟主机快速搭建网站？  制作企业网站建设方案,怎样建设一个公司网站？  android nfc常用标签读取总结  免费的流程图制作网站有哪些,2025年教师初级职称申报网上流程？  Linux安全能力提升路径_长期防护思维说明【指导】  Laravel模型事件有哪些_Laravel Model Event生命周期详解  Laravel如何实现多级无限分类_Laravel递归模型关联与树状数据输出【方法】  Laravel怎么实现微信登录_Laravel Socialite第三方登录集成  如何在建站主机中优化服务器配置？  大连 网站制作,大连天途有线官网？  Laravel Eloquent模型如何创建_Laravel ORM基础之Model创建与使用教程  邀请函制作网站有哪些,有没有做年会邀请函的网站啊？在线制作，模板很多的那种？  韩国服务器如何优化跨境访问实现高效连接？  香港服务器网站生成指南：免费资源整合与高速稳定配置方案  如何用y主机助手快速搭建网站？  Laravel怎么使用artisan命令缓存配置和视图  php静态变量怎么调试_php静态变量作用域调试技巧【解答】  Windows10电脑怎么设置虚拟光驱_Win10右键装载ISO镜像文件