2011-03-31 44 views
2

我正在處理聲音數據的應用程序系統。第一個應用程序只需從麥克風插孔讀取數據並將數據發送到下一個應用程序。主循環重複執行此代碼:爲什麼我的聲音滯後?

0 : Globals.mySleep(waitTime); // tells the thread to sleep for the proper amount of time for a given data format 
1 : inputLine.read(buffer, 0, bufferSize); // reads sound data from the microphone jack into buffer 
2 : if(connections.get(REGISTER) != null) { // if the next application is connected 
3 :  DataSlice slice = new DataSlice(buffer, serialIDCounter++, getDeviceName()); // create a slice of data to send, containing the sound data 
4 :  try{ 
5 :   connections.get(REGISTER).sendDataSlice(slice); // send the data to the next application. supposed to block until next application receives the data 
6 :   connections.get(REGISTER).flush(); // make sure data gets sent 
7 :  } catch (IOException e) { 
8 :   // Stream has been broken. Shut Down 
9 :   close(); 
10:  } 
11: } 

當我啓動系統時,它總是落後幾秒。如果我暫停系統(GUI應用程序告訴應用程序在輸入應用程序停止接收來自輸入應用程序的數據之後,所以輸入應用程序在暫停時應該在第5行阻止),等待然後再次播放,系統會滯後很長時間我剛剛停了下來。例如,如果它以10秒的延遲開始,然後暫停5秒並再次播放,則會滯後15秒。

當我將程序作爲可運行jar文件運行時,會發生這種情況。從Eclipse運行它時不會發生。

我已經在兩臺運行Ubuntu Linux 10.04 LTS的計算機上測試過它。它發生在一個,而不是另一個。儘管另一方面,當我嘗試從Eclipse運行它時,確實遇到了一個完全不同的問題。不知道該怎麼做。如果你想在電腦上看一些規格,我很樂意把它們給你。只要告訴我你想要什麼樣的規格以及如何獲得它們。

誰能告訴我什麼可能會導致滯後?謝謝。

- 編輯 -

每安德魯的建議下,我創造了什麼,我相信是一個SSCCE

import java.awt.event.MouseEvent; 
import java.awt.event.MouseListener; 

import javax.sound.sampled.*; 
import javax.swing.JButton; 
import javax.swing.JFrame; 
import javax.swing.JPanel; 

public class Main implements MouseListener{ 
    // Class that reads a signal from Line-in source and sends that signal 
    // to either a recorder module or the signal-viewing pipeline 
    public class PlayThread extends Thread { 

     byte[] buffer = new byte[bufferSize]; 
     boolean playing = false; 
     boolean connected = false; 

     PlayThread() {} 

     public void run() { 
      while(true) { 
       try { 
        sleep(waitTime); 
        inputLine.read(buffer, 0, bufferSize); 
        if(connected) { 
         while(!playing) 
          sleep(100); 
         int max = 0; 
         for(int i = 0; i < buffer.length; i++) { 
          if(Math.abs(buffer[i]) > max) 
           max = Math.abs(buffer[i]); 
         } 
         System.out.println("Max: " + max); 
        } 
       } catch (InterruptedException e) { 
        e.printStackTrace(); 
       } 
      } 
     } 

     public void setPlaying(boolean playing) { 
      this.playing = playing; 
     } 

     public void setConnected(boolean connected) { 
      this.connected = connected; 
     } 
    } 

    TargetDataLine inputLine; 
    AudioFormat format; 
    float sampleRate; 
    int sampleSizeBits; 
    int channels; 
    int waitTime; 
    int bufferSize; 
    int slicesPerSecond; 
    int windowSize = 512; 
    PlayThread pThread; 

    JFrame gui = new JFrame("Sound Lag"); 
    JPanel panel = new JPanel(); 
    JButton play = new JButton("Play"), pause = new JButton("Pause"), 
      connect = new JButton("Connect"), disconnect = new JButton("Disconnect"); 

    Main() { 
     sampleRate = 44100; 
     sampleSizeBits = 16; 
     channels = 2; 
     bufferSize = (sampleSizeBits/8)*channels*windowSize; 
     slicesPerSecond = (int) ((sampleRate/(float)channels)/(float)windowSize); 
     waitTime = (int)((((1000f/sampleRate)/(float)sampleSizeBits)/2f)*8f*(float)bufferSize); 

     play.addMouseListener(this); 
     pause.addMouseListener(this); 
     connect.addMouseListener(this); 
     disconnect.addMouseListener(this); 

     panel.add(play); 
     panel.add(pause); 
     panel.add(connect); 
     panel.add(disconnect); 
     gui.add(panel); 
     gui.setVisible(true); 
     gui.pack(); 
     gui.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); 
    } 

    public void read() { 
     // Open line from line-in 
     format = new AudioFormat(sampleRate, sampleSizeBits, channels, true, true); 

     // Obtain and open the lines. 
     inputLine = getTargetDataLine(); 

     pThread = new PlayThread(); 
     pThread.start(); 
    } 

    private TargetDataLine getTargetDataLine() { 
     try { 
      DataLine.Info info = new DataLine.Info(TargetDataLine.class, format); 
      for (Mixer.Info mi : AudioSystem.getMixerInfo()) { 
       TargetDataLine dataline = null; 
       try { 
        Mixer mixer = AudioSystem.getMixer(mi); 
        dataline = (TargetDataLine)mixer.getLine(info); 
        dataline.open(format); 
        dataline.start(); 
        return dataline; 
       } 
       catch (Exception e) {} 
       if (dataline != null) 
        try { 
         dataline.close(); 
        } 
        catch (Exception e) {} 
      } 
     } 
     catch (Exception e) {} 
     return null; 
    } 

    public static void main(String[] args) { 
     Main main = new Main(); 
     main.read(); 
    } 

    @Override 
    public void mouseClicked(MouseEvent arg0) { 
     if(arg0.getSource() == play) { 
      System.out.println("Playing"); 
      pThread.setPlaying(true); 
     } 
     else if(arg0.getSource() == pause) { 
      System.out.println("Paused"); 
      pThread.setPlaying(false); 
     } 
     else if(arg0.getSource() == connect) { 
      System.out.println("Connected"); 
      pThread.setConnected(true); 
     } 
     else if(arg0.getSource() == disconnect) { 
      System.out.println("Disconnected"); 
      pThread.setConnected(false); 
     } 
    } 

    @Override public void mouseEntered(MouseEvent arg0) {} 
    @Override public void mouseExited(MouseEvent arg0) {} 
    @Override public void mousePressed(MouseEvent arg0) {} 
    @Override public void mouseReleased(MouseEvent arg0) {} 
} 

此代碼生成與它的四個按鈕的窗口:播放,暫停,連接,並斷開連接。如果按下播放,就好像該節目處於「播放」模式。如果單擊連接,就好像聲音輸入應用程序已連接到下一個模塊。
要測試,請執行以下操作:
將聲音設備連接到麥克風插孔(但不要播放任何內容)。
從此代碼創建可運行jar文件。
從終端運行文件。
點擊「播放」。
點擊「連接」。

在這一點上,你應該看到一堆更小的數字沿着終端。

在您的音響設備上,開始播放聲音。

你應該立即開始在終端上看到更大的數字。

停止播放聲音設備上的聲音(應該返回到終端中的較小號碼)。
點擊「暫停」。
等5秒鐘。
點擊「播放」。

用音頻設備開始播放聲音。

這是錯誤發生的地方。如果我在Eclipse中運行此代碼,我會立即再次獲得更大的數字。如果我只是運行jar文件,那麼會有5秒的延遲,然後我會得到更大的數字。

有沒有什麼新想法?

回答

2

它已修復。每當我想讓聲音流(每當我按下播放)時,我都會關閉當前流並打開一個新流。

我沒有意識到TargetDataLine實際上保存了一個聲音數據的緩衝區,只要讀取方法被調用,就可以從中讀取聲音數據。

它看起來像我從Eclipse運行應用程序時,它使用的是不同類型的TargetDataLine,而不是將它作爲可運行jar文件運行時。這由緩衝區之間的大小差異來證明。儘管大小差異只是大約2倍,所以我認爲問題不在於緩衝區的大小,而在於與獲取的TargetDataLine有關的其他問題。

奇怪的是,刪除Globals.mySleep(waitTime)在修復SSCCE中起作用,但不是它應該表示的真正程序。

我試過排水和沖洗線,而不是取代它,但這些似乎都沒有工作,雖然我可能一直在錯誤地使用它們。

所以問題是:DataLine的緩衝區被填滿,而程序沒有播放時,緩衝區沒有被清空,所以當它開始播放時,它繼續以通常的播放速率從緩衝區獲取數據,導致它落後。

解決方案是:當程序開始播放時,替換DataLine。

- 編輯 -

進一步觀察表明,當我從Eclipse中運行,它似乎是使用不同的JRE比當我作爲一個jar文件。我將默認的java程序設置爲java-6-sun而不是java-6-openjdk,並且它可以在jar文件中正常工作。

另外,我試着運行替換另一臺計算機上的DataLine的方法。在這臺電腦上,我收到了一個令人討厭的信號。這似乎需要更長的時間來拉一個新的DataLine,所以我決定這是行不通的。現在,我只是簡單地從DataLine中讀取數據。如果系統暫停,我不會在任何地方發送信號。

+0

發佈答案的好通話。很高興你對問題進行了整理。 :-) – 2011-05-07 16:39:18

1

我發現在這種情況下最好的做法是,你的代碼很慢,但你不知道爲什麼要使用profiler,http://www.quest.com/jprobe/software_download.aspx你可以得到這個java profiler的免費路徑,它會告訴你一行行花了多少時間以及執行了多少次,你應該能夠準確地確定你用這個編碼減慢了什麼。

希望這有助於 埃蒙·

+0

謝謝,Eamonn。根據我發現的情況(我的文章中的一些編輯應該反映出這一點),我不認爲這是一個性能問題。 – BCarpe 2011-03-31 15:38:43

1

Globals.mySleep(WAITTIME); //告訴線程的時間適量睡眠對於一個給定的數據格式

嫌疑的「適當」 waitTime這裏是「0」。

如果你想要更多的懷疑,我建議你發佈SSCCE(沒有行號)。

+0

謝謝,安德魯。我發佈了我認爲是SSCCE的內容。 – BCarpe 2011-03-31 17:04:45