關(guān)于采用UDP協(xié)議傳輸音頻的代碼.docx

關(guān)于采用UDP協(xié)議傳輸音頻的代碼請(qǐng)高手指教package, importpackage com.android.test;import java.io.File;import .DatagramPacket;import .DatagramSocket;import .InetAddress;import android.app.Activity;import android.media.AudioFormat;import android.media.AudioManager;import android.media.AudioRecord;import android.media.AudioTrack;import android.media.AudioTrack.OnPlaybackPositionUpdateListener;import android.media.MediaRecorder;import android.os.AsyncTask;import android.os.Bundle;import android.util.Log;import android.view.View;import android.view.View.OnClickListener;import android.widget.Button;import android.widget.TextView;public class TestRecroderUDP extends Activity implements OnClickListener /* Called when the activity is first created. */Button startRecording, stopRecording, startPlaying, stopPlaying;boolean isRecording = false;/ 是否錄放的標(biāo)記boolean isPlaying = false;RecordAudio recordTask;PlayAudio playTask;TextView statusTextView;File recordingFile;byte tmpBuf = null;Overridepublic void onCreate(Bundle savedInstanceState) super.onCreate(savedInstanceState);setContentView(R.layout.main);statusTextView = (TextView) this.findViewById(R.id.TextView);startRecording = (Button) this.findViewById(R.id.startRecording);startRecording.setOnClickListener(this);stopRecording = (Button) this.findViewById(R.id.stopRecording);stopRecording.setOnClickListener(this);startPlaying = (Button) this.findViewById(R.id.startPlaying);startPlaying.setOnClickListener(this);stopPlaying = (Button) this.findViewById(R.id.stopPlaying);stopPlaying.setOnClickListener(this);stopRecording.setEnabled(false);startPlaying.setEnabled(false);stopPlaying.setEnabled(false);/*File path = new File(Environment.getExternalStorageDirectory() .getAbsolutePath();path.mkdirs();try recordingFile = File.createTempFile(recording, .pcm, path); catch (IOException e) throw new RuntimeException(Could not create file on SD card, e);*/Overridepublic void onClick(View v) / TODO Auto-generated method stubif (v = startRecording) record(); else if (v = stopRecording) stopRecording(); else if (v = startPlaying) play(); else if (v = stopPlaying) stopPlaying();public void play() startPlaying.setEnabled(false);playTask = new PlayAudio();playTask.execute();stopPlaying.setEnabled(true);statusTextView.setText(playTask.getStatus().toString();public void stopPlaying() isPlaying = false;stopPlaying.setEnabled(false);startPlaying.setEnabled(true);/ playTask.cancel(isPlaying);statusTextView.setText(playTask.getStatus().toString();public void record() startRecording.setEnabled(false);stopRecording.setEnabled(true);startPlaying.setEnabled(true);recordTask = new RecordAudio();recordTask.execute();statusTextView.setText(recordTask.getStatus().toString();public void stopRecording() isRecording = false;/ startRecording.setEnabled(true);stopRecording.setEnabled(false);statusTextView.setText(recordTask.getStatus().toString();private class PlayAudio extends AsyncTask Overrideprotected Void doInBackground(Void. params) / TODO Auto-generated method stub isPlaying = true; int bufferSize = AudioTrack.getMinBufferSize(8000, AudioFormat.CHANNEL_CONFIGURATION_MONO, AudioFormat.ENCODING_PCM_16BIT); byte audiodata = new bytebufferSize; System.arraycopy(tmpBuf, 0, audiodata, 0, tmpBuf.length); try / DataInputStream dis = new DataInputStream( new / BufferedInputStream(new FileInputStream( recordingFile); AudioTrack audioTrack = new AudioTrack( AudioManager.STREAM_MUSIC, 8000, AudioFormat.CHANNEL_CONFIGURATION_MONO, AudioFormat.ENCODING_PCM_16BIT, bufferSize, AudioTrack.MODE_STREAM); DatagramSocket s = new DatagramSocket(8648); DatagramPacket packet = new DatagramPacket(audiodata, audiodata.length); boolean listen = true; audioTrack.play(); while (listen) s.receive(packet); s.close(); audioTrack.play(); audioTrack.setPlaybackPositionUpdateListener(new OnPlaybackPositionUpdateListener() Override public void onMarkerReached(AudioTrack audioTrack) / TODO Auto-generated method stub Override public void onPeriodicNotification(AudioTrack audioTrack) / TODO Auto-generated method stub );/audioTrack.write(audiodata,0,audiodata.length);/audioTrack.write(packet.getData(),0,audiodata.length); startPlaying.setEnabled(false); stopPlaying.setEnabled(true); catch (Exception e) Log.e(audioTrack, Playing failed); return null;class RecordAudio extends AsyncTask Overrideprotected Void doInBackground(Void. params) / TODO Auto-generated method stub isRecording = true; try / DataOutputStream dos = new DataOutputStream( / new BufferedOutputStream(new / FileOutputStream(recordingFile); int bufferSize = AudioRecord.getMinBufferSize(8000, AudioFormat.CHANNEL_CONFIGURATION_MONO, AudioFormat.ENCODING_PCM_16BIT); AudioRecord audioRecord = new AudioRecord( MediaRecorder.AudioSource.MIC, 8000, AudioFormat.CHANNEL_CONFIGURATION_MONO, AudioFormat.ENCODING_PCM_16BIT, bufferSize); byte buffer = new bytebufferSize; audioRecord.startRecording(); int bufferReadResult = 0; int r = 0; while (isRecording) bufferReadResult = audioRecord.read(buffer, 0, buffer.length); /* * for (int i = 0; i bufferReadResult; i+) * dos.writeByte(bufferi); */ tmpBuf = new bytebufferReadResult; System.arraycopy(buffer, 0, tmpBuf, 0, bufferReadResult); publishProgress(new Integer(r); r+; audioRecord.stop(); / dos.close(); DatagramSocket ds = new DatagramSocket(); DatagramPacket pack = new DatagramPacket(tmpBuf, bufferReadResult, InetAddress.getByName(), 8648); ds.send(pack); ds.close(); catch (Throwable t) Log.e(AudioRecord, Recording failed); return null;