import java.io.IOException;
import java.io.InputStream;
import javax.sound.sampled.AudioFormat;
import javax.sound.sampled.AudioInputStream;
import javax.sound.sampled.AudioSystem;
import javax.sound.sampled.DataLine;
import javax.sound.sampled.SourceDataLine;
import javax.sound.sampled.UnsupportedAudioFileException;

public class Mp3Player {
    private InputStream fis;
    private boolean flag;
    private Thread thread;

    public Mp3Player(InputStream fis, boolean flag) {
        System.out.println(fis);
        this.fis = fis;
        this.flag = flag;
        new Player();
    }

    public Thread getThread() {
        return thread;
    }

    public class Player implements Runnable {
        public Player() {
            thread = new Thread(this);
            thread.start();
        }

        public void run() {
            while (true) {
                try {
                    // File file =new File(fis.getFile());
                    AudioInputStream audioInputStream = AudioSystem
                            .getAudioInputStream(fis);
                    AudioFormat audioFormat = audioInputStream.getFormat();
                    // 转换mp3文件编码

                    if (audioFormat.getEncoding() != AudioFormat.Encoding.PCM_SIGNED) {

                        audioFormat = new AudioFormat(
                                AudioFormat.Encoding.PCM_SIGNED,

                                audioFormat.getSampleRate(), 16, audioFormat

                                .getChannels(), audioFormat.getChannels() * 2,

                                audioFormat.getSampleRate(), false);

                        audioInputStream = AudioSystem.getAudioInputStream(
                                audioFormat,

                                audioInputStream);

                    }
                    // 打开输出设备

                    DataLine.Info dataLineInfo = new DataLine.Info(

                    SourceDataLine.class, audioFormat,

                    AudioSystem.NOT_SPECIFIED);

                    SourceDataLine sourceDataLine = (SourceDataLine) AudioSystem
                            .getLine(dataLineInfo);

                    sourceDataLine.open(audioFormat);

                    sourceDataLine.start();

                    int cnt;
                    byte tempBuffer[] = new byte[320];
                    while ((cnt = audioInputStream.read(tempBuffer, 0,
                            tempBuffer.length)) != -1) {
                        if (cnt > 0) {
                            // 写入缓存数据
                            sourceDataLine.write(tempBuffer, 0, cnt);
                        }

                    }
                    // Block等待临时数据被输出为空
                    sourceDataLine.drain();
                    sourceDataLine.close();
                    if (!flag)
                        break;
                } catch (Exception e) {
                    e.printStackTrace();
                    break;
                }
            }
        }
    }
    public static void main(String[] args) throws UnsupportedAudioFileException, IOException{
        new Mp3Player(Mp3Player.class.getResourceAsStream("/...superpqckages/sounds/pcm-8000-16-2.wav"), true);
    }
}