audioplaystream.java

java语音聊天系统 分为服务器端 客户端 连接之后 既可以相互通信 包括语音 摄像头

package PC;

import	java.io.*;
import	javax.sound.sampled.*;

// OutputStream that writes its data to the soundcard output
public class AudioPlayStream extends OutputStream implements LineListener {

	private AudioFormat m_format;
	private SourceDataLine m_line;
	private int m_bufferSize;
	private boolean immediateStop=false;
	private LineListener m_listener;

	public AudioPlayStream(AudioFormat format) {
		super();
		m_format=format;
		if (Debug.TRACE) {
			//Debug.println(this, "<init> with format="+format);
		}
	}
	
	public void setListener(LineListener ll) {
		m_listener=ll;
	}

	public void update(LineEvent event) {
		if (m_listener!=null) {
			m_listener.update(event);
		}
		if (Debug.TRACE) {
			if (event.getType().equals(LineEvent.Type.STOP)) {
				//Debug.println("Play: Stop");
			} else if (event.getType().equals(LineEvent.Type.START)) {
				//Debug.println("Play: Start");
			} else if (event.getType().equals(LineEvent.Type.OPEN)) {
				//Debug.println("Play: Open");
			} else if (event.getType().equals(LineEvent.Type.CLOSE)) {
				//Debug.println("Play: Close");
			}
		}
	}

	// opens the sound hardware
	public void open() throws Exception {
		DataLine.Info info = new DataLine.Info(SourceDataLine.class, m_format);

		// get and open the target data line for capture.
		m_line = null;
		try {
			m_line = (SourceDataLine) AudioSystem.getLine(info);
			m_line.addLineListener(this);
			if (Debug.DEBUG) {
				//Debug.println(this, "open(): Got SourceDataLine "+m_line.getClass());
			}
			m_bufferSize=(int) (m_format.getSampleRate()/4); // 125ms
			// align buffer size to integral frames
			m_bufferSize-=m_bufferSize % m_format.getFrameSize();
			m_line.open(m_format, m_bufferSize);
			if (Debug.DEBUG) {
				//Debug.println(this, "open(): opened SourceDataLine ");
			}
			m_bufferSize=m_line.getBufferSize();
		} catch (LineUnavailableException ex) {
			throw new Exception("Unable to open the line: "+ex.getMessage());
		}
		immediateStop=false;
	}


	public void setImmediateStop(boolean value) {
		immediateStop=value;
	}

	public void start() throws Exception {
		m_line.flush();
		m_line.start();
		immediateStop=false;
	}

	public void close() throws IOException {
		close(immediateStop);
	}

	public void close(boolean immediately) throws IOException {
		if (m_line!=null) {
			if (Debug.TRACE) {
				//Debug.println(this, "close(immediate="+immediately+")");
			}
			if (!immediately) {
				drain();
			} else {
				m_line.stop();
				flush();
			}
			if (m_line!=null) {
				m_line.close();
				m_line=null;
			}
		}
		m_bufferSize=0;
		immediateStop=false;
	}

	public void write(int b) throws IOException {
		byte[] hack=new byte[1];
		hack[0]=(byte) b;
		write(hack);
	}

	public void write(byte[] b, int off, int len) throws IOException {
		if (m_line==null) {
			throw new IOException("Output line is closed.");
		}
		int res=m_line.write(b, off, len);
		if (Debug.TRACE_READWRITE) {
			//Debug.println(this, "write: "+res+" bytes.");
		}
	}

	public void flush() throws IOException {
		if (m_line!=null) {
			if (Debug.TRACE) {
				//Debug.println(this, "flush()");
			}
			immediateStop=true;
			m_line.flush();
			synchronized (this) {
				notifyAll(); // interrupt any drain going on
			}

		}
	}

	public synchronized void drain() {
		if (m_line!=null && m_line.isActive()) {
			long t=0;
			long waitTime=AMAudioFormat.bytes2Ms(m_bufferSize, m_format)+50;
			if (Debug.DEBUG || Debug.TRACE) {
				//Debug.println(this, "drain() simulation ("+waitTime+"ms...");
				t=System.currentTimeMillis();
			}
			try {
				wait(waitTime);
			} catch (InterruptedException ie) {}

			if (Debug.TRACE) {
				//Debug.println(this, "drain() exit: "+(System.currentTimeMillis()-t)+"ms");
			}
		}
	}

	public int getBufferSize() {
		return m_bufferSize;
	}
}