/**
* @see
* @author Al_assad [email protected]
* @date 2016年11月17日 下午6:27:59
* @version V1.0  
* Description: 簡易音訊播放器（只支援AU，RA，WAV）
* 			   在不使用JMF的情況下快速實現音訊播放
* 
*/
import javax.sound.sampled.*;
import java.io.*;

public class MusicPlayer {
	private String musicPath; //音訊檔案
	private volatile boolean run = true;  //記錄音訊是否播放
	private Thread mainThread;   //播放音訊的任務執行緒
	
	private AudioInputStream audioStream;
	private AudioFormat audioFormat;
	private SourceDataLine sourceDataLine;
	
	public MusicPlayer(String musicPath) {
		this.musicPath = musicPath;
		prefetch();
	}
	
	//資料準備
	private void prefetch(){
		try{
		//獲取音訊輸入流
	    audioStream = AudioSystem.getAudioInputStream(new File(musicPath));
		//獲取音訊的編碼物件
		audioFormat = audioStream.getFormat();
		//包裝音訊資訊
		DataLine.Info dataLineInfo = new DataLine.Info(SourceDataLine.class,
				audioFormat,AudioSystem.NOT_SPECIFIED);
		//使用包裝音訊資訊後的Info類建立源資料行，充當混頻器的源
		sourceDataLine = (SourceDataLine)AudioSystem.getLine(dataLineInfo);
		
		sourceDataLine.open(audioFormat);
		sourceDataLine.start();
		
		}catch(UnsupportedAudioFileException ex){
			ex.printStackTrace();
		}catch(LineUnavailableException ex){
			ex.printStackTrace();
		}catch(IOException ex){
			ex.printStackTrace();
		}
		
	}
	//解構函式:關閉音訊讀取流和資料行
	protected void finalize() throws Throwable{
		super.finalize();
		sourceDataLine.drain();
		sourceDataLine.close();
		audioStream.close();
	}
	
	//播放音訊:通過loop引數設定是否迴圈播放
	private void playMusic(boolean loop)throws InterruptedException {
		try{
				if(loop){
					while(true){
						playMusic();
					}
				}else{
					playMusic();
					//清空資料行並關閉
					sourceDataLine.drain();
					sourceDataLine.close();
					audioStream.close();
				}
			
		}catch(IOException ex){
			ex.printStackTrace();
		}
		
		
	}
	private void playMusic(){
		try{
			synchronized(this){
				run = true;
			}
			//通過資料行讀取音訊資料流，傳送到混音器;
			//資料流傳輸過程：AudioInputStream -> SourceDataLine;
			audioStream = AudioSystem.getAudioInputStream(new File(musicPath));
			int count;
			byte tempBuff[] = new byte[1024];
			
				while((count = audioStream.read(tempBuff,0,tempBuff.length)) != -1){
					synchronized(this){
					while(!run)
						wait();
					}
					sourceDataLine.write(tempBuff,0,count);
							
			}

		}catch(UnsupportedAudioFileException ex){
			ex.printStackTrace();
		}catch(IOException ex){
			ex.printStackTrace();
		}catch(InterruptedException ex){
			ex.printStackTrace();
		}
		
	}
	
	
	//暫停播放音訊
	private void stopMusic(){
		synchronized(this){
			run = false;
			notifyAll();
		}
	}
	//繼續播放音樂
	private void continueMusic(){
		synchronized(this){
			 run = true;
			 notifyAll();
		}
	}
	
	
	//外部呼叫控制方法:生成音訊主執行緒；
	public void start(boolean loop){
		mainThread = new Thread(new Runnable(){
			public void run(){
				try {
					playMusic(loop);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
		mainThread.start();
	}
	
	//外部呼叫控制方法：暫停音訊執行緒
	public void stop(){
		new Thread(new Runnable(){
			public void run(){
				stopMusic();
				
			}
		}).start();
	}
	//外部呼叫控制方法：繼續音訊執行緒
	public void continues(){
		new Thread(new Runnable(){
			public void run(){
				continueMusic();
			}
		}).start();
	}

//Test
    public static void main(String[] args) throws InterruptedException{

        MusicPlayer player = new MusicPlayer("bgm/1.wav");   //建立音樂播放器
        
        player.start(true);                                        //以開始以迴圈的形式播放，player(false)為不迴圈播放
        
        TimeUnit.SECONDS.sleep(5);
        
        player.stop();                        //暫停播放音訊
        
        TimeUnit.SECONDS.sleep(4);
        
        player.continues();                //繼續開始播放音訊
        
    }

 }