java sound 简单播放器代码

package com.xzz.applet.service; import java.io.BufferedInputStream; import java.io.IOException; import java.net.Socket; import javax.sound.sampled.AudioFormat; import javax.sound.sampled.AudioSystem; import javax.sound.sampled.DataLine; import javax.sound.sampled.LineUnavailableException; import javax.sound.sampled.SourceDataLine; public class SimpleAudioPlayer { public SourceDataLine sdLine; public AudioFormat audioFormat; private PlayThread playThread; private Socket soc; public boolean stop = true; public SimpleAudioPlayer(Socket soc) throws LineUnavailableException { audioFormat = MyAudioFormat.getInstance(); DataLine.Info dataLineInfo = new DataLine.Info(SourceDataLine.class, audioFormat); sdLine = (SourceDataLine) AudioSystem.getLine(dataLineInfo); sdLine.open(); this.soc = soc; } public void start() throws IllegalRecordStateException { if (stop) { sdLine.start(); playThread = new PlayThread(); playThread.start(); } else { throw new IllegalRecordStateException( "Illegal playing state! Player is active at the time."); } } public void stop() { stop = true; playThread.stopService(); playThread = null; sdLine.stop(); } public void close(){ sdLine.close(); } class PlayThread extends Thread { private BufferedInputStream in; @Override public void run() { try { in = new BufferedInputStream(soc.getInputStream()); } catch (IOException e1) { e1.printStackTrace(); } byte[] buf = new byte[1024 * 1]; int readed = -1; try { while (stop) { if ((readed = in.read(buf)) > 0) { sdLine.write(buf, 0, readed); } else break; } } catch (Exception e) { e.printStackTrace(); } } public void stopService(){ try { in.close(); } catch (Exception e) { } } } }