Android 通过流播放声音

Android 通过流播放声音    AudioRecord和AudioTrack类是Android获取和播放音频流的重要类，放置在android.media包中。与该包中的 MediaRecorder和MediaPlayer类不同，AudioRecord和AudioTrack类在获取和播放音频数据流时无需通过文件保存 和文件读取，可以动态地直接获取和播放音频流，在实时处理音频数据流时非常有用。        当然，如果用户只想录音后写入文件或从文件中取得音频流进行播放，那么直接使用MediaRecorder和MediaPlayer类是首选，因为这 两个类使用非常方便，而且成功率很高。而AudioRecord和AudioTrack类的使用却比较复杂，我们发现很多人都不能成功地使用这两个类，甚 至认为Android的这两个类是不能工作的。        其实，AudioRecord和AudioTrack类的使用虽然比较复杂，但是可以工作，我们不仅可以很好地使用了这两个类，而且还通过套接字 （Socket）实现了音频数据的网络传输，做到了一端使用AudioRecord获取音频流然后通过套接字传输出去，而另一端通过套接字接收后使用 AudioTrack类播放。        下面是我们对AudioRecord和AudioTrack类在使用方面的经验总结：         （1）创建AudioRecord和AudioTrack类对象：创建这两个类的对象比较复杂，通过对文档的反复和仔细理解，并通过多次失败的尝 试，并在北理工的某个Android大牛的网上的文章启发下，我们也最终成功地创建了这两个类的对象。创建AudioRecord和AudioTrack 类对象的代码如下：        AudioRecord类： java代码： 1. m_in_buf_size =AudioRecord.getMinBufferSize(8000, 2. AudioFormat.CHANNEL_CONFIGURATION_MONO, 3. AudioFormat.ENCODING_PCM_16BIT); 4. m_in_rec = new AudioRecord(MediaRecorder.AudioSource.MIC,8000, 5. AudioFormat.CHANNEL_CONFIGURATION_MONO, 6. AudioFormat.ENCODING_PCM_16BIT, 7. m_in_buf_size) ; 复制代码 AudioTrack类： java代码： 1. m_out_buf_size = android.media.AudioTrack.getMinBufferSize(8000, 2. AudioFormat.CHANNEL_CONFIGURATION_MONO, 3. AudioFormat.ENCODING_PCM_16BIT); 4. m_out_trk = new AudioTrack(AudioManager.STREAM_MUSIC, 8000, 5. AudioFormat.CHANNEL_CONFIGURATION_MONO,AudioFormat.ENCODING_PCM_16BIT, 6. m_out_buf_size, 7. AudioTrack.MODE_STREAM); 复制代码 （2）关于AudioRecord和AudioTrack类的监听函数，不用也行。        （3）调试方面，包括初始化后看logcat信息，以确定类的工作状态，初始化是否成功等。        编写好代码，没有语法错误，调用模拟器运行、调试代码时，logcat发挥了很好的功用。刚调试时，经常会出现模拟器显示出现异常，这时我们可以在代码的 一些关键语句后添加如Log.d(“test1″,”OK”)；这样的语句进行标识，出现异常时我们就可以在logcat窗口观察代码执行到哪里出现异 常，然后进行相应的修改、调试。模拟器不会出现异常时，又遇到了录放音的问。录音方面，刚开始选择将语音编码数据存放在多个固定大小的文件中进行传送， 但是这种情况下会出现声音断续的现象，而且要反复的建立文件，比较麻烦，后来想到要进行网上传输，直接将语音编码数据以数据流的形式传送，经过验证，这种 方法可行并且使代码更加简洁。放音方面，将接收到的数据流存放在一个数组中，然后将数组中数据写到AudioTrack中。刚开始只是“嘟”几声，经过检 查发现只是把数据写一次，加入循环，让数据反复写到AudioTrack中，就可以听到正常的语音了。接下来的工作主要是改善话音质量与话音延迟，在进行 通话的过程中，观察logcat窗口，发现向数组中写数据时会出现Bufferflow的情况，于是把重心转移到数组大小的影响上，经过试验，发现 AudioRecord一次会读640个数据，然后就对录音和放音中有数组的地方进行实验修改。AudioRecord和AudioTrack进行实例化 时，参数中各有一个数组大小，经过试验这个数组大小和AudioRecord和AudioTrack能正常实例化所需的最小Buffer大小（即上面实例 化时的m_in_buf_size和m_out_buf_size参数）相等且服务器方进行缓存数据的数组尺寸是上述数值的2倍时，语音质量最好。由于录 音和放音的速度不一致，受到北理工大牛的启发，在录音方面，将存放录音数据的数组放到LinkedList中,当LinkedList中数组个数达到 2（这个也是经过试验验证话音质量最好时的数据）时，将先录好的数组中数据传送出去。经过上述反复试验和修改，最终使双方通话质量较好，且延时较短。 （4）通过套接字传输和接收数据        数据传送部分，使用的是套接字。通信双方，通过不同的端口向服务器发送请求，与服务器连接上后，开始通话向服务器发送数据，服务器通过一个套接字接收到一 方的数据后，先存在一个数组中，然后将该数组中数据以数据流的形式再通过另一个套接字传送到另一方。这样就实现了双方数据的传送。        （5）代码架构        为避免反复录入和读取数据占用较多资源，使程序在进行录放音时不能执行其他命令，故将录音和放音各写成一个线程类，然后在主程序中，通过MENU控制通话的开始、停止、结束。        最后说明，AudioRecord和AudioTrack类可以用，只是稍微复杂些。以下贴出双方通信的源码，希望对大家有所帮助：        主程序 java代码： 1. package eoe.demo; 2. import android.app.Activity; 3. import android.os.Bundle; 4. import android.view.Menu; 5. import android.view.MenuItem; 6. public class Daudioclient extends Activity { 7. public static final int MENU_START_ID = Menu.FIRST ; 8. public static final int MENU_STOP_ID = Menu.FIRST + 1 ; 9. public static final int MENU_EXIT_ID = Menu.FIRST + 2 ; 10. protected Saudioserver m_player ; 11. protected Saudioclient m_recorder ; 12. @Override 13. public void onCreate(Bundle savedInstanceState) { 14. super.onCreate(savedInstanceState); 15. setContentView(R.layout.main); 16. } 17. public boolean onCreateOptionsMenu(Menu aMenu) 18. { 19. boolean res = super.onCreateOptionsMenu(aMenu) ; 20. aMenu.add(0, MENU_START_ID, 0, “START”) ; 21. aMenu.add(0, MENU_STOP_ID, 0, “STOP”) ; 22. aMenu.add(0, MENU_EXIT_ID, 0, “EXIT”) ; 23. return res ; 24. } 25. public boolean onOptionsItemSelected(MenuItem aMenuItem) 26. { 27. switch (aMenuItem.getItemId()) { 28. case MENU_START_ID: 29. { 30. m_player = new Saudioserver() ; 31. m_recorder = new Saudioclient() ; 32. m_player.init() ; 33. m_recorder.init() ; 34. m_recorder.start() ; 35. m_player.start() ; 36. } 37. break ; 38. case MENU_STOP_ID: 39. { 40. m_recorder.free() ; 41. m_player.free() ; 42. m_player = null ; 43. m_recorder = null ; 44. } 45. break ; 46. case MENU_EXIT_ID: 47. { 48. int pid = android.os.Process.myPid() ; 49. android.os.Process.killProcess(pid) ; 50. } 51. break ; 52. default: 53. break ; 54. } 55. return super.onOptionsItemSelected(aMenuItem); 56. } 57. } 复制代码 录音程序Saudioclient： java代码： 1. package eoe.demo; 2. import java.io.DataOutputStream; 3. import java.io.IOException; 4. import java.net.Socket; 5. import java.net.UnknownHostException; 6. import java.util.LinkedList; 7. import android.media.AudioFormat; 8. import android.media.AudioRecord; 9. import android.media.MediaRecorder; 10. import android.util.Log; 11. public class Saudioclient extends Thread 12. { 13. protected AudioRecord m_in_rec ; 14. protected int m_in_buf_size ; 15. protected byte [] m_in_bytes ; 16. protected boolean m_keep_running ; 17. protected Socket s; 18. protected DataOutputStream dout; 19. protected LinkedList m_in_q ; 20. public void run() 21. { 22. try 23. { 24. byte [] bytes_pkg ; 25. m_in_rec.startRecording() ; 26. while(m_keep_running) 27. { 28. m_in_rec.read(m_in_bytes, 0, m_in_buf_size) ; 29. bytes_pkg = m_in_bytes.clone() ; 30. if(m_in_q.size() >= 2) 31. { 32. dout.write(m_in_q.removeFirst() , 0, m_in_q.removeFirst() .length); 33. } 34. m_in_q.add(bytes_pkg) ; 35. } 36. m_in_rec.stop() ; 37. m_in_rec = null ; 38. m_in_bytes = null ; 39. dout.close(); 40. } 41. catch(Exception e) 42. { 43. e.printStackTrace(); 44. } 45. } 46. public void init() 47. { 48. m_in_buf_size = AudioRecord.getMinBufferSize(8000, 49. AudioFormat.CHANNEL_CONFIGURATION_MONO, 50. AudioFormat.ENCODING_PCM_16BIT); 51. m_in_rec = new AudioRecord(MediaRecorder.AudioSource.MIC, 52. 8000, 53. AudioFormat.CHANNEL_CONFIGURATION_MONO, 54. AudioFormat.ENCODING_PCM_16BIT, 55. m_in_buf_size) ; 56. m_in_bytes = new byte [m_in_buf_size] ; 57. m_keep_running = true ; 58. m_in_q=new LinkedList(); 59. try 60. { 61. s=new Socket(“192.168.1.100″,4332); 62. dout=new DataOutputStream(s.getOutputStream()); 63. //new Thread(R1).start(); 64. } 65. catch (UnknownHostException e) 66. { 67. // TODO Auto-generated catch block 68. e.printStackTrace(); 69. } 70. catch (IOException e) 71. { 72. // TODO Auto-generated catch block 73. e.printStackTrace(); 74. } 75. } 76. public void free() 77. { 78. m_keep_running = false ; 79. try { 80. Thread.sleep(1000) ; 81. } catch(Exception e) { 82. Log.d(“sleep exceptions…\n”,”") ; 83. } 84. } 85. } 复制代码 放音程序Saudioserver： java代码： 1. package eoe.demo; 2. import java.io.DataInputStream; 3. import java.io.IOException; 4. import java.net.Socket; 5. import android.media.AudioFormat; 6. import android.media.AudioManager; 7. import android.media.AudioTrack; 8. import android.util.Log; 9. public class Saudioserver extends Thread 10. { 11. protected AudioTrack m_out_trk ; 12. protected int m_out_buf_size ; 13. protected byte [] m_out_bytes ; 14. protected boolean m_keep_running ; 15. private Socket s; 16. private DataInputStream din; 17. public void init() 18. { 19. try 20. { 21. s=new Socket(“192.168.1.100″,4331); 22. din=new DataInputStream(s.getInputStream()); 23. m_keep_running = true ; 24. m_out_buf_size = AudioTrack.getMinBufferSize(8000, 25. AudioFormat.CHANNEL_CONFIGURATION_MONO, 26. AudioFormat.ENCODING_PCM_16BIT); 27. m_out_trk = new AudioTrack(AudioManager.STREAM_MUSIC, 8000, 28. AudioFormat.CHANNEL_CONFIGURATION_MONO, 29. AudioFormat.ENCODING_PCM_16BIT, 30. m_out_buf_size, 31. AudioTrack.MODE_STREAM); 32. m_out_bytes=new byte[m_out_buf_size]; 33. // new Thread(R1).start(); 34. } 35. catch(Exception e) 36. { 37. e.printStackTrace(); 38. } 39. } 40. public void free() 41. { 42. m_keep_running = false ; 43. try { 44. Thread.sleep(1000) ; 45. } catch(Exception e) { 46. Log.d(“sleep exceptions…\n”,”") ; 47. } 48. } 49. public void run() 50. { 51. byte [] bytes_pkg = null ; 52. m_out_trk.play() ; 53. while(m_keep_running) { 54. try 55. { 56. din.read(m_out_bytes); 57. bytes_pkg = m_out_bytes.clone() ; 58. m_out_trk.write(bytes_pkg, 0, bytes_pkg.length) ; 59. } 60. catch(Exception e) 61. { 62. e.printStackTrace(); 63. } 64. } 65. m_out_trk.stop() ; 66. m_out_trk = null ; 67. try { 68. din.close(); 69. } catch (IOException e) { 70. // TODO Auto-generated catch block 71. e.printStackTrace(); 72. } 73. } 74. } 复制代码