G.726编码语音传输Android端代码

package prox.voiceshare; import java.io.BufferedOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.RandomAccessFile; import java.net.DatagramPacket; import java.net.InetAddress; import java.net.MulticastSocket; import java.net.UnknownHostException; import android.app.Activity; import android.app.ProgressDialog; import android.content.pm.ActivityInfo; import android.media.AudioFormat; import android.media.AudioManager; import android.media.AudioRecord; import android.media.AudioTrack; import android.media.MediaPlayer; import android.media.MediaRecorder; import android.os.AsyncTask; import android.os.Bundle; import android.os.Handler; import android.util.Log; import android.view.Menu; import android.view.MenuItem; import android.view.View; import android.widget.Button; import android.widget.Toast; public class voiceshare extends Activity { private Button StartRecordButton=null; //it needs to be a single-channel (monaural), //little-endian, unheadered 16-bit signed PCM audio file sampled at 16000 Hz. //44100Hz是当前唯一能保证在所有设备上工作的采样率，在一些设备上还有22050, 16000或11025。 static final int frequency = 8000; //8KHz static final int channelConfiguration = AudioFormat.CHANNEL_CONFIGURATION_MONO; static final int audioEncoding = AudioFormat.ENCODING_PCM_16BIT; int recBufSize=0; private AudioRecord audioRecord=null; int playBufSize=0; private AudioTrack audioTrack=null; public MediaPlayer AnswerPlayer=null; public Handler AudioRecordHandler=null; public Runnable AudioRecordTask=null; public boolean AudioRecordTimerRun=false; public String RawFilePath="/sdcard/VoiceshareRecord.pcm"; public File RawFile = null; public FileOutputStream RawFOStream=null; public BufferedOutputStream RawBOStream=null; public InputStream AnswerIStream = null; public FileInputStream AnswerFIStream=null; //------------------------------------------------- static final int VOICE_FRAME_SIZE=480; public String EncodeDataFilePath="/sdcard/VoiceshareEncodeResult.g726"; public String DecodeDataFilePath="/sdcard/VoiceshareDecodeResult.pcm"; //Multicast Encoded Voice Data!!! static String MultiSenderAddress="229.2.2.2"; static int MultiSenderPort=8888; static InetAddress IA=null; static MulticastSocket MultiReceiver=null; /** Called when the activity is first created. */ @Override public void onCreate(Bundle savedInstanceState) { //默认竖屏!!! super.setRequestedOrientation(ActivityInfo.SCREEN_ORIENTATION_PORTRAIT); super.onCreate(savedInstanceState); setContentView(R.layout.main); //16bits->recBufSize:1600 16bits->playBufSize:2972 8bits->playBufSize:1486 recBufSize = AudioRecord.getMinBufferSize(frequency,channelConfiguration, audioEncoding); Log.d("chenxupro", "recBufSize:"+recBufSize); //recBufSize:1600 if(recBufSize<0) { recBufSize=1600*3; //mBufferFrames = mBufferBytes / (numChannels * sampleBytes); } audioRecord = new AudioRecord(MediaRecorder.AudioSource.MIC, frequency, channelConfiguration, audioEncoding, recBufSize); playBufSize=AudioTrack.getMinBufferSize(frequency,channelConfiguration,audioEncoding); Log.d("chenxupro", "playBufSize:"+playBufSize); //playBufSize:1486 audioTrack = new AudioTrack(AudioManager.STREAM_MUSIC,frequency,channelConfiguration,audioEncoding,playBufSize,AudioTrack.MODE_STREAM); StartRecordButton=(Button)findViewById(R.id.StartRecordButton); StartRecordButton.setOnClickListener(new Button.OnClickListener() { @Override public void onClick(View v) { AudioRecordPD=new ProgressDialog(voiceshare.this); AudioRecordPD.setMessage("Please Speak..."); AudioRecordPD.show(); new AudioRecordTask().execute("Start"); } }); AudioRecordHandler = new Handler(); AudioRecordTask = new Runnable() { public void run() { //Stop!!! if (AudioRecordTimerRun) { //HideList(); AudioRecordTimerRun = false; } } }; try { IA = InetAddress.getByName(MultiSenderAddress); } catch(UnknownHostException e) { e.printStackTrace(); } try { MultiReceiver = new MulticastSocket(MultiSenderPort); } catch(IOException e) { e.printStackTrace(); } try { //MultiReceiver.setTimeToLive(255); MultiReceiver.setTimeToLive(2); //MultiReceiver.setReceiveBufferSize(10240); //MultiReceiver.setSoTimeout(10); //Wait 10ms!!! } catch (IOException e) { e.printStackTrace(); } try { MultiReceiver.joinGroup(IA); } catch (IOException e) { e.printStackTrace(); } } private ProgressDialog AudioRecordPD=null; private ProgressDialog AudioRecogPD=null; // 设置三种类型参数分别为String,Integer,String class AudioRecordTask extends AsyncTask<String, Integer, String> { // 可变长的输入参数，与AsyncTask.exucute()对应 @Override protected String doInBackground(String... params) { //Start!!! //Create New Raw File RawFile=new File(RawFilePath); try { RawFOStream = new FileOutputStream(RawFile); } catch (FileNotFoundException e) { e.printStackTrace(); } RawBOStream = new BufferedOutputStream(RawFOStream); byte[] RecordBuffer = new byte[recBufSize]; audioRecord.startRecording(); AudioRecordHandler.removeCallbacks(AudioRecordTask); AudioRecordTimerRun = true; //AudioRecordHandler.postDelayed(AudioRecordTask, 5000); while(AudioRecordTimerRun) { //1600->OK 960->OK!!!Has Lost??? int bufferReadResult = audioRecord.read(RecordBuffer, 0,VOICE_FRAME_SIZE*2); //480*2=960 Log.d("bufferReadResult", String.valueOf(bufferReadResult)); byte[] TmpBuf = new byte[bufferReadResult]; System.arraycopy(RecordBuffer, 0, TmpBuf, 0,bufferReadResult); short[] ou_dec_pcmbuf=new short[VOICE_FRAME_SIZE]; //decoder output short[] in_enc_pcmbuf=new short[VOICE_FRAME_SIZE]; //encoder input short[] ou_enc_unpacked=new short[VOICE_FRAME_SIZE]; //encoder output //byte[] TmpArr=new byte[VOICE_FRAME_SIZE*2]; byte[] TmpEnArr=new byte[VOICE_FRAME_SIZE/8*2]; VoiceEncode(TmpBuf, TmpEnArr); DatagramPacket packet = new DatagramPacket(TmpEnArr, VOICE_FRAME_SIZE/8*2,IA,MultiSenderPort); packet.setLength(VOICE_FRAME_SIZE/8*2); //480*2/8=120 try { MultiReceiver.send(packet); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } //RAEncodeFile.write(TmpEnArr, 0, VOICE_FRAME_SIZE/8*2); //480/8*2=120 /* try { RawBOStream.write(TmpBuf, 0, bufferReadResult); } catch (IOException e) { e.printStackTrace(); } */ } try { RawBOStream.close(); } catch (IOException e) { e.printStackTrace(); } try { RawFOStream.close(); } catch (IOException e) { e.printStackTrace(); } audioRecord.stop(); AudioRecordPD.dismiss(); //VoiceRecogByRawFile(RawFilePath); return "OK!"; } @Override protected void onCancelled() { super.onCancelled(); } @Override protected void onPostExecute(String result) { Toast.makeText(voiceshare.this, "Record OK!", Toast.LENGTH_SHORT).show(); //AudioRecogPD=new ProgressDialog(voiceshare.this); //AudioRecogPD.setMessage("Recoging..."); //AudioRecogPD.show(); //new AudioRecogTask().execute("Start"); ////new